main.java

局域网聊天系统的设计与实现

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package list;


import broadcast.Receive;
import java.util.logging.Level;
import java.util.logging.Logger;
import lanchat.GUIchat;
import lanchat.Mserver;

/**
 *
 * @author Administrator
 */
public class main extends Thread{
        private login log;
        private Receive re;
        private list ls ;
        private int flag =0;
        private String name = null;


        //构造方法
        public main() throws Exception{
            log = new login();
            while(log.getflag()){
                Thread.sleep(100);//等待 输入用户名完成
            }
            re = new Receive(); //开启 广播信息 接收程序
            re.start();
            ls = new list();    //开启在线list
            
        }

   
        public void run(){
            while(true){
            try {
                name = re.gethostname();
                flag = re.getar();//将receive的flag 赋值过去
                if (name != null) {
                    if (flag == 1) {
                        ls.additem(name); // 调用添加用户函数
                        flag = 0;
                        re.setar(0);
                    }
                    if (flag == 2) {
                        ls.removeitem(name);//嚼用删除 用户函数
                        flag = 0;
                        re.setar(0);
                    }
                    
                }
                if(Mserver.flag == 1){//添加 一个 点到点 登入信息 的item
                        ls.additem(Mserver.name);
                        Mserver.flag = 0;
                        Mserver.name = null;
                    }
                if(Mserver.flag == 2){//打开相对应的聊天框
                        ls.comitem(Mserver.name);
                        //System.out.println(Mserver.m);
                        if(Mserver.guichat[Mserver.m] == null)//防止弹出多个相同窗口
                            Mserver.guichat[Mserver.m] = new GUIchat(Mserver.name);
                        Mserver.flag = 0;
                        Mserver.name = null;
                        
                    }
                name = null;
                Thread.sleep(400);//没400MS 一循环，比Mserver快100MS ，使Mserver有足够时间获得正确的m
            } catch (InterruptedException ex) {
                Logger.getLogger(main.class.getName()).log(Level.SEVERE, null, ex);
            }
            }
        }

        public static void main(String args[]) throws Exception {
            
            new main().start();
            Mserver.server();
        }

}