netty源码

分析pipeline.fireChannelRead()readBuf存放是是客户端channel

init(channel)解析

doReadMessages(readBuf):1、会调用ServerSocketChannel.accept()获取一个客户端SocketChannel;2、将SocketChannel转成NioSocketChannel加入buf中，并携带属性

端口绑定和监听

执行器体现

绑定端口

关注read事件

HeadContext#read()

将NioSocketCHannel注册到workerGroup上

4

一个children就是一个线程每个线程会绑定selector

初始化启动器，进行属性的绑定工作。

NioServerSocketChannel#doBind()

channelRead()读到的应该是一个完成的业务数据，而channelReadComplete()是不再由数据可读时调用。

类图

成员children：NioEventLoop

进入newChild()

1

read()方法获取客户端sockerChannel

MultithreadEventExecutorGroup

这个pipeline.fireChannelRead会触发ServerSockerChannel的pipeline中所有入站的channelRead()方法

这里的channel实现类是ServerSocketChannelImpl

进入bossGroup中的NioEventLoop的run方法进行分析

2

ServerBootStrapAcceptor是一个ChannelInboundHandler所有会调用他的channelRead()方法

监听NioSocketChannel上的Read事件

这里的unsafe是NioMessageUnsafe类的对象

分析unsafe.read()

sockerChannel注册完毕后会触发NioSocketChannel中的doBeginRead()

服务端接收客户端连接

参考文献https://blog.csdn.net/wuyangyang555/article/details/122478709

3

这里绑定的channel类

创建新的NioSocketChannel

AbstractChannel#Register()

分析源码之前请先看netty工作架构图

NioEventLoop绑定了selector

ServerSocketChannel配置

 EventLoopGroup bossGroup = new NioEventLoopGroup()

完成之后进入NioEventLoop的run方法的死循环中

配置new ServerBootstrap();

可以看到，在死循环中，做了两件事：1、处理selector的连接事件；2、取队列中的任务进行执行；

将ServerSockerChannel注册到Selector上

taskQueue也在这里体现。

通过构造器反射得到ServerSockerChannel

创建了nThreads个类型为EventExecutor的children

监听Accept事件

doReadMessages(readBuf)

channelread