重新认识BIO、NIO、IO多路复用、Select、Poll、Epollo它们之间的关系

一、背景

二、名词理解

（1）BIO

（2）NIO

（3）IO多路复用

（4）Select、Poll、Epollo

三、他们之间的关系总结

一、背景

最近又在学习网络IO相关知识，对我们常说的BIO、NIO、IO多路复用、Select、Poll、Epollo之间到底是什么关系，进行重新学习以及总结，特此记录一下。希望对一样迷惑的朋友也有一定的帮助

二、名词理解

（1）BIO

BIO它是Blocking IO的缩写，它的关键的特点就是阻塞IO，什么叫阻塞IO呢，就是你可以理解为它处理连接、读写事件是阻塞的，它采用阻塞方式进行数据读写操作。即当一个线程在执行IO操作时，若没有数据可读，则该线程会一直阻塞等待，直到有数据可读或者超时。如果还不理解我们不妨看看具体的BIO服务端实现的代码，加深自己的理解。

BIO服务端代码

package bio;import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;/*** bio - server 类** @author chen* @date 2024年03月10日 10:43*/
public class BioServer {public static void main(String[] args) {try {System.out.println("*****服务端启动******");//定义一个ServerSocket对象进行一个服务端的接口注册ServerSocket serverSocket = new ServerSocket(8888);//监听客户端的Socket链接请求Socket socket = serverSocket.accept();//从socket对象中得到一个字节输入流对象InputStream is = socket.getInputStream();//将字节输入流包装成一个缓冲字符输入流（不能直接将字节输入流包装成缓冲字符输入流，先将字节输入流转成字符输入流，再转成缓冲字符输入流）BufferedReader br = new BufferedReader(new InputStreamReader(is));String msg;while ((msg = br.readLine()) != null){System.out.println("服务端收到信息:"+msg);}} catch (IOException e) {e.printStackTrace();}}}

这里我们看到BIO的accept和read方法都是阻塞方法，也就是说线程一旦调用就会进行阻塞

看到这里我们不妨可以思考一下，那我如果想实现多连接处理应该怎么实现？

既然我们一个连接一个线程，那是否我们可以看更多的线程去处理连接，没错，早期的BIO是这样都是这样去处理的，如下代码，加入线程池后的处理

package bio;import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;/*** TODO 类功能描述** @author chen* @date 2024年03月10日 10:43*/
public class BioMoreThreadServer {public static ExecutorService executorService = Executors.newFixedThreadPool(2);public static void main(String[] args) {try {System.out.println("*******服务端启动*********");//注册端口ServerSocket ss = new ServerSocket(8888);//定义一个死循环，负责不断的接收客户端的Socket的连接请求while (true){Socket socket = ss.accept();//创建一个独立的线程来处理这个客户端socket的通信需求
//                new ServerThreadReader(socket).start();//用线程池替代，线程池只是解决了防止频繁创建和销毁线程，并没有解决可以更多的支持连接这个问题（连接数还是有限）executorService.submit(new ServerThreadReader(socket));}} catch (IOException e) {e.printStackTrace();}}}

这里需注意一个细节，加入线程池后，并没有解决能够支持更多的连接的问题，仅仅只是防止线程频繁创建以及销毁，降低系统压力。

看完了BIO我们会提出一个疑问，那如果能够支持更大的连接数呢？

（2）NIO

NIO是Java 1.4引入的新的IO模型，它采用了多路复用器（Selector）机制，通过少量线程同时管理多个通道，实现了单线程同时处理多个请求的效果。NIO具有高并发性、高吞吐量和更高的可靠性，适合处理连接数多且连接时间较短的场景。NIO的核心组件包括通道(Channel)、缓冲区(Buffer)和选择器(Selector)。选择器允许程序同时等待多个通道上的事件，如连接、数据到达等。

从我个人理解的角度，就是新的网络IO模型，增加了在网络IO读取过程中的一些特性，例如非阻塞、高吞吐、高并发性。那么他跟IO多路复用有什么关系呢？

（3）IO多路复用

IO多路复用（IO Multiplexing）一种同步IO模型，单个进程/线程就可以同时处理多个IO请求。一个进程/线程可以监视多个文件句柄；一旦某个文件句柄就绪，就能够通知应用程序进行相应的读写操作；没有文件句柄就绪时会阻塞应用程序，交出cpu。多路是指网络连接，复用指的是同一个进程/线程。

这里从我个人的角度理解，以盖房子为例，NIO是一个基础，提供了大量的基础工具（通道[Channel]、缓冲区[Buffer]和选择器[Selector]等等），就像一个我们要盖房子的各种工具已经给你备好了，接下来我们要盖一个怎样的房子(IO多路复用)，相当于我们用NIO的技术实现了IO多路复用，如果没有NIO本身这项技术的支持，就不可能实现IO多路复用。

IO多路复用的代码实现

package nio;import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;/*** TODO 类功能描述** @author chen* @date 2024年03月10日 13:01*/
public class NioServer {public static void main(String[] args) {try {ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();serverSocketChannel.configureBlocking(false);serverSocketChannel.bind(new InetSocketAddress(8888));Selector selector = Selector.open();serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);// 无限判断当前线程状态，如果没有中断，就一直执行while内容。while(!Thread.currentThread().isInterrupted()){// 获取准备就绪的channelif (selector.select() == 0) {continue;}// 获取到对应的 SelectionKey 对象Set<SelectionKey> keys = selector.selectedKeys();Iterator<SelectionKey> keyIterator = keys.iterator();// 遍历所有的 SelectionKey 对象while (keyIterator.hasNext()){// 根据不同的SelectionKey事件类型进行相应的处理SelectionKey key = keyIterator.next();if (!key.isValid()){continue;}if (key.isAcceptable()){accept(serverSocketChannel,selector,key);}if(key.isReadable()){read(key);}// 移除当前的keykeyIterator.remove();}}} catch (Exception e) {e.printStackTrace();}}private static void read(SelectionKey key) {try {SocketChannel socketChannel = (SocketChannel) key.channel();//清除缓冲区，准备接受新数据ByteBuffer readBuffer = ByteBuffer.allocate(1024);//调整缓冲区大小为1024字节int numRead = socketChannel.read(readBuffer);;String str = new String(readBuffer.array(),0,numRead);System.out.println("read String is: " + str);}catch (Exception e){e.printStackTrace();}}private static void accept(ServerSocketChannel serverSocketChannel, Selector selector, SelectionKey key) {try {SocketChannel socketChannel = serverSocketChannel.accept();socketChannel.configureBlocking(false);// 注册客户端读取事件到selectorsocketChannel.register(selector, SelectionKey.OP_READ);System.out.println("client connected " + socketChannel.getRemoteAddress());}catch (Exception e){e.printStackTrace();}}
}

那这个时候IO多路复用算是明白了 ~~

那此时有提出一个疑问：那么IO多路复用跟我们常说的Select、Poll、Epollo又有什么关系？

（4）Select、Poll、Epollo

Select、Poll、Epollo的概念我这里就不一一叙说

总结起来他们就是操作系统函数，不同的操作系统(window、linux)有不同的实现，而且这项技术是不断演化，从早期的Select、演化到Poll、再到Epollo。上面讲到IO多路复用能够使用一个线程监听连接、读写事件，它们在操作系统底层是如何实现的呢？（任何的Java逻辑都是会回归操作系统，例如Java的创建线程，底层也是调用操作系统函数进行线程的创建）其实我们可以追到Select方法的源码，最终会调用本地方法，这里答案也就揭晓了，这三个操作系统函数，是操作系统帮我实现能够使用一个线程监听多个事件的功能，它们是实现IO多路复用的在操作系统层面的基石。

protected int doSelect(long var1) throws IOException {if (this.channelArray == null) {throw new ClosedSelectorException();} else {this.timeout = var1;this.processDeregisterQueue();if (this.interruptTriggered) {this.resetWakeupSocket();return 0;} else {this.adjustThreadsCount();this.finishLock.reset();this.startLock.startThreads();try {this.begin();try {this.subSelector.poll();} catch (IOException var7) {this.finishLock.setException(var7);}if (this.threads.size() > 0) {this.finishLock.waitForHelperThreads();}} finally {this.end();}this.finishLock.checkForException();this.processDeregisterQueue();int var3 = this.updateSelectedKeys();this.resetWakeupSocket();return var3;}}}

三、他们之间的关系总结

最后我画一张图来总结它们的关系

NIO本身这项技术本身是一个大的基石，我们利用了这个基石实现了IO多路复用，而Select、Poll、Epollo这些操作系统函数，是我们操作系统层面的基石，借助这种机制能够帮我们实现事件监听，实现单个线程处理多个事件。从而实现IO多路复用机制，这样就解决了BIO连接数的限制，能够支持处理更多的连接。