服务器同时处理多个客户端

Dear 丶 2021-11-11 15:54 412阅读 0赞

要服务器同时支持多个客户端的连接，就必须加入多线程的处理机制，

将每一个连接的客户端都创建一个新的线程对象

![20190806082237460.png][]

package com.vince;
    
    import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /**
     * 处理多个客户端
     * 主线程用于监听客户端的连接，每次有连接成功，开启一个线程来处理该客户端的消息
     */
    public class MutilServerDemo {
        public static void main(String[] args) {
            //线程池  开辟3个线程
            ExecutorService es = Executors.newFixedThreadPool(3);
            try {
                ServerSocket server = new ServerSocket(6666);
                System.out.println("服务器已经启动，正在等待连接......");
                while (true) {
                    //等待客户端连接,造成阻塞，如果有客户端连接成功，立即返回一个Socket对象
                    Socket s = server.accept();
                    System.out.println(s.getInetAddress().getHostAddress());
                    es.execute(new UserThread(s));
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    
    /**
     * 用来处理客户端请求的线程任务
     */
    class UserThread implements Runnable {
        private Socket s;
    
        public UserThread(Socket s) {
            this.s = s;
        }
    
        @Override
        public void run() {
            try {
                BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
                PrintStream ps = new PrintStream(new BufferedOutputStream(s.getOutputStream()));
                String info = br.readLine();//获取到用户信息
                System.out.println(info);
                ps.println("ECHO" + info);
                ps.flush();
                ps.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

![20190806082431636.png][]

package com.vince;
    import java.io.*;
    import java.net.Socket;
    import java.util.Scanner;
    
    public class MutilClientDemo {
        public static void main(String[] args) {
            //客户端输入
            Scanner input = new Scanner(System.in);
            //创建一个Socket对象，指定要连接的服务器
            try {
                //获取Socket的输出流
                Socket socket = new Socket("localhost",6666);
                PrintStream ps = new PrintStream(new BufferedOutputStream(socket.getOutputStream()));
                BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    
                System.out.println("请输入：");
                String info = input.nextLine();
                ps.println(info);
                ps.flush();
                //读取服务器端返回的数据
                  info = br.readLine();
                System.out.println(info);
                ps.close();
                br.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

![20190806082621356.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 3][]

[20190806082237460.png]: /images/20211109/47a69605a21848a7875797dbd7192c76.png
[20190806082431636.png]: /images/20211109/e842e41375f040678b27b8024fa92978.png
[20190806082621356.png]: /images/20211109/3273e88d237a465fbddd70b9cc7db385.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70]: /images/20211109/23c8df3200ea4e1c8feb8b6373e20acc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 1]: /images/20211109/fc3c8d5012f64d6c9b19e09ccae534ec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 2]: /images/20211109/3238d638fb7641c2969fa6fd77aebe33.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pzMTM0MjA4NDc3Ng_size_16_color_FFFFFF_t_70 3]: /images/20211109/658cca7e618b497e83ab6a47c79565fb.png