【正文】 } public void windowClosing(WindowEvent e){//exit program ()。 } }}//窗口關(guān)閉事件適配器class ChatFrame_WindowAdapter extends { ChatRoomClient chatFrame。 } public void keyPressed(KeyEvent e){//鍵擊 Enter 鍵，發(fā)送信息！ int j=()。 } }}//文本筐 textField2 的鍵擊事件適配器class textField2_KeyAdapter extends { ChatRoomClient chatFrame。 }public void keyPressed(KeyEvent e){//輸入的是 enter，開始連接！ int j=()。 } }}//文本筐 textField1 的鍵擊事件適配器class textField1_KeyAdapter extends { ChatRoomClient chatFrame。 ()。 try{//close IOstream ()。 ()。 ()。 try{//服務(wù)器退出關(guān)閉連接和相關(guān)的 流 ()。 }catch(InterruptedException ei){ processMsg(())。 } (1000)。 stopRun()。 while(isTrue){ try{ msg=()。 }public void run(){ String msg。 } public void processMsg(String msg){//客戶端處理消息 (msg)。 }private void button2_actionPerformed(ActionEvent e){//發(fā)送按鈕 sendInformation()。 ()。 ()。 processMsg(Connect failed!)。 out=new PrintWriter(())。 if(sock!=null){//connection successed processMsg(Connect successfully!)。 (panel2,)。 (panel1,)。//frame is registered to WindowListener (new BorderLayout())。 (button2)。 (label1)。 //textField2:for input message。//panel2 //press button2: 發(fā)送 to send message (new (){ public void actionPerformed(ActionEvent e){ button2_actionPerformed(e)。 (textField1)。be registered to KeyListener. //press key:Enter to connect the Client to Server (new textField1_KeyAdapter(this))。 } })。 textArea=new TextArea()。 panel2=new Panel()。 label1=new Label(消息:)。 textField1=new TextField(input Server address here!)。 } private void jbInit(){//should set size,position and Font of every ponentbutton1=new Button(連接)。 } } public static void main(String[] args){//main method ChatRoomClient c=new ChatRoomClient()。//thread can go on runing ??public ChatRoomClient(){ try{ jbInit()。 //create Thread to Read information from Server Thread readThread。 Socket sock。 // PrintWriter out。 TextArea textArea。 TextField textField1,textField2。public class ChatRoomClient extends Frame implements Runnable{ Panel panel1,panel2。import .*。//reference to the method exit() in ChatRoomServer. }}import .*。 public ChatFrame_WindowAdapter(ChatRoomServer chatFrame){ =chatFrame。//清除以發(fā)送的信息} try{ (100)。 broadcast(broadcastInfor)。j++){ string=(String)(j)。//客戶名 //讀取每個連接線程的信息棧并把信息發(fā)送出去 for(int j=0。 msgStack=。i()。 (str)。k()。 //()。 chatClients=。//broadcast information=ClientName+string。//information in inforStack String ClientName。 CommunicateThread Thread2。//信息棧 ClientMsg。 chatClients。 }catch(Exception e){。 }public void sendInformation(String str){//發(fā)送信息 try{ (str)。} } }public void writeInformation(String infor){//寫信息棧 (infor)。//在 Clients 中清除本線程序 。 ()。} finally{ try{ ()。 try{ (100)。 }else if(infor!=null){ writeInformation(infor)。 if((Client exit!)){ writeInformation(infor)。 }public void run(){ String infor。 return。 }catch(IOException ei){ try{ ()。 try{ in=new BufferedReader(new InputStreamReader(()))。 index2=index。//public CommunicateThread(Socket Sock,ChatRoomServer cFrame,int index){ ClientSock=Sock。//run() inforStack。 ChatRoomServer chatFrame。 protected BufferedReader in=null。 } }public static void main(String[] args){ ChatRoomServer chat=new ChatRoomServer()。 try{ ()。} }catch(IOException e){ processMsg(())。//version2 (Thread+i)。 i++。//創(chuàng)建線程保持連接 (ct)。 try{ while(true){ Socket ClientSock=()。//廣播線程 ()。//啟動接受連接的線程 ()。 ClientsInfor=new ()。 } processMsg(Server listening on port:+DEFAULT_PORT)。 }catch(IOException e){ processMsg(())。 }public void processMsg(String str){// (str)。 ()。 (sPanel,)。//注冊到繼承了窗口適配器的類 (600,600)。 (button1)。 (new (){//退出按鈕注冊 public void actionPerformed(ActionEvent e){ button1_actionPerformed(e)。 button1=new Button(退出)。 sPanel=new ScrollPane()。 } ServerListen()。 public ChatRoomServer(){ try{ jbInit()。//記錄連接的線程 ClientsInfor。//廣播 thread。//默認(rèn)端口號 Thread chatAcceptThread。 // ServerSocket ServerSock。 TextArea textArea。public class ChatRoomServer extends Frame implements Runnable{ Panel panel。import .*。 圖 20 服務(wù)器被停止 圖 21 服務(wù)器停止后的客戶端附 錄附錄 A 源程序主要代碼import .*。圖 18 系統(tǒng)客戶端若在運行過程中有用戶退出客戶端，則服務(wù)器端會有該用戶已退出的提示，并且當(dāng)前在線人數(shù)會自動減 1，在此為 user2 退出。圖 17 系統(tǒng)服務(wù)器端用戶可以通過登錄界面進(jìn)入到聊天室，即系統(tǒng)的客戶端。圖 16 管理員登錄界面進(jìn)入到服務(wù)器端后啟動服務(wù)器。 } sendClients(people)。i++){ Connect c=(Connect)(i)。 for(int i=0。 String constr=”當(dāng)前在線人數(shù)為+ activeConnects”。 服務(wù)器顯示在線用戶人數(shù)public void notifyRoom(){ StringBuffer people=new StringBuffer(PEOPLE)。 }catch(InterruptedException ex){} } }catch(Exception e){} }}首先，服務(wù)器端得到每個連接上的客戶端信息棧，讀取每個連接線程信息棧并把信息發(fā)送出去。 } ()。 broadcastInfor=ClientName++string。j()。 ClientName=(String)(i)。i++){ Thread1=(CommunicateThread)(i)。 服務(wù)器轉(zhuǎn)發(fā)信息public void run(){ try{ while(true){ for(int i=0。 (button2)。 (label1)。 } })。}()。display(connect successfully!++())。address=()。((userInfo))。StringBuffer info=new StringBuffer(INFO:)。fromServer=newBufferedReader(new I