本文参考了深度解读Tomcat中的NIO模型 和Tomcat NIO 模型的实现两篇文章，在看本文之前要先看一下这两位大神的分析，写的很好。但笔者对上述文章中关于NioBlockingSelector和BlockPoller的部分理解有些不太顺畅，所以下面只针对这一部分按照自己的思路整理出了本文。

即使用了NIO模式，在tomcat中读取request body和写response的时候，根据servlet规范需要使用从Request和Response两个类获取流来进行读写，而ServletInputStream和 ServletOutputStream根据servlet规范是要求阻塞读写的。

比如在Request处理时，工作线程读请求line和header的时候是非阻塞的，而读request body是阻塞的。而由于accept的socket设置blocking false，所以要找到一个办法去让工作线程阻塞的去处理非阻塞的socket。

我们在org.apache.tomcat.util.net.NioEndpoint这个tomcat的NIO模式下连接和线程处理的核心组件中，可以找到Endponit初始化代码：

直接看一下最后

NioBlockingSelector 和 BlockPoller，前者提供读写方法、如果一次没读写完则阻塞在一个读写锁上等待通知就绪，后者内部是selector和轮询线程、负责epoll出来当前读写就绪的连接。当读写就绪时，就会打开连接上的读写锁（CountDownLatch实现），让阻塞在锁上的线程继续读写。接下来以写response为例，看一下这个过程。

这里我们可以从我们写的Servlet程序的response.getWriter().write()方法处用单步跟踪调试的办法一点一点的跟踪到NioBlockingSelector.write()，笔者也是这么试过的，但是也可以在“知道了答案的”情况下，偷懒直接通过在NioBlockingSelector.write()方法上打断点，通过观察线程栈的方法来了解这里的调用链路。断点打好之后，调用我们编写的servlet，在response.getWriter().write(）写返回的时候，找到如下的调用栈：

可以看到在response写了缓冲之后，针对response响应（注意不是socket连接）做了“end and flush”，将数据从缓冲区冲刷到socket，这个冲刷实际上就是NioSocketWrapper.doWrite() -> NioSelectorPool.write() -> NioBlockingSelector.write()这样一个调用链路。所以最后我们来看NioBlockingSelector.write()方法：

上面有个awaitWriteLatch的操作，依靠writeLatch来阻塞在等待写就绪事件上，而写就绪事件已经通过BlockPoller.add注册到BlockPoller了，至此，如何使用一个非阻塞的socket模拟阻塞写的过程搞清楚了:

socket.write() -> 没写完，OP_WRITE注册到BlockPoller，线程阻塞等待awaitWriteLatch -> BlockPoller selector获得写就绪、writerLatch.countdown()通知 -> 线程继续写。

最后看一下tomcat9 的线程，可以看到跟8.5相比Poller只启动1个、就是那个ClientPoller线程，另外BlockPoller线程的作用上面也分析了。

来自jstack的输出