当前位置：首页 > news >正文

springboot体会BIO（阻塞式IO）

news 2025/6/26 3:56:31

使用springboot体会阻塞式IO

大致的思路为：
创建一个socket服务端，监听socket通道，并打印出socket通道中的内容。
创建两个socket客户端，向socket服务端写入消息。

1.创建服务端

public class RedisServer {public static void main(String[] args) throws IOException {ServerSocket serverSocket = new ServerSocket(6379);while (true){System.out.println("redis服务端开始监听连接请求");//accept 阻塞式操作Socket socket = serverSocket.accept();System.out.println("redis监听到连接请求:" + UUID.randomUUID());InputStream inputStream = socket.getInputStream();int length;byte[] bytes = new byte[1024];//read 阻塞式操作while ((length = inputStream.read(bytes)) != -1){System.out.println("redis服务端成功读取请求体:"  + new String(bytes,0,length));}}}}

2.创建客户端1

 public class RedisClient01 {public static void main(String[] args) throws IOException {Socket socket = new Socket("127.0.0.1",6379);OutputStream outputStream = socket.getOutputStream();while (true){Scanner scanner = new Scanner(System.in);String in = scanner.next();if("quit".equals(in)){break;}outputStream.write(in.getBytes());System.out.println("redis一号客户端完成写入操作");}outputStream.close();socket.close();}
}

3.创建客户端2

public class RedisClient02 {public static void main(String[] args) throws IOException {Socket socket = new Socket("127.0.0.1",6379);OutputStream outputStream = socket.getOutputStream();while (true){Scanner scanner = new Scanner(System.in);String in = scanner.next();if("quit".equals(in)){break;}outputStream.write(in.getBytes());System.out.println("redis二号客户端完成写入操作");}outputStream.close();socket.close();}
}

4.体验BIO（一）

我们先启动socket服务端

启动客户端1，再观察服务端的日志打印，成功监听客户端1与服务端建立了socket连接

我们使用客户端1写入数据，再观察服务端和客户端1的日志打印，客户端写入成功，服务端读取成功，一切安好

我们再启动第二个客户端，观察服务端的日志，没有任何新增的打印

难道是代码有问题？我们使用客户端2写入试试

写入是成功的，此时服务端的日志会有新增的打印吗？

依旧没有
当我把客户端1退出时，再来看一下服务端的日志

之前客户端2写入的消息成功被读取到了

5.小总结（一）

结合代码以及日志的打印结果分析：
服务端只能处理一个客户端的请求，第二个客户端发起请求，只能阻塞，直到第一个客户端的请求全部处理完毕。

6.如何处理阻塞问题？

我们借助多线程机制，使read方法“不阻塞”，修改我们服务端的代码

public class RedisServer {public static void main(String[] args) throws IOException {ServerSocket serverSocket = new ServerSocket(6379);while (true){System.out.println("redis服务端开始监听连接请求");//accept 阻塞式操作Socket socket = serverSocket.accept();System.out.println("redis监听到连接请求:" + UUID.randomUUID());new Thread(() ->{try {InputStream inputStream = socket.getInputStream();int length;byte[] bytes = new byte[1024];//read 阻塞式操作while ((length = inputStream.read(bytes)) != -1) {System.out.println("redis服务端成功读取请求体:" + new String(bytes, 0, length));}}catch (Exception e){e.printStackTrace();}},Thread.currentThread().getName()).start();}}
}