黑马程序员技术交流社区

标题: 一个java小程序 [打印本页]
作者: 请许我一世安宁    时间: 2015-10-26 21:18
标题: 一个java小程序
  1. /*
  2. 这是一个能实现两个人聊天的小程序
  3. */
  4. import java.net.*;
  5. import java.io.*;
  6. class Chat{
  7.         public static void main(String[] args)throws Exception{
  8.                
  9.                 ServerSocket ss = new ServerSocket(10002);
  10.                 new Thread(new ServerThread(ss)).start();
  11.                 try{
  12.                         Thread.sleep(5000);
  13.                         Socket s = new Socket("192.168.1.71",10001);
  14.                         Thread t = new Thread(new ClientThread(s));
  15.                         t.start();
  16.                 }
  17.                 catch (Exception e){
  18.                         throw new RuntimeException("线程出现异常");
  19.                 }
  20.         }
  21. }
  22. class ClientThread implements Runnable{
  23.         private Socket s;
  24.         public ClientThread(Socket s){
  25.                 this.s = s;
  26.         }
  27.         public void run(){
  28.                 BufferedReader bufr = null;
  29.                 BufferedWriter bufOut = null;
  30.                 try{
  31.                         bufr = new BufferedReader(new InputStreamReader(System.in));
  32.                         bufOut = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
  33.                         String line = null;
  34.                         while((line=bufr.readLine())!=null){
  35.                                 if (line.equals("exit")) {  
  36.                     System.out.print("发送完毕");  
  37.                     bufOut.write(line);  
  38.                     bufOut.flush();  
  39.                     s.shutdownOutput();  
  40.                     break;  
  41.                 }  
  42.                                 bufOut.write(line);
  43.                                 bufOut.newLine();
  44.                                 bufOut.flush();
  45.                         }
  46.                         bufOut.close();
  47.                         s.close();
  48.                 }
  49.                 catch (Exception e){
  50.                         throw new RuntimeException("发送消息失败");
  51.                 }
  52.         }
  53. }
  54. class ServerThread implements Runnable{
  55.         private ServerSocket ss;
  56.         BufferedWriter bufOut = null;
  57.         public ServerThread(ServerSocket ss){
  58.                 this.ss = ss;
  59.         }
  60.         public void run(){
  61.                 Socket s;
  62.                 try{
  63.                         s = ss.accept();
  64.                 }
  65.                 catch (Exception ee){
  66.                         throw new RuntimeException("服务端建立失败");
  67.                 }
  68.                 String ip = s.getInetAddress().getHostAddress();
  69.                
  70.                 try{
  71.                         System.out.println(ip+".....connected");
  72.                         BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
  73.                         //PrintWriter ps = new PrintWriter(s.getOutputStream(),true);
  74.                         String str = null;
  75.                         while((str=bufIn.readLine())!=null){
  76.                                 if("exit".equals(str)){
  77.                                         System.out.println(s.getInetAddress().getHostName()+"发送的消息"+str);
  78.                                         break;
  79.                                 }
  80.                                 System.out.println(s.getInetAddress().getHostAddress()+"发送的消息"+str);           
  81.                         }
  82.                         s.shutdownInput();
  83.                         bufOut = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
  84.                         bufOut.write("服务器已接收到消息");
  85.                         bufOut.flush();
  86.                         s.shutdownOutput();
  87.                         s.close();
  88.                 }
  89.                 catch(Exception e){
  90.                         throw new RuntimeException("接收消息失败");
  91.                 }
  92.                 finally{
  93.                         if(bufOut!=null){
  94.                                 try        {
  95.                                         bufOut.close();
  96.                                 }
  97.                                 catch (Exception e){
  98.                                         e.printStackTrace();
  99.                                 }
  100.                         }
  101.                         if(s!=null){
  102.                                 try{
  103.                                         s.close();
  104.                                 }
  105.                                 catch (Exception e){
  106.                                         e.printStackTrace();
  107.                                 }
  108.                         }
  109.                         if(ss!=null){
  110.                                 try{
  111.                                         ss.close();
  112.                                 }
  113.                                 catch (Exception e){
  114.                                         e.printStackTrace();
  115.                                 }
  116.                         }
  117.                 }
  118.         }
  119. }

  121.                
复制代码


作者: ppaapc    时间: 2015-10-26 21:57
有点意思



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2