黑马程序员技术交流社区

标题: 多线程实现点对点聊天 [打印本页]
作者: Aaron9527    时间: 2016-6-8 23:58
标题: 多线程实现点对点聊天
  1. package cn.itcast.点对点实现多线程聊天;

  3. import java.io.InputStream;
  4. import java.io.OutputStream;
  5. import java.net.Socket;
  6. import java.util.Scanner;

  8. public class Client {
  9.         public static void main(String[] args) throws Exception{
  10.                 Scanner sc = new Scanner(System.in);
  11.                 Socket socket = new Socket("127.0.0.1",8888);
  12.                 System.out.println("欢迎登陆熊熊客户端，祝您聊的开心！");
  13.                 OutputStream out = socket.getOutputStream();
  14.                
  15.                 new ClientThread(socket).start();
  16.                 //InputStream intput = socket.getInputStream();
  17.         //        byte [] byteArray = new byte[1024];//不必每次都创建一个长度为1024的数组，
  18.                 //它是不断的读取写入，所以只需要一个就够了
  19.         //        int len = 0;
  20.                 while(true){
  21.                         System.out.println("键盘轻点，距离不再遥远，对服务器说点什么吧！");
  22.                         String str = sc.next();
  23.                         out.write(str.getBytes());
  24.                         if(str.equals("over")){
  25.                                 break;
  26.                         }
  27.         //                len = intput.read(byteArray);
  28.         //                str = new String(byteArray,0,len);
  29.         //                System.out.println("服务器悄悄对你说:"+"\r\n"+str);
  30.                        
  31.                 }
  32.                 System.out.println("客户端结束，下次要记得熊熊噢~");
  33.                 System.exit(0);
  34.                 socket.close();
  35.                
  36.         }
  37. }


  40. package cn.itcast.点对点实现多线程聊天;

  42. import java.io.OutputStream;
  43. import java.net.ServerSocket;
  44. import java.net.Socket;
  45. import java.util.Scanner;
  46. public class Server {
  47.         public static void main(String[] args) throws Exception{
  48.                 Scanner sc = new Scanner(System.in);
  49.                 ServerSocket server = new ServerSocket(8888);
  50.                 Socket socket = server.accept();
  51.                 System.out.println("欢迎登陆熊熊服务器，祝您聊的开心~");
  52.         //        InputStream input = socker.getInputStream();
  53.                 OutputStream output = socket.getOutputStream();
  54.                 new ServerThread(socket).start();
  55.         //        byte [] byteArray = new byte[1024];
  56.         //        int len =0;
  57.                 while(true){
  58.                         //读取从客户端来的数据
  59.         //                len=input.read(byteArray);
  60.         //                String str = new String(byteArray,0,len);
  61.         //                System.out.println("客户端悄悄对你说"+"\r\n"+str);
  62.                        
  63.                         System.out.println("键盘轻点，距离不再遥远，对客户端说点什么吧！");
  64.                         String        str =sc.next();
  65.                         output.write(str.getBytes());
  66.                         if(str.equals("over")){
  67.                                 break;
  68.                         }
  69.                
  70.                        
  71.                 }
  72.                 System.out.println("客户端结束，下次要记得熊熊噢~");
  73.                 System.exit(0);
  74.                 socket.close();
  75.                 server.close();
  76.         }
  77. }


  80. package cn.itcast.点对点实现多线程聊天;

  82. import java.io.IOException;
  83. import java.io.InputStream;
  84. import java.net.Socket;

  86. /*
  87. * 客户端线程：
  88. *                 主要职责：从网络接收数据
  89. * */
  90. public class ClientThread extends Thread {
  91.         // 我需要接收数据，就需要Socket，这里得想办法搞出一个Socket对象
  92.         private Socket socket;

  94.         public ClientThread(Socket socket) {
  95.                 this.socket = socket;
  96.         }

  98.         public void run() {
  99.                 try {
  100.                         InputStream input = socket.getInputStream();
  101.                         int len = 0;
  102.                         byte[] byteArray = new byte[1024];
  103.                         while (true) {
  104.                                 len = input.read(byteArray);
  105.                                 String str = new String(byteArray, 0, len);
  106.                                 System.out.println("有来自服务端的新消息：" + "\r\n" + str);
  107.                                 if (str.equals("over")) {
  108.                                         System.out.println("客户端结束，下次要记得熊熊噢~");
  109.                                         System.exit(0);
  110.                                 }
  111.                         }
  112.                 } catch (IOException e) {
  113.                         e.printStackTrace();
  114.                 }
  115.         }
  116. }


  119. package cn.itcast.点对点实现多线程聊天;

  121. import java.io.IOException;
  122. import java.io.InputStream;
  123. import java.net.Socket;

  125. /*
  126. * 服务端：接收数据
  127. * */
  128. public class ServerThread extends Thread{
  129.         private Socket socket;
  130.         public ServerThread(Socket socket){
  131.                 this.socket=socket;
  132.         }
  133.         public void run(){
  134.                 try {
  135.                         InputStream input = socket.getInputStream();
  136.                         int len =0;
  137.                         byte [] byteArray = new byte[1024];
  138.                         while(true){
  139.                                 len = input.read(byteArray);
  140.                                 String str = new String(byteArray,0,len);
  141.                                 System.out.println("有来自客户端的新消息：" + "\r\n" + str);
  142.                                 if(str.equals("over")){
  143.                                         System.out.println("客户端结束，下次要记得熊熊噢~");
  144.                                         System.exit(0);
  145.                                 }
  146.                         }
  147.                 } catch (IOException e) {
  148.                         e.printStackTrace();
  149.                 }
  150.         }
  151. }
复制代码




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