main.java

P2P聊天系统 该程序是由NetBeans IDE 6.5

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

package MServer;


import chatGUI.chat;
import chatGUI.list;
import chatGUI.login;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
import multicast.Receive;

/**
 *
 * @author Administrator
 */
public class main extends Thread{

        login log;
        Receive re;
        list ls;
        Mserver ms;
        chat []chats = new chat[256];
        //构造方法
        public main() throws Exception{
            log = new login();
            while(log.getflag()){
                Thread.sleep(100);//等待 输入用户名完成
            }
            re = new Receive(log.getusername()); //开启 广播信息 接收程序
            re.start();
            ms =new Mserver(chats);//服务器线程启动
            ms.start();
            ls = new list(log.getusername(),chats);    //开启在线list
        }
        public void run(){
            while(true){
            try {
                String name = re.gethostname();
                boolean msflag = false;
                int flag = 0;
                flag= re.getflag();
                if(flag ==0){
                    flag = ms.getflag();
                    if(flag != 0){
                        msflag = true;
                        name = ms.gethostname();
                    }
                }
                if (name != null) {
                    if (flag == 1) {
                        //System.out.println(name);
                        ls.additem(name); // 调用添加用户函数
                        flag = 0;
                        if (msflag){
                            ms.setflag(0);
                            msflag = false;
                        }else
                            re.setflag(0);
                    }
                    if (flag == 2) {
                        ls.removeitem(name);//调用删除用户函数
                        flag = 0;
                        re.setflag(0);
                    }
                    name = null;
                }
                Thread.sleep(400);
            } 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();
        }

}