【正文】 on=ClientName+string。public BroadcastThread(ChatRoomServer cFrame){ chatFrame2=cFrame。 chatClients=。 ClientMsg=。 //()。 } public void broadcast(String str){//廣播 for(int k=0。k()。k++){//send to everyone 分別調(diào)用每個連接線程 ，發(fā)送信息 Thread2=(CommunicateThread)(k)。 (str)。 } }public void run(){ try{ while(true){ for(int i=0。i()。i++){ Thread1=(CommunicateThread)(i)。 msgStack=。//得到每個連接的信息棧 ClientName=(String)(i)。//客戶名 //讀取每個連接線程的信息棧并把信息發(fā)送出去 for(int j=0。j()。j++){ string=(String)(j)。 broadcastInfor=ClientName++string。 broadcast(broadcastInfor)。 } //clear the inforStack ()。//清除以發(fā)送的信息} try{ (100)。//version2 }catch(InterruptedException ex){} } }catch(Exception e){} }}//處理窗口關閉事件的適配器class ChatFrame_WindowAdapter extends { ChatRoomServer chatFrame。 public ChatFrame_WindowAdapter(ChatRoomServer chatFrame){ =chatFrame。 } public void windowClosing(WindowEvent e){//exit program ()。//reference to the method exit() in ChatRoomServer. }}import .*。import .*。import .*。import .*。public class ChatRoomClient extends Frame implements Runnable{ Panel panel1,panel2。 Button button1,button2。 TextField textField1,textField2。 Label label1。 TextArea textArea。 ScrollPane sPanel。 // PrintWriter out。 BufferedReader in=null。 Socket sock。 public final static int DEFAULT_PORT=6666。 //create Thread to Read information from Server Thread readThread。 boolean isTrue=true。//thread can go on runing ??public ChatRoomClient(){ try{ jbInit()。 }catch(Exception e){ ()。 } } public static void main(String[] args){//main method ChatRoomClient c=new ChatRoomClient()。 ()。 } private void jbInit(){//should set size,position and Font of every ponentbutton1=new Button(連接)。// set Font button2=new Button(發(fā)送)。 textField1=new TextField(input Server address here!)。 textField2=new TextField(input Message here and send to Server)。 label1=new Label(消息:)。 panel1=new Panel()。 panel2=new Panel()。 sPanel=new ScrollPane()。 textArea=new TextArea()。//panel1 //press button1: 連接 to connect the Client to Server (new (){ public void actionPerformed(ActionEvent e){ button1_actionPerformed(e)。 } })。 //textField1:for input the address of Server。be registered to KeyListener. //press key:Enter to connect the Client to Server (new textField1_KeyAdapter(this))。//() (button1)。 (textField1)。//sPanel ScrollPane (textArea)。//panel2 //press button2: 發(fā)送 to send message (new (){ public void actionPerformed(ActionEvent e){ button2_actionPerformed(e)。 } })。 //textField2:for input message。be registered to KeyListener. //press key:Enter to send message (new textField2_KeyAdapter(this))。 (label1)。 (textField2)。 (button2)。//frame (new ChatFrame_WindowAdapter(this))。//frame is registered to WindowListener (new BorderLayout())。 (500,400)。 (panel1,)。 (sPanel,)。 (panel2,)。 //()} public void startConnect(){//開始連接 try{ sock=new Socket((),DEFAULT_PORT)。 if(sock!=null){//connection successed processMsg(Connect successfully!)。 } in=new BufferedReader(new InputStreamReader(()))。 out=new PrintWriter(())。 }catch(IOException ex){ processMsg(())。 processMsg(Connect failed!)。 }readThread=new Thread(this)。 ()。 }//public void endConnect(){//close IOstream public void sendInformation(){ (())。 ()。}private void button1_actionPerformed(ActionEvent e){//連接按鈕 startConnect()。 }private void button2_actionPerformed(ActionEvent e){//發(fā)送按鈕 sendInformation()。 }public void stopRun(){//to stop the running thread isTrue=false。 } public void processMsg(String msg){//客戶端處理消息 (msg)。 (\n)。 }public void run(){ String msg。 isTrue=true。 while(isTrue){ try{ msg=()。 if((Server exit!)){//Server exit processMsg(msg)。 stopRun()。//終止線程 }else if(msg!=null){ processMsg(msg)。 } (1000)。 }catch(IOException e){ processMsg(())。 }catch(InterruptedException ei){ processMsg(())。 } } //endConnect()。 try{//服務器退出關閉連接和相關的 流 ()。 ()。 ()。 }catch(IOException ioe){} }public void exit(){//窗口關閉；如果有連接則關閉連接和相關的流 try{//send Client exit! to Server! (Client exit!)。 ()。 }catch(Exception exc){} //endConnect()。 try{//close IOstream ()。 ()。 ()。 }catch(IOException ioe){} finally{ (0)。 } }}//文本筐 textField1 的鍵擊事件適配器class textField1_KeyAdapter extends { ChatRoomClient chatFrame。public textField1_KeyAdapter(ChatRoomClient chatFrame){ =chatFrame。 }public void keyPressed(KeyEvent e){//輸入的是 enter，開始連接！ int j=()。 if(j==){ ()。 } }}//文本筐 textField2 的鍵擊事件適配器class textField2_KeyAdapter extends { ChatRoomClient chatFrame。public textField2_KeyAdapter(ChatRoomClient chatFrame){ =chatFrame。 } public void keyPressed(KeyEvent e){//鍵擊 Enter 鍵，發(fā)送信息！ int j=()。 if(j==){ ()。 } }}//窗口關閉事件適配器class ChatFrame_WindowAdapter extends { ChatRoomClient chatFrame。 public ChatFrame_WindowAdapter(ChatRoomClient chatFrame){ =chatFrame。 } public void windowClosing(WindowEvent e){//exit program ()。//reference to the method exit() in ChatRoomClient. }