掘金 后端 ( ) • 2024-03-22 16:59

概念

1.handler

源码是这么解析它的 the ChannelHandler to use for serving the requests.

意思是用于服务请求,也就是主reactor线程处理的handler.

重要的实现类

ServerBootstrapAcceptor

image.png

这个类在ServerBootstrap启动中有默认加到主reactor的pipeline(默认的pipeline是DefaultChannelPipeline,请记住这个实现类)里。

LoggingHandler

netty提供的一个记录日志handler

childHandler

Set the ChannelHandler which is used to serve the request for the Channel's. 文档指出这是一个处理channel请求的handler

启动流程

1.初始化serverSocket

1.1 创建ServerSocketChannel

具体实现由启动时channel参数决定

1.2 初始化channel

向serverSocketChannel加入ChannelInitializer实例, 在该实例回调中向pipeline中加入启动时加入的handler实例(上文提到的handler参数)和ServerBootstrapAccptor实例

1.3 从bossGroup中取出一个线程来处理channel注册,并注册到线程自己的selector上

  1. #启动bossGroup线程,在线程里处理事件循环和队列任务,具体逻辑不深入。
  2. 这里注册到selector的感兴趣事件为0,并没有将accept事件加入到selector中,这里只有启动,和处理任务队列里的数据,只有后面执行bind方法后才能真正处理网络事件。
  3. 从这里可以得知,我们在许多的bossgroup中取出一个,如果是设定了多个bossGroup线程,并且只绑定到一个网卡,其它线程可能不会被使用,这个问题需要我们思考。

2.doBind0绑定端口

2.1 调用channel的bind方法

2.2 调用channel里的pipeline.bind方法

2.3 从尾结点开始找到所有OUT的handler,并调用bind方法

在header节点会调用unsafe.bind,这里才是netty真正实现的方法

2.3.1 NioMessageUnsafe.bind
2.3.2 doBind绑定网卡和端口
2.3.3 触发fireChannelActive事件
if (!wasActive && isActive()) {
    invokeLater(new Runnable() {
        @Override
        public void run() {
            pipeline.fireChannelActive();
        }
    });
}

2.3.4 从头节点执行active方法

// 找到所有inBound的active方法
ctx.fireChannelActive();  // findContextInbound(MASK_CHANNEL_ACTIVE)


readIfIsAutoRead();
// 调用pipeline.read方法
2.3.4.1 readIfIsAutoRead从pipeline的尾结点开始读取
2.3.4.2 读取到headContext节点

调用headContext.read读取,即调用unsafe.beginRead(),这里的unsafe实现类是NioMessageUnsafe

2.3.4.3 doBeginRead

这里才真正将accept事件加入到selector感兴趣中

final int interestOps = selectionKey.interestOps();
if ((interestOps & readInterestOp) == 0) {
    selectionKey.interestOps(interestOps | readInterestOp);
}

3.初始化完成

至此,可以开始接收网络数据。

  1. 有连接过来,会在bossGroup线程中感知到,具体逻辑在NioEventLoop.run方法中可以查看。
  2. 具体处理读请求数据的在NioMessageUnsafe.read中