【BIO】Socket 编程：基于BIO的Server、Client 示例

╰半夏微凉° 2022-12-30 13:38 157阅读 0赞

### Server ###

public class Server {
        
    
        public static void main(String[] args) throws Exception {
        
            ServerSocket server = new ServerSocket(8000);
            System.out.println("Server started...");
    		
    		// while(true) 持续接收请求
            while(true) {
        
                Socket socket = server.accept();
                System.out.println("有客户端连接了..." + socket.getRemoteSocketAddress());
                // 给每个连接都启动一个线程，实现并发处理
                new Thread(() -> {
        
                    try {
        
                        handler(socket);
                    } catch (Exception e) {
        
                        e.printStackTrace();
                    }
                }).start();
            }
        }
    
        private static void handler(Socket socket) throws Exception {
        
    		System.out.println("-->" + Thread.currentThread().getName());		
    
    		// 读
            InputStream inputStream = socket.getInputStream();
            BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
            String str = reader.readLine();
            System.out.println(socket.getRemoteSocketAddress() + "：" + str);
    
            TimeUnit.SECONDS.sleep(10); // 通过sleep来验证可以通过处理多个连接
    		
    		// 写
            OutputStream outputStream = socket.getOutputStream();
            PrintWriter writer = new PrintWriter(outputStream);
            writer.println("ACK");
            writer.flush();
            System.out.println("已向" + socket.getRemoteSocketAddress() + "回发确认消息ACK");
        }
    }

### Client ###

public class Client {
        
    
        public static void main(String[] args) throws IOException {
        
            Socket socket = new Socket("127.0.0.1", 8000);
    		System.out.println("Connect success...");
    		
    		// 写
            OutputStream outputStream = socket.getOutputStream();
            PrintWriter writer = new PrintWriter(outputStream);
            writer.println("hello");
            writer.flush();
            System.out.println("向服务端发送数据结束");
    
    		// 读
            InputStream inputStream = socket.getInputStream();
            BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
            String str = reader.readLine();
            System.out.println("Server：" + str);
    
            socket.close();
        }
    }

我们先启动 Server，然后先后启动两个 Client  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center]

可以看到虽然通过 BIO 也是实现了同时处理多个多个客户端的连接，但是 Server 需要给每个 Client 都启动一个线程，这将会消耗许多性能。

> 上面只是简单列出了 BIO 如何进行 Socket 编程，采用的 C/S 架构，但 BIO 还可以用于 B/S 架构，比如手写个 Tomcat 玩玩 [【Tomcat】第八篇：150代码手写Tomcat（基于BIO，超详细注释）][Tomcat_150_Tomcat_BIO]…

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNTkyNw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/fe7b6adc7bdb43d4a39977f332c2727e.png
[Tomcat_150_Tomcat_BIO]: https://blog.csdn.net/weixin_43935927/article/details/108743213