共计 4947 个字符，预计需要花费 13 分钟才能阅读完成。
本文章转自：乐字节
文章次要解说：I/ O 技术在零碎设计
获取更多 Java 相干常识能够关注公众号《乐字节》发送：999
一 Java I/ O 模型
1 BIO（Blocking IO）
BIO 是同步阻塞模型，一个客户端连贯对应一个解决线程。在 BIO 中，accept 和 read 办法都是阻塞操作，如果没有连贯申请，accept 办法阻塞；如果无数据可读取，read 办法阻塞。
2 NIO（Non Blocking IO）
NIO 是同步非阻塞模型，服务端的一个线程能够解决多个申请，客户端发送的连贯申请注册在多路复用器 Selector 上，服务端线程通过轮询多路复用器查看是否有 IO 申请，有则进行解决。
NIO 的三大外围组件：
Buffer：用于存储数据，底层基于数组实现，针对 8 种根本类型提供了对应的缓冲区类。
Channel：用于进行数据传输，面向缓冲区进行操作，反对双向传输，数据能够从 Channel 读取到 Buffer 中，也能够从 Buffer 写到 Channel 中。
Selector：选择器，当向一个 Selector 中注册 Channel 后，Selector 外部的机制就能够主动一直地查问（Select）这些注册的 Channel 是否有已就绪的 I/O 事件（例如可读，可写，网络连接实现等），这样程序就能够很简略地应用一个线程高效地治理多个 Channel，也能够说治理多个网络连接，因而，Selector 也被称为多路复用器。当某个 Channel 下面产生了读或者写事件，这个 Channel 就处于就绪状态，会被 Selector 监听到，而后通过 SelectionKeys 能够获取就绪 Channel 的汇合，进行后续的 I / O 操作。
Epoll 是 Linux 下多路复用 IO 接口 select/poll 的加强版本，它能显著进步程序在大量并发连贯中只有大量沉闷的状况下的零碎 CPU 利用率，获取事件的时候，它毋庸遍历整个被侦听的描述符集，只有遍历那些被内核 IO 事件异步唤醒而退出 Ready 队列的描述符汇合就行了。
3 AIO（NIO 2.0）
AIO 是异步非阻塞模型，个别用于连接数较多且连接时间较长的利用，在读写事件实现后由回调服务去告诉程序启动线程进行解决。与 NIO 不同，当进行读写操作时，只需间接调用 read 或 write 办法即可。这两种办法均为异步的，对于读操作而言，当有流可读取时，操作系统会将可读的流传入 read 办法的缓冲区，并告诉应用程序；对于写操作而言，当操作系统将 write 办法传递的流写入结束时，操作系统被动告诉应用程序。能够了解为，read/write 办法都是异步的，实现后会被动调用回调函数。
二 I/ O 模型演变
1 传统 I / O 模型
对于传统的 I / O 通信形式来说，客户端连贯到服务端，服务端接管客户端申请并响应的流程为：读取 -> 解码 -> 利用解决 -> 编码 -> 发送后果。服务端为每一个客户端连贯新建一个线程，建设通道，从而解决后续的申请，也就是 BIO 的形式。
这种形式在客户端数量一直减少的状况下，对于连贯和申请的响应会急剧下降，并且占用太多线程浪费资源，线程数量也不是没有下限的，会遇到各种瓶颈。尽管能够应用线程池进行优化，然而仍然有诸多问题，比方在线程池中所有线程都在解决申请时，无奈响应其余的客户端连贯，每个客户端仍旧须要专门的服务端线程来服务，即便此时客户端无申请，也处于阻塞状态无奈开释。基于此，提出了基于事件驱动的 Reactor 模型。
2 Reactor 模型
Reactor 模式是基于事件驱动开发的，服务端程序处理传入多路申请，并将它们同步分派给申请对应的解决线程，Reactor 模式也叫 Dispatcher 模式，即 I / O 多路复用对立监听事件，收到事件后散发（Dispatch 给某过程），这是编写高性能网络服务器的必备技术之一。
Reactor 模式以 NIO 为底层反对，外围组成部分包含 Reactor 和 Handler：
•Reactor：Reactor 在一个独自的线程中运行，负责监听和散发事件，分发给适当的处理程序来对 I / O 事件做出反馈。它就像公司的电话接线员，它接听来自客户的电话并将线路转移到适当的联系人。
•Handlers：处理程序执行 I / O 事件要实现的理论事件，Reactor 通过调度适当的处理程序来响应 I/O 事件，处理程序执行非阻塞操作。相似于客户想要与之交谈的公司中的理论员工。
依据 Reactor 的数量和 Handler 线程数量，能够将 Reactor 分为三种模型:
•单线程模型 (单 Reactor 单线程)
•多线程模型 (单 Reactor 多线程)
•主从多线程模型 (多 Reactor 多线程)
单线程模型
Reactor 外部通过 Selector 监控连贯事件，收到事件后通过 dispatch 进行散发，如果是连贯建设的事件，则由 Acceptor 解决，Acceptor 通过 accept 承受连贯，并创立一个 Handler 来解决连贯后续的各种事件，如果是读写事件，间接调用连贯对应的 Handler 来解决。
Handler 实现 read -> (decode -> compute -> encode) ->send 的业务流程。
这种模型益处是简略，害处却很显著，当某个 Handler 阻塞时，会导致其余客户端的 handler 和 accpetor 都得不到执行，无奈做到高性能，只实用于业务解决十分疾速的场景，如 redis 读写操作。
多线程模型
主线程中，Reactor 对象通过 Selector 监控连贯事件, 收到事件后通过 dispatch 进行散发，如果是连贯建设事件，则由 Acceptor 解决，Acceptor 通过 accept 接管连贯，并创立一个 Handler 来解决后续事件，而 Handler 只负责响应事件，不进行业务操作，也就是只进行 read 读取数据和 write 写出数据，业务解决交给一个线程池进行解决。
线程池调配一个线程实现真正的业务解决，而后将响应后果交给主过程的 Handler 解决，Handler 将后果 send 给 client。
单 Reactor 承当所有事件的监听和响应，而当咱们的服务端遇到大量的客户端同时进行连贯，或者在申请连贯时执行一些耗时操作，比方身份认证，权限查看等，这种刹时的高并发就容易成为性能瓶颈。
主从多线程模型
存在多个 Reactor，每个 Reactor 都有本人的 Selector 选择器，线程和 dispatch。
主线程中的 mainReactor 通过本人的 Selector 监控连贯建设事件，收到事件后通过 Accpetor 接管，将新的连贯调配给某个子线程。
子线程中的 subReactor 将 mainReactor 调配的连贯退出连贯队列中通过本人的 Selector 进行监听，并创立一个 Handler 用于解决后续事件。
Handler 实现 read -> 业务解决 -> send 的残缺业务流程。
对于 Reactor，最权威的材料应该是 Doug Lea 大神的 Scalable IO in Java，有趣味的同学能够看看。
三 Netty 线程模型
Netty 线程模型就是 Reactor 模式的一个实现，如下图所示：
1 线程组
Netty 形象了两组线程池 BossGroup 和 WorkerGroup，其类型都是 NioEventLoopGroup，BossGroup 用来承受客户端发来的连贯，WorkerGroup 则负责对实现 TCP 三次握手的连贯进行解决。
NioEventLoopGroup 外面蕴含了多个 NioEventLoop，治理 NioEventLoop 的生命周期。每个 NioEventLoop 中蕴含了一个 NIO Selector、一个队列、一个线程；其中线程用来做轮询注册到 Selector 上的 Channel 的读写事件和对投递到队列外面的事件进行解决。
Boss NioEventLoop 线程的执行步骤：
•解决 accept 事件, 与 client 建设连贯, 生成 NioSocketChannel。
•将 NioSocketChannel 注册到某个 worker NIOEventLoop 上的 selector。
•解决工作队列的工作，即 runAllTasks。
Worker NioEventLoop 线程的执行步骤：
•轮询注册到本人 Selector 上的所有 NioSocketChannel 的 read 和 write 事件。
•解决 read 和 write 事件，在对应 NioSocketChannel 解决业务。
•runAllTasks 解决工作队列 TaskQueue 的工作，一些耗时的业务解决能够放入 TaskQueue 中缓缓解决，这样不影响数据在 pipeline 中的流动解决。
Worker NIOEventLoop 解决 NioSocketChannel 业务时，应用了 pipeline (管道)，管道中保护了 handler 处理器链表，用来解决 channel 中的数据。
2 ChannelPipeline
Netty 将 Channel 的数据管道形象为 ChannelPipeline，音讯在 ChannelPipline 中流动和传递。ChannelPipeline 持有 I / O 事件拦截器 ChannelHandler 的双向链表，由 ChannelHandler 对 I / O 事件进行拦挡和解决，能够不便的新增和删除 ChannelHandler 来实现不同的业务逻辑定制，不须要对已有的 ChannelHandler 进行批改，可能实现对批改关闭和对扩大的反对。
ChannelPipeline 是一系列的 ChannelHandler 实例，流经一个 Channel 的入站和出站事件能够被 ChannelPipeline 拦挡。每当一个新的 Channel 被创立了，都会建设一个新的 ChannelPipeline 并绑定到该 Channel 上，这个关联是永久性的；Channel 既不能附上另一个 ChannelPipeline 也不能拆散以后这个。这些都由 Netty 负责实现，而无需开发人员的特地解决。
依据起源, 一个事件将由 ChannelInboundHandler 或 ChannelOutboundHandler 解决，ChannelHandlerContext 实现转发或流传到下一个 ChannelHandler。一个 ChannelHandler 处理程序能够告诉 ChannelPipeline 中的下一个 ChannelHandler 执行。Read 事件（入站事件）和 write 事件（出站事件）应用雷同的 pipeline，入站事件会从链表 head 往后传递到最初一个入站的 handler，出站事件会从链表 tail 往前传递到最前一个出站的 handler，两种类型的 handler 互不烦扰。
ChannelInboundHandler 回调办法：
ChannelOutboundHandler 回调办法：
3 异步非阻塞
写操作：通过 NioSocketChannel 的 write 办法向连贯外面写入数据时候是非阻塞的，马上会返回，即便调用写入的线程是咱们的业务线程。Netty 通过在 ChannelPipeline 中判断调用 NioSocketChannel 的 write 的调用线程是不是其对应的 NioEventLoop 中的线程，如果发现不是则会把写入申请封装为 WriteTask 投递到其对应的 NioEventLoop 中的队列外面，而后等其对应的 NioEventLoop 中的线程轮询读写事件时候，将其从队列外面取出来执行。
读操作：当从 NioSocketChannel 中读取数据时候，并不是须要业务线程阻塞期待，而是等 NioEventLoop 中的 IO 轮询线程发现 Selector 上有数据就绪时，通过事件告诉形式来告诉业务数据已就绪，能够来读取并解决了。
每个 NioSocketChannel 对应的读写事件都是在其对应的 NioEventLoop 治理的单线程内执行，对同一个 NioSocketChannel 不存在并发读写，所以无需加锁解决。
应用 Netty 框架进行网络通信时，当咱们发动 I / O 申请后会马上返回，而不会阻塞咱们的业务调用线程；如果想要获取申请的响应后果，也不须要业务调用线程应用阻塞的形式来期待，而是当响应后果进去的时候，应用 I / O 线程异步告诉业务的形式，所以在整个申请 -> 响应过程中业务线程不会因为阻塞期待而不能干其余事件。
感激大家的认同与反对，小编会继续转发《乐字节》优质文章
