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

springboot体会BIO（阻塞式IO）

article 2024/11/20 21:37:51

使用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();
        }
    }
}