Netty进阶:手把手教你如何编写一个NIO服务端

Netty是一款非常优秀的网络编程框架,是对NIO的二次封装,本文将重点剖析Netty服务端的启动流程,深入底层了解如何使用NIO编程服务端。

本文是笔者基于问题的启发式源码阅读技巧的展示,建议带着如下问题开始本文的阅读:

  • ServerBootstrap 的 option 与 childOption 分别有什么作用

  • 服务端IO通道如何绑定事件链。

  • ServerBootstrap 的 handler 方法与 childHandler 方法的区别又是什么?

  • childHandler中的方法在服务端bind方法时会被调用吗?

1、Netty服务端启动示例


基于Netty的使用示例如下:

图片

代码@1:创建主从多Reactor线程模型的Boss线程组,通常只需要设置一个线程,用于监听客户端的连接请求(OP_ACCEPT)。

代码@2:创建主从多Reactor线程模型的Work线程组,即IO线程组,默认为CPU核数的两倍。

代码@3:创建Netty服务端启动工具类ServerBootstrap。

代码@4:调用group方法设置主从线程组。

代码@5:设置通道的类型,服务端NIO通道类型 NioServerSocketChannel。

代码@6:通过option方法为通道服务端通道选项。

代码@7:通过chiildOption方法为IO通道设置选项。

代码@8:通过ChannelInitializer添加自定义的ChannelHandler,通常包括编码解码器、业务Handler。

代码@9:调用管道的addLast添加自定义编码解码器。

代码@10:调用bind方法绑定到服务端指定接口,绑定完成后则在指点端口上监听客户端的连接。

服务端的核心流程入口为bind方法,接下来我们将详细分析其实现原理,继续体会NIO编程技巧。

2、Netty服务端启动流程


通过跟踪其bind方法,最终将进入到AbstractBootstrap的doBind方法。

图片

其关键实现点:
代码@1:通过调用initAndRegister方法完成底层网络初始化与通道注册工作。
代码@2:如果初始化与注册工作已完成,则直接调用doBind0方法完成绑定操作。

代码@3:如果初始化与注册工作未完成,则通过regFuture(注册凭证)中添加监听器,等注册完成后再执行doBind0方法。

技巧提示:基于Future异步编程,在主线程中通过调用future.isDone方法判断异步方法是否已完成,如果未完成,通过在该凭证上添加监听器(事件回调),操作完成后执行回调逻辑。

从上面的方法来看服务端的绑定流程包含初始化与绑定两个子流程,接下来将分别深入探讨。

2.1 通道初始化

基于NIO编程,需要先创建通道,然后将其注册到事件选择器,这个过程由 AbstractBootstrap 的 initAndRegister 方法实现。

图片

实现的关键点如下:
代码@1:创建NIO服务端通道实现类NioServerSocketChannel的实例。

代码@2:调用 init 方法初始化通道。

代码@3:将通道注册到事件轮询器EventLoopGroup

代码@4::如果通道已注册,但发生了错误则调用通道close方法回收相关资源,如果未注册成功,则强制清除通道占用的资源,特别是文件占用符。

关于通道的注册逻辑已经在手把手教你如何编写一个NIO客户端 中已详细介绍,故接下来重点关注一下服务端通道的注册流程。

2.1.1 服务端通道初始化流程

AbstractBootstrap 的 init 方法是一个抽象方法,具体有其子类实现:

图片

服务端通道的初始化代码由ServerBootstrap的init方法。


图片

Step1:首先将通过ServerBootstrap设置的选项与附加选项初始化到通道中。


图片

Step2:init 方法的关键点:将 handler 方法设置的事件链,同时新增 ServerBootstrapAcceptor 事件处理方法加入到 NioServerSocketChannel 的事件链,但并没有把 childHandler 中添加的事件链添加到NioServerSocketChannel。

读者朋友们,请停下来思考一下,为什么会这样?从现在可以肯定的是 handler 方法定义的事件处理方法将在与 NioServerSocketChannel 相关的事件发生时其作用。

要解开这个谜题,我们有必要来看看 ServerBootstrapAcceptor 是如何工作的。

2.1.2 ServerBootstrapAcceptor 详解

ServerBootstrapAcceptor 类图如下所示:

图片

ServerBootstrapAcceptor方法只实现了inbound事件的channelRead事件。在详细探究它之前先看看属性:

  • EventLoopGroup childGroup
    事件执行器组,ServerBootstrap设置的从Reactor线程组,即Work线程组。

  • ChannelHandler childHandler
    ServerBootstrap#childHandler 设置的事件处理器,也就是用户定义的事件处理器。

接下来探究其 channelRead 方法的实现逻辑:

图片

Step1:channelRead竟然传入的是一个Channel,那这个Channel对象是NioSocketChannel吗?

是的,原来当 OP_ACCEPT 事件触发后,Server端会通过调用ServerSocketChannel 的 accept()方法,将返回一个 NioSocketChannel,读写操作的载体,在NIO中负责数据的读写。

Step2:将通过 childHandler 定义的事件处理器绑定到 NioSocketChannel。

最终完成 NioServerSocketChannel 与 NioSocketChannel 的初始化与事件绑定。

关于 NioSocketChannel 详细的初始化流程蕴含在 ChannelInitializer,其机制已经在 手把手教你如何编写一个NIO客户端 中详细介绍。

2.2 NIO绑定机制

在通道完成初始化与注册后,服务端需要进行端口绑定,由 AbstractBootstrap 的 doBind0 方法实现。

图片

bind 的核心实现最终是调用 Channel 的 bind 方法,最终由 AbstractChannel 类实现:


图片

bind事件将传播,根据Netty事件传播机制,bind 属于 ChannelOutbound事件,最终将调用 HeadContext的bind方法,最终将调用Unsafe的bind方法,更加具体是调用 AbstractChannel的内部类AbstractUnsafe的bind方法,其代码如下所示:


图片

doBind 方法是一个抽象方法,NIO服务端的实现:NioServerSocketChannel。


图片

即最终通过调用NIO底层NioServerSocketChannel 的 bind 方法完成服务端通道的绑定操作,即实现服务端在特定端口监听客户客户端的连接请求。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 217,826评论 6 506
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,968评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,234评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,562评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,611评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,482评论 1 302
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,271评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,166评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,608评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,814评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,926评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,644评论 5 346
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,249评论 3 329
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,866评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,991评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,063评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,871评论 2 354

推荐阅读更多精彩内容