server_services_of_chat_room_by_Java.doc

Java聊天室项目的服务器端 server services of chat room by Java基于shocket类似dos界面的importjava.io.*;.*;importjava.util.*;classCustomerimplementsSerializableStringcustname;Stringmsgofsay;Stringflag;publicclassChatServerimplementsRunnableServerSocketserversocket;/创建服务器套接字ThreadserverThread;publicChatServer()/构造符tryserversocket=newServerSocket(1001);/在1001端口监听客户请求catch(IOExceptione)System.out.println(无法启动服务器！+e);tryserverThread=newThread(this);System.out.println(Serverstarted.);serverThread.start();/启动服务器线程catch(Exceptione)System.out.println(不能启动线程+e);publicvoidrun()trywhile(true)Socketfromclient=serversocket.accept();/利用accept()监听客户端请求，并获得客户端套接字Connectioncon=newConnection(fromclient);/与客户端进行通信catch(IOExceptione)System.out.println(服务器无法侦听到客户端！+e);publicstaticvoidmain(Stringargs)newChatServer();classConnectionextendsThreadCustomercustsend;SocketnetClient;ObjectInputStreamstreamfromClient;ObjectOutputStreamstreamtoClient;staticmsgm=newmsg();publicConnection(Socketclient)netClient=client;trystreamfromClient=newObjectInputStream(netClient.getInputStream();/返回InputStream即输入流，该输入流的源是客户端套接字streamtoClient=newObjectOutputStream(netClient.getOutputStream();/返回OutputStream即输出流，该输出流的目标是客户端套接字，将该输出流包装到打印输出流即toClientcatch(IOExceptione)trynetClient.close();/关闭套接字catch(IOExceptione1)System.err.println(客户端已经断开！+e1);custsend=newCustomer();custsend.custname=Server;custsend.flag=Connect;custsend.msgofsay=欢迎进入公共聊天室！;trystreamtoClient.writeObject(custsend);catch(Exceptione2)System.out.println(cantsendtoclient);System.out.println(e2);StreamInsi=newStreamIn(m);/读出msgsi.start();StreamOutso=newStreamOut(m);/写入msgso.start();classStreamInextendsThread/从客户端写入vectorCustomercusttemp;publicStreamIn(msgm)publicvoidrun()trywhile(true)custtemp=(Customer)streamfromClient.readObject();/从客户端读一个对象m.writeMsg(custtemp);System.out.println(custtemp.custname+says:+custtemp.msgofsay);catch(Exceptione)System.out.println(服务器与客户端断开了，请重新打开客户端！+e);classStreamOutextendsThread/读出vector到客户端intlCount=0;Customercusttemp;publicStreamOut(msgm)publicvoidrun()trywhile(true)custtemp=m.readMsg(lCount);lCount+;streamtoClient.writeObject(custtemp);catch(Exceptione1)custtemp.custname=custtemp.custname;custtemp.flag=Logout;custtemp.msgofsay=已经断线离开了！;m.writeMsg(custtemp);trynetClient.close();catch(IOExceptionioe)System.out.println(cantclosessocket);System.out.println(ioe);System.out.println(不能发送到客户端！+e1);staticclassmsgstaticintmsgCount=0;staticVectormsgBox=newVector(1,1);publicsynchronizedvoidwriteMsg(Customertemp)msgBox.addElement(temp);msgCount+;notifyAll();publicsynchronizedCustomerreadMsg(intlCount)Customertemp;while(lCount=msgCount)trywait();catch(InterruptedExceptioni