java_Socket通信_聊天程序

1、ackagemyfistsocket;/*一个作为Server*/importjava.io.*;.*;classMynewServerpublicstaticvoidmain(Stringargs)throwsIOExceptionServerSockets=newServerSocket(6666);System.out.println(服务器端中);Socketsocket二s.accept();System.out.println(开始：+socket);GetMessagegm=newGetMessage(socket);SendMessagesm=newSendMessage(so

2、cket);Threadgt二newThread(gm);Threadst二newThread(sm);gt.start();st.start();/接收消息classGetMessageimplementsRunnableBufferedReaderin;publicGetMessage(Socketsocket)tryin=newBufferedReader(newInputStreamReader(socket.getlnputStream();catch(IOExceptione)e.printStackTrace();publicvoidrun()Stringstr=;while(t

3、rue)trystr=in.readLine();catch(IOExceptione)e.printStackTrace();if(str.equals(q)break;System.out.print(客户端回应说：+str);/发送消息classSendMessageimplementsRunnablePrintWriterout;BufferedReaderis;publicSendMessage(Socketsocket)throwsIOExceptionout二newPrintWriter(newBufferedWriter(newOutputStreamWriter(socket

4、.getOutputStream(),true);is=newBufferedReader(newInputStreamReader(System.in);publicvoidrun()Stringinput二newString();while(true)tryinput二is.readLine().trim();catch(IOExceptione)e.printStackTrace();System.out.print(服务器说：);packagemyfistsocket;/*一个作为importimportClient*/java.io.*;.*;publicclassMynewClie

5、ntpublicstaticvoidmain(Stringargs)throwsIOExceptionInetAddressaddr=InetAddress.getByName();Socketsocket二newSocket(addr,6666);System.out.println(socket二+socket);CGetMessagegm=newCGetMessage(socket);CSendMessagesm=newCSendMessage(socket);Threadgt二newThread(gm);Threadst二newThread(sm);gt.start();st.star

6、t();/接收消息classCGetMessageimplementsRunnableprivateSocketsocket;BufferedReaderin;publicCGetMessage(Socketsocket)this.socket=socket;publicvoidrun()BufferedReaderin;Stringstr=;while(true)tryin=newBufferedReader(newInputStreamReader(socket.getlnputStream();str=in.readLine();catch(IOExceptione)e.printSta

7、ckTrace();System.out.println(服务器回应说：+str);/发送消息classCSendMessageimplementsRunnablePrintWriterout;BufferedReaderis;publicCSendMessage(Socketsocket)throwsIOExceptionout二newPrintWriter(newBufferedWriter(newOutputStreamWriter(socket.getOutputStream(),true);is=newBufferedReader(newInputStreamReader(System.in);publicvoidrun()Stringinput二newString();while(true)tryinput二i