java实现多人聊天对话室

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.ScheduledThreadPoolExecutor;

/**

  * @author: Ren

  * @date: 2020-08-03  15:23

  * @description:

  */

public class TcpserverC2 {

     public static void main(String[] args) throws IOException {

//        定义多线程，让多个用户都可以参与到聊天室

         ExecutorService pool = new ScheduledThreadPoolExecutor( 10 );

//        绑定端口

         ServerSocket serverSocket = new ServerSocket( 8888 );

//        利用循环一直来读取新的socket

         while ( true ) {

//            开始serversocket侦听请求，这方法会阻塞等待tcp请求的到来，一旦到来，就返回

             Socket accept = serverSocket.accept();

             pool.execute( new Runnable() {

                 Socket socket = accept;

//                定义字节数组来读取输入流

                 byte [] buf = new byte [ 1024 ];

                 @Override

                 public void run() {

//                    定义输入输出流

                     InputStream in = null ;

                     OutputStream out = null ;

                     try {

                         in = socket.getInputStream();

                         out = socket.getOutputStream();

                         while ( true ) {

                             int len = in.read(buf);

                             System.out.println( "服务器收到：" + new String(buf, 0 , len, ( "utf-8" )));

                             // 聊天室服务端一般不会参与对话，所以一般不加这个功能

//                            String xitongshuohua = scanner.nextLine();

//                            out.write("谢谢".getBytes(Charset.forName("utf-8")));

                             out.write( "谢谢" .getBytes(( "utf-8" )));

                         }

                     } catch (IOException e) {

                         e.printStackTrace();

                     }

                 }

             });

         }

     }

}

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.Socket;

import java.util.Scanner;

/**

  * @author: Ren

  * @date: 2020-08-03  15:23

  * @description:

  */

public class TcpClientC2 {

     public static void main(String[] args) throws IOException {

//        目标地址，目标端口

         Socket socket = new Socket( "127.0.0.1" , 8888 );

         InputStream in = socket.getInputStream();

         OutputStream out = socket.getOutputStream();

         Scanner scanner = new Scanner(System.in);

         byte [] buf = new byte [ 1024 ];

         while ( true ) {

             String word = scanner.nextLine();

             out.write(word.getBytes(( "utf-8" )));

             int lrn = in.read(buf);

             System.out.println( "服务端回复：" + new String(buf, 0 ,lrn,( "utf-8" )));

         }

     }

}