Java TCP通信：服务端接受多个客户端

た入场券 2022-11-26 14:00 374阅读 0赞

# 实现一个服务端可以同时接收多个客户端的消息 #

需要在服务端引入多线程。  
每接收一个客户端的Socket通道，就为它分配一个独立的线程来处理它的消息。  
如此便可实现一个服务端可以同时接收多个客户端的消息。

*  服务端

import java.io.BufferedReader;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class ServerDemo { 
        public static void main(String[] args) throws Exception{ 
            System.out.println("———————服务端启动———————");
            //1.注册端口：public ServerSocket(int port)
            ServerSocket serverSocket = new ServerSocket(8888);
            //2.定义一个循环不断接受客户端的连接请求
            while (true) { 
                //3.开始等待接受客户端的Socket管道连接
                Socket accept = serverSocket.accept();
                new ServerReaderThread(accept).start();
            }
        }
    }
    
    class ServerReaderThread extends Thread{ 
        private Socket socket;
    
        public ServerReaderThread(Socket socket){ 
            this.socket = socket;
        }
    
        @Override
        public void run() { 
            try { 
                //3.从socket通信管道中得到一个字节输入流
                InputStream is = socket.getInputStream();
                //4.把字节输入流转换成字符输入流
                InputStreamReader isr = new InputStreamReader(is);
                //5.把字符输入流包装为缓冲字符输入流
                BufferedReader br = new BufferedReader(isr);
                //6.按照行读取消息
                String line;
                while ((line = br.readLine())!= null){ 
                    System.out.println(socket.getRemoteSocketAddress()+"说："+line);
                }
            }catch (Exception e){ 
                System.out.println("客户端"+socket.getRemoteSocketAddress()+"下线了。");
            }
        }
    }

*  客户端

import java.io.OutputStream;
    import java.io.PrintStream;
    import java.net.Socket;
    import java.util.Scanner;
    
    public class ClientDemo { 
        public static void main(String[] args) throws Exception{ 
            //1.客户端请求于服务端的socket管道连接
            Socket socket = new Socket("127.0.0.1", 8888);
            //2.从socket通信管道中得到一个字节输入流
            OutputStream os = socket.getOutputStream();
            //3.包装为高级打印流
            PrintStream ps = new PrintStream(os);
            //4.开始发送消息出去
            while(true){ 
                Scanner sc = new Scanner(System.in);
                System.out.print("请输入消息：");
                ps.println(sc.nextLine());
                ps.flush();
            }
        }
    }