前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Netty系列(五):源码解读ServerBootstrapAcceptor类职能,探究Netty启动流程

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

作者头像
鳄鱼儿
发布2024-05-21 21:07:38
880
发布2024-05-21 21:07:38
举报

ServerBootstrapAcceptor是Netty服务端用来接收客户端连接的核心类,本文将介绍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服务端。

代码语言:javascript
复制
nc localhost 8888

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

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

总结

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

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

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2024-05-21,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • init方法
  • ServerBootstrapAcceptor类
    • 什么时候会触发channelRead方法
    • 总结
    领券
    问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档