java聊天程序源代碼

java聊天程序源代碼，簡單點(diǎn)，盡量帶注釋，注釋越多越好謝謝。懸賞分:20-解決時(shí)間：2010-8-216:12哥哥姐姐們盡量帶多點(diǎn)的注釋，我是初學(xué)者，謝謝了提問者：無傷一號-二—級-最佳答案服務(wù)端：importjava.io.*;.*;importjava.util.*;publicclassChatServer{booleanstat=false;ServerSocketss=null;ListvCIient>clients=newArrayListvCIient>();〃用于存客戶端publicstaticvoidmain(String[]args){newChatServer().start();}publicvoidstart(){try{ss=newServerSocket(8888);stat=true;}catch(BindExceptione){//Sever端已經(jīng)運(yùn)行，當(dāng)重復(fù)運(yùn)行時(shí)拋異常System.out.println("端口正在使用中。。。。")；System.out.println("請關(guān)掉相關(guān)程序并重新運(yùn)行服務(wù)器！");〃還會拋別的異常，所以直接關(guān)閉窗口System.exit(O);}catch(IOExceptione){e.printStackTrace();}try{while(stat){Sockets=ss.accept();System.out.println("aclientconnected!");〃測試語句寫在最左邊，以后沒用可以刪除或注掉Clientc=newClient(s); 〃每建立一個(gè)客戶端，就new一個(gè)客戶端對象，啟動一個(gè)線程newThread(c).start();clients.add(c);〃勿忘寫，將每個(gè)客戶端加入到容器里}}catch(lOExceptione){e.printStackTrace();}finally{try{ss.close();}catch(IOExceptione){e.printStackTrace();}}}classClientimplementsRunnable{privateSockets;privateDataInputStreamdis;privateDataOutputStreamdos;privatebooleancont=false;publicClient(Sockets){this.s=s;try{dis=newDataInputStream(s.getlnputStream());//初始化dos=newDataOutputStream(s.getOutputStream());cont=true;}catch(IOExceptione){e.printStackTrace();}}publicvoidsend(Stringstr){〃用于發(fā)送給客戶端try{dos.writeUTF(str);}catch(IOExceptione){clients.remove(this);〃移除那個(gè)退出的對象System.out.println("—個(gè)客戶退出了”)；//e.printStackTrace();}}publicvoidrun(){try{while(cont){Stringstr=dis.readUTF();〃阻塞式方法System.out.println(str);for(inti=0;i<clients.size();i++){Clientc=clients.get(i);〃取客戶端c.send(str);}/* 另外兩種方法，但不適用，它會鎖定服務(wù)端for(lteratorvClient>it=clients.iterator();it.hasNext();){Clientc=it.next();c.send(str);}IteratorvClient>it=clients.iterator();while(it.hasNext()){Clientc=it.next();c.send(str);}*/}}catch(EOFExceptione){ 〃readUTF()阻塞式方法，所以關(guān)閉客戶端會拋異常System.out.println("Clientclosed!");}catch(lOExceptione){e.printStackTrace();}finally{try{if(dis!=nuII)dis.close();if(dos!=nuII)dos.close();if(s!=null){s.close();s=null;〃更嚴(yán)格的方法，等于空就沒人去用了，垃圾收集器就回收走}}catch(lOExceptione){e.printStackTrace();}}}}}客戶端:importjava.awt.*;importjava.awt.event.*;importjava.io.*;.*;publicclassChatClientextendsFrame{Sockets=null;DataOutputStreamdos=null;DatalnputStreamdis=null;privatebooleancont=false;TextFieldtfTxt=newTextField();TextAreataContent=newTextArea();ThreadtRecv=newThread(newRecvThread());publicstaticvoidmain(String[]args){newChatClient().launchFrame();}publicvoidlaunchFrame(){setLocation(400,300);this.setSize(300,300);add(tfTxt,BorderLayout.SOUTH);add(taContent,BorderLayout.NORTH);pack();〃包在一起，去掉中間空著的this.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){disconnect();System.exit(0);}});tfTxt.addActionListener(newTfListent());setVisible(true);connect();tRecv.start(); 〃啟動線程}publicvoidconnect(){try{s=newSocket("",8888);〃注意不要定義成Sockets,這就成了局部變量而不是成員變量了System.out.println("connected!");dos=newDataOutputStream(s.getOutputStream());dis=newDataInputStream(s.getInputStream());cont=true;}catch(UnknownHostExceptione){e.printStackTrace();}catch(IOExceptione){e.printStackTrace();}}publicvoiddisconnect(){try{dos.close();dis.close();s.close();}catch(IOExceptione){e.printStackTrace();}/*〃無法解決readUTF阻塞式方法try{cont=false;〃關(guān)閉線程tRecv.join();〃合并線程，徹底讓他停止}catch(InterruptedExceptione){e.printStackTrace();}finally{try{dos.close();〃線程停止之后才能關(guān)流，不然拋SocketException異常dis.close();s.close();}catch(IOExceptione){e.printStackTrace();}}*/}privateclassTfListentimplementsActionListener{publicvoidactionPerformed(ActionEvente){Stringstr=tfTxt.getText().trim();tfTxt.setText("");try{dos.writeUTF(str);dos.flush();}catch(lOExceptione1){e1.printStackTrace();}}}privateclassRecvThreadimplementsRunnable{publicvoidrun(){try{while(cont){Stringstr=dis.readUTF();taContent.setText(taContent.getText()+str+'\n');}}catch