【Netty源码分析】02 Netty Server 启动流程 下_当前动态
上面我们分析了initAndRegister()
方法的核心流程,Channel
准备工作基本也都完成了:
(相关资料图)
Channel
和NioEventLoop
进行了关联;Channel
也注册到Selector
上了;NioEventLoop
线程也启动完成,开始轮询事件、处理事件。这里还遗漏了两个事情:channel
和端口绑定以及channel
向Selector
注册OP_ACCEPT
。这就是在doBind()
方法中另一个重要的方法:doBind0()
中进行完成的。
doBind0
if (regFuture.isDone()) { ChannelPromise promise = channel.newPromise(); doBind0(regFuture, channel, localAddress, promise); return promise;} else { final PendingRegistrationPromise promise = new PendingRegistrationPromise(channel); //register还未完成,则添加listener,待注册完成再执行doBind0()进行server端口绑定 regFuture.addListener(new ChannelFutureListener() { @Override public void operationComplete(ChannelFuture future) throws Exception { Throwable cause = future.cause(); if (cause != null) { promise.setFailure(cause); } else { promise.registered(); doBind0(regFuture, channel, localAddress, promise); } } }); return promise;}
上面代码一大堆,核心就是调用doBind0()
方法,但是执行该方法前必须保证上一步initAndRegister()
方法中执行完成。通过regFuture.isDone()
进行判断,具体设置位置见下:
//AbstractChannel.AbstractUnsafe#register0pipeline.invokeHandlerAddedIfNeeded();// 将指定的promise标记为成功:regFuture.isDone()=true,doBind0()才能开始执行safeSetSuccess(promise);pipeline.fireChannelRegistered();
进行向下跟踪,来到了如下代码处,会发现需要调用channel.bind()
方法,但是不是在当前线程中直接调用,而是封装成task
放入到NioEventLoop
的任务队列taskQueue
中,由NioEventLoop
线程执行:
private static void doBind0( final ChannelFuture regFuture, final Channel channel, final SocketAddress localAddress, final ChannelPromise promise) { channel.eventLoop().execute(new Runnable() { @Override public void run() { if (regFuture.isSuccess()) { channel.bind(localAddress, promise).addListener(ChannelFutureListener.CLOSE_ON_FAILURE); } else { promise.setFailure(regFuture.cause()); } } });}
这时的NioEventLoop
线程是已经启动并开始工作的,所以channel.bind()
这里是可以执行的。
层层调用最终是在pipeline
中的head
这个节点进行处理的:
public final void bind(final SocketAddress localAddress, final ChannelPromise promise) { assertEventLoop(); if (!promise.setUncancellable() || !ensureOpen(promise)) { return; } //还没有绑定端口,isActive()返回false boolean wasActive = isActive(); try { //调用底层java api,将channel绑定到具体端口上 doBind(localAddress); } catch (Throwable t) { safeSetFailure(promise, t); closeIfClosed(); return; } //经过上面绑定端口,这时isActive()=true if (!wasActive && isActive()) { invokeLater(new Runnable() { @Override public void run() { //触发server handler的channelActive()方法 pipeline.fireChannelActive(); } }); } safeSetSuccess(promise);}
这个方法主要完成2件事:
doBind()
:调用java api
,将channel
绑定到具体端口上;pipeline.fireChannelActive()
:将pipeline.fireChannelActive()
放入到NioEventLoop
线程中执行;下面我们再来看下pipeline.fireChannelActive()
:
public void channelActive(ChannelHandlerContext ctx) { ctx.fireChannelActive(); readIfIsAutoRead();}
该方法主要做2件事:
ctx.fireChannelActive()
:触发handler#channelActive()
调用,表示当前channel
已处于激活状态,可以正常工作了;readIfIsAutoRead()
:从名称看就是,如果配置autoRead
,调用readIfIsAutoRead()
直接进行read
操作;readIfIsAutoRead()
会调用tail.read()
,然后一层层往前查找,最终调用的是head#read()
方法。protected void doBeginRead() throws Exception { final SelectionKey selectionKey = this.selectionKey; if (!selectionKey.isValid()) { return; } readPending = true; final int interestOps = selectionKey.interestOps(); // 将SelectionKey当前的操作位与注册操作位进行按位与操作,如果等于0,说明目前并没有设置注册操作位 if ((interestOps & readInterestOp) == 0) { // Server Channel会在这里注册真正的ACCEPT事件 selectionKey.interestOps(interestOps | readInterestOp); }}
channel
绑定好端口后,触发了channelActive()
方法回调,channel
真正进入可以正常工作状态,这时还差最后一步:注册OP_ACCEPT
事件。
总结
这样,Netty
整体启动就全部完成,NioServerSocketChannel
这时就可以正常接收到客户端连接请求。
关键词:
上一篇:消息称,为避开欧盟反垄断调查微软提出改变云计算策略 精彩看点
下一篇:最后一页
- 环球速看:玻璃市场早报
- 衣服染色剂对人体的危害_衣服染色剂
- 世界热点评!天润工业:3月28日融资买入605.71万元,融资融券余额8524.48万元
- 环球视讯!爱威科技:3月28日融资净买入11.49万元,连续3日累计净买入97.26万元
- 合肥首个“双层高架”挑战高难度转体
- 俄方对安理会未通过涉“北溪”管道决议草案表示遗憾 天天最新
- 以数提效、以智赋能!2023年广西工业互联网创新发展大会在邕举行
- 热议:犀牛溜冰场好玩吗 犀牛溜冰场玩法简介
- 电脑打不了字只有字母怎么切换中文_电脑打不了字 讯息
- 助力重庆资本市场高质量发展 全面注册制下新三板挂牌制度专项培训会在重庆股转中心举办 每日动态
-
康城书院邮箱地址_康城书院邮箱
1、远在1800年前,汉灵帝中平五年(公元188年),郑玄就在这里创建了闻名遐迩的康成书院。2、郑玄在这里讲学授徒,据史
-
山竹的热量高吗_山竹的热量高不高呢 通讯
解答:1、100克山竹的热量在70卡左右,所以山竹不是高热量的水果。2、山竹含有大量的糖、膳食纤维、多种维生素,以及人体
-
天天热点评!东华软件龙虎榜数据(3月28日)
东华软件今日涨停,全天换手率14 33%,成交额33 64亿元,振幅9 58%。龙虎榜数据显示,机构净买入4808 57
-
世界速递!淘宝天猫发布TS100年度榜单
TS100年度榜单是根据淘宝天猫消费洞察和科学筛选标准推出。
-
北汽新能源公布车载健身专利
天眼查App显示,3月28日,北京新能源汽车股份有限公司申请的“车载健身装置及车辆”专利公布。专利摘要显示,该车载健身装置包括阻力装置以及
-
360电脑清理大师怎么卸载_360电脑清理大师|焦点快看
1、360清理大师软件有电脑版。2、现在其所有功能融合到360安全卫士里去了。3、下载并安装360安全卫士。4、2、打开
-
胡子鲶-观察
1、塘鲺,鱼类,可食用,学名胡子鲶,在分类上属鲇形目、胡子鲶科。2、属于热带、亚热带鱼类,广布于我国南方各地,既是营养丰
-
3月27日MTBE外盘市场收盘价上调
截止3月27日收盘,亚洲MTBE市场收盘价较上一交易日下调10 50美元 吨,FOB新加坡收于966 99-968 99美元 吨。欧洲MTBE市场收盘价较上一交
-
美团没有新故事
美团没有新故事,美团2022年财报没有任何意外
-
快自查!佛山这4560辆车被交警点名!-环球今头条
快自查!佛山这4560辆车被交警点名!,粤E11838、粤Y07862……这80辆重点车辆已被交警盯上还有4480辆车上路行驶将被查扣请各位车主赶紧自查!不要
X 关闭
全球头条:新能源布局加速落子 风电光伏建设正酣
每日速递:气体传感器的发展现状与未来展望
当前速递!国内三大石油企业发布半年报 目光投向新能源
【全球聚看点】如何在智能建筑物联网与隐私之间取得平衡
快资讯:欧洲7月电动汽车销量同比下滑5%
X 关闭
消息称,为避开欧盟反垄断调查微软提出改变云计算策略 精彩看点
非国家工作人员受贿行为包括什么呢-环球短讯
《普及洗地机高端技术,追觅洗地机家族新品M13 Beta多平台开售》 天天最新
环球热讯:图解南京化纤年报:第四季度单季净利润同比增69.28%
苹果推出 tvOS 16.5 Beta 1(20L5527d)更新 视点