本文主要是介绍springboot体会BIO（阻塞式IO），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
使用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();}}
}
7.体验BIO（二）
我们一样还是先启动服务端，再启动客户端1和客户端2，使用客户端1和客户端2向服务端写入消息，通过上述的例子我们得知，服务端会先处理客户端1的请求，客户端2的请求会阻塞。
服务端使用多线程之后，客户端2的请求就不会阻塞
8.小总结（二）
使用多线程后，确实能够处理多个客户端的请求，不会产生阻塞。但是来一个请求就new一个线程，对于操作系统来说是资源的严重浪费。
9.解决方案
（1）线程池
（2）NIO（非阻塞IO）
10.阻塞式IO模型
这篇关于springboot体会BIO（阻塞式IO）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
