• Netty系列(五):源码解读ServerBootstrapAcceptor类职能,探究Netty启动流程


    ServerBootstrapAcceptorNetty服务端用来接收客户端连接的核心类,本文将介绍ServerBootstrapAcceptor的职能。

    init方法

    在上一篇文章源码解读 backlog 参数作用中我们知道,在Netty服务端启动时,会调用ServerBootstrap.bind()绑定本地端口用来监听客户端的连接。

    而这个方法会通过反射创建ServerSocketChannel并初始化,ServerBootstrap.init()会初始化ServerSocketChannel,将ServerBootstrapAcceptor添加到服务端ChannelPipeline中。

    在这里插入图片描述

    init方法用于服务端Channel的初始化,初始化ServerSocketChannelChannelPipeline,并向ChannelPipeline中添加了一个ChannelInitializer

    ChannelInitializer是一个ChannelHandler,但它不处理任何出站、入站事件,其目的只为了完成Channel的初始化。

    ChannelHandler被添加到ChannelPipeline后,会触发一个handlerAdded方法回调,这个方法里会调用initChannel()进行初始化,初始化完成后会将自己从Pipeline中删除,

    在这里插入图片描述

    We are done with init the Channel, removing the initializer now.(完成 Channel 的初始化后,删除初始化器。)

    我们再看回ServerBootstrapAcceptor类,其中在向ChannelPipeline中添加ChannelInitializer时,在initChannel方法中会向ChannelPipeline中添加一个ServerBootstrap.handler()。这是个用户自定义的ChannelHandler,如果用户没有设置,就不会通过判空校验,也就不会添加到ChannelPipeline中。

    在处理完用户自定义的ChannelHandler后,还会再添加一个ServerBootstrapAcceptor

    在这里插入图片描述

    ServerBootstrapAcceptor

    我们先看一下ServerBootstrapAcceptor类图结构(虚线表示实现接口,实线表示类继承),我们得知ServerBootstrapAcceptor实现了ChannelInboundHandler接口,而是ChannelInboundHandler本身就是进站处理器,处理channel进站的一系列事件。

    在这里插入图片描述

    ServerBootstrapAcceptor类属性也就是childChannel相关的配置信息,相关介绍如下:

    1. childGroup: Reactor模型中的WorkerGroup
    2. childHandler: 客户端Channel的ChannelHandler
    3. childOptions: 客户端Channel的Options
    4. childAttrs: 客户端Channel的Attrs
    5. enableAutoReadTask: 启用自动读取的任务

    ServerBootstrapAcceptor类重写了channelRead方法,这是它最主要的方法。

    在这里插入图片描述

    channelRead方法中,整个过程如下:

    1. 设置SocketChannelPipeline
    2. 设置ChannelOptionsAttributes
    3. Channel注册到WorkerGroup中。
    4. Channel注册到workGroup中。

    如果整个过程出现了异常,Netty会调用forceClose()强制关闭连接,其底层是调用了SocketChannel.close()方法关闭连接。

    什么时候会触发channelRead方法

    debug模式启动netty后,我们在channelRead方法打断点,通过nc连接netty服务端。

    
    nc localhost 8888
    
    • 1
    • 2

    运行nc指令后,我们会发现断点位置阻塞了。
    我们可以看到,传入的msg是NioSocketChannel,记录的是与客户端连接的channel。接下来我们仔细看一下调用栈,该方法被触发时是运行在bossGroup的线程中的。

    在这里插入图片描述

    当有新客户端连接时,就会触发ServerBootstrapAcceptor类的channelRead方法。

    总结

    ServerBootstrapAcceptor类是一个特殊的ChannelHandler,是Netty服务端用来接收客户端连接的核心类。

    ServerBootstrap在初始化Channel时,会往它的ChannelPipeline中添加ServerBootstrapAcceptor,而ServerBootstrapAcceptor重写了ChannelRead回调,当有新客户端连接时,就会触发ChannelRead回调,这样ServerBootstrapAcceptor就可以拿到客户端连接,并对客户端连接进行初始化并注册到WorkerGroup中。

  • 相关阅读:
    mysql拆分字符串做条件查询
    短视频不火怎么办?加上配音试试看|教你制作最近超火的配音旁白
    springboot如何整个Swagger呢?
    python - excel 设置样式
    警惕 有种过敏叫“牛奶蛋白过敏”
    c++day4
    6.判断是不是闰年
    尚硅谷wepack课程学习笔记
    【面试题-007】说一下JVM原理
    Python中文分词及词频统计
  • 原文地址:https://blog.csdn.net/Ber_Bai/article/details/128170823