netty源码阅读--处理客户端请求

news2024/11/16 20:33:26

背景

netty是一个非常成熟的NIO框架，众多apache的顶级项目底层通信框架都是用的是netty,本系列博客主要是记录自己复习netty源码的过程，重在理解netty的关键如：如何启动，如何接受网络数据、netty的内存管理机制以及编解码器等，废话不多说，直接跟着netty源码中的MQTT的官方示例来看netty服务端启动完成之后，如何处理客户端请求
在这里插入图片描述

处理客户端请求的核心流程

在这里插入图片描述

netty接收网络消息相关代码

通过上文我们知道了，NioEventLoop的run方法，是监听客户端网络接入的核心方法，接下来以这个方法为起点，我们看netty如何处理数据接入的：

接收客户端连接接入

在这里插入图片描述

步骤4中方法的进一步解析，当doReadMessage方法获取到客户端channel即socketchannel之后，接下来到第8步，开始触发服务端自己的管道里面的handler的channelread方法了！

通过管道依次执行管道里面的数据流入链表上的节点，并依次执行其channelRead方法
在这里插入图片描述

12步中的具体代码体：register0时绑定到当前socketchannel的work线程池中的eventloop来执行的————注意此时不是boss线程

在这里插入图片描述

接收客户端数据-work线程池

在这里插入图片描述

前面的执行方法work线程和boss线程执行的一模一样，但是从下面步骤开始会有差异，主要原因还是unsafe对象不一样

最终，socketchannel中的字节流数据是从PooledByteBuf的setBytes( )方法里获取的，具体代码如下：
在这里插入图片描述
第5步从socketchannel中的字节流中拿到指定长度的字节数据之后，会执行
“pipeline.fireChannelRead(byteBuf);”方法，该方法通过管道依次触发inboundHandler类型的链表节点上的所有handler的channelRead方法，最终开始执行解码器的channelRead方法
在这里插入图片描述