【正文】 ULT_PORT 6666 默認(rèn)端口號 Thread chatAcceptThread 啟動接受連接的線程 BroadcastThread broadcastThread 廣播 thread run when Server is listening JavautilVector Clients 記錄連接的線程 JavautilVector ClientsInfor 記錄連接線程的信息 public static int index 0 public ChatRoomServer try jbInit catch Exception e eprintStackTrace ServerListen 服務(wù)器開始監(jiān)聽 private void jbInit 初始化界面 panel new Panel sPanel new ScrollPane textArea new TextArea Server information\n button1 new Button 退出 sPaneladd textArea button1addActionListener new JavaawteventActionListener 退出按鈕注冊 public void actionPerformed ActionEvent e button1_actionPerformed e paneladd button1 thisaddWindowListener new ChatFrame_WindowAdapter this 注冊到繼承了窗口適配器的類 thissetSize 600600 thissetLayout new BorderLayout thisadd sPanelBorderLayoutCENTER thisadd panelBorderLayoutSOUTH thisshow private void button1_actionPerformed ActionEvent e exit public void processMsg String str textAreaappend str private void ServerListen try ServerSock new ServerSocket DEFAULT_PORT catch IOException e processMsg etoString processMsg Server failed\n processMsg Server listening on portDEFAULT_PORT Clients new JavautilVector ClientsInfor new JavautilVector chatAcceptThread new Thread this 啟動接受連接的線程 chatAcceptThreadstart broadcastThread new BroadcastThread this 廣播線程 broadcastThreadstart 還有一個回收無用連接 thread 的線程 public void run 接受連接并記錄線程信息 int i 0 try while true Socket ClientSock ServerSockaccept CommunicateThread ct new CommunicateThread ClientSockthisindex 創(chuàng)建線程保持連接 Clientsadd ct record Communicate Thread i indexversion2 ClientsInforadd Threadi processMsg Threadijoin in\n catch IOException e processMsg etoString public void exit broadcastThreadbroadcast Server exit try ServerSockclose catch IOException ioe finally Systemexit 0 public static void main String[] args ChatRoomServer chat new ChatRoomServer class CommunicateThread extends Thread 保持連接線程 protected Socket ClientSock protected BufferedReader in null protected PrintWriter out ChatRoomServer chatFrame boolean isTrue truerun JavautilVector inforStack int index2 public CommunicateThread Socket SockChatRoomServer cFrameint index ClientSock Sock chatFrame cFrame index2 index inforStack new JavautilVector try in new BufferedReader new InputStreamReader ClientSockgetInputStream out new PrintWriter ClientSockgetOutputStream catch IOException ei try ClientSockclose catch IOException ei2 chatFrameprocessMsg eitoString return thisstart public void run String infor try while isTrue infor inreadLine if inforequals Client exit writeInformation infor 把信息寫到信息棧以倍廣播出去 stopRun else if infor null writeInformation infor else break try Threadsleep 100 version2 catch InterruptedException ex catch IOException e finally try inclose outclose ClientSockclose chatFrameClientsremove index2 在 Clients 中清除本線程序 ChatRoomServerindex catch IOException ei public void writeInformation String infor 寫信息棧 inforStackadd infor private void stopRun 終止線程 isTrue false public void sendInformation String str 發(fā)送信息 try outprintln str outflush catch Exception e class BroadcastThread extends Thread 廣播線程 ChatRoomServer chatFrame2 JavautilVector chatClients 連接線程 信息 JavautilVector msgStack 信息棧 JavautilVector ClientMsg 記錄客戶發(fā)送的信息 CommunicateThread Thread1 CommunicateThread Thread2 String stringinformation in inforStack String ClientNameClient thread name String broadcastInforbroadcast information ClientNamestring public BroadcastThread ChatRoomServer cFrame chatFrame2 cFrame chatClients chatFrame2Clients ClientMsg chatFrame2ClientsInfor thisstart public void broadcast String str 廣播 for int k 0k chatClientssize k send to everyone 分別調(diào)用每個連接 線程發(fā)送信息 Thread2 CommunicateThread chatClientsget k Thread2sendInformation str public void run try while true for int i 0i chatClientssize i Thread1 CommunicateThread chatClientsget i msgStack Thread1inforStack 得到每個連接的信息棧 ClientName String ClientMsgget i 客戶名 讀取每個連接線程的信息棧并把信息發(fā)送出去 for int j 0j msgStacksize j string String msgStackget j broadcastInfor ClientName string broadcast broadcastInfor clear the inforStack msgStackremoveAllElements 清除以發(fā)送的信息 try Threadsleep 100 version2 catch InterruptedException ex catch Exception e 處理窗口關(guān)閉事件的適配器 class ChatFrame_WindowAdapter extends JavaawteventWindowAdapter ChatRoomServer chatFrame public ChatFrame_WindowAdapter ChatRoomSe