上面我们分析了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
这时就可以正常接收到客户端连接请求。
关键词:
(责任编辑:黄俊飞)推荐内容
- 执教两个多月力助高芙首进美网决赛,郑钦
- CPI同比由降转涨 8月份上涨0.1%
- “亚运文旅之约”推出12条主题漫游长廊
- “灯塔工厂”点亮“未来制造”
- 华晟经世与NVIDIA正式成为合作伙伴
- 魔兽世界中的频道修改权限怎么改 魔兽世
- 完美充值会员能不能跳过新手(完美充值)
- 西部牧业:公司没有涉足水产养殖饲料
- 润贝航科:拟1.8亿元投建先进航空复合材
- 高股息率+稳健成长股曝光!5股PE不足10倍
- “金融16条”发布以来 哪些银行在积极增
- 天原股份董秘回复:磷酸铁锂正极材料认证
- 可穿戴设备也能“可支付”了?「支付芯」
- “曹氏鸭脖”企业号自曝使用大量添加剂?
- 河北义务教育阶段适龄残疾儿童少年入学率
- A股异动 | 冠石科技三连板 “华为含量
- 北京地铁APP9月1日升级,新增这些功能
- 中国8月财新制造业PMI 51
- 天禄辟邪百解(天禄辟邪)
- 8月份经济景气水平总体稳定
- 《最后的真相》成都路演:闫妮称黄晓明有
- 北京 演唱会 2021_sj北京演唱会
- 美军仓皇撤离阿富汗两周年丨美专家:战争
- 纳税人为工商户店名的,购房须提供营业执
- 谷歌Chrome浏览器带来新品!允许用户将密
- 长沙市第四医院:开展就医体验调研 让患
- 璞泰来上半年营收增13%净利降6.6% 股价涨1.61%
- 中报速递|时代中国上半年营收约99亿元
- 备孕需要吃什么维生素(备孕需要吃什么)
- 装甲核心6辅助装备推进器怎么获得 装甲
- 抖音推出“开学公开课”系列知识直播,10
- 争做社区共建小主人
- 河源市源城区新韵物业管理100%股权被挂牌
- 梦东方(00593.HK):延迟刊发2023年中期业绩
- 开个文具店大概要多少钱(开个文具店需要
- 张家界严查“摩电”交通违法 优化“创文
- 迪迩秀 | 金砖合作:强化南南关系与推
- 合肥百货:控股股东建投集团自愿承诺不减
- 中山街道超多公益课程来啦!大人、孩子都
- 涡阳县楚店镇:老有所学 快乐无限
- 学习语丨把铸牢中华民族共同体意识工作抓
- 凤竹纺织(600493)每日收评(08-30)
- 搭载“候鸟团”的车子趴窝在高速,幸亏他
- 华为Mate 60回归!红魔发海报欢迎 网友
- 机械键盘怎么打大写_机械键盘怎么打数字
- 青海有机枸杞产品远销世界30多个国家和地
- 深夜刷屏!苹果宣布大消息,英伟达又爆了
- 超200亿!票房成绩刷新暑期档影史纪录
- 海军某支队着力提升政治干部军事素质融入
- 肺部“大救星”找到了,不是莲藕!抓紧吃
- 滨江集团2023年8月29日晚间披露2023年半
- 香港恒生指数收涨1.95% 恒生科技指数涨2.59%
- 1-0,第42分钟,瓦伦西亚禁区内犯规,裁
- 新疆阿克苏地区库车市发生3.7级地震 震
- 风力太大 日本探月发射再次受挫
- 生益科技:覆铜板价格仍有压力
- 全民反诈齐行动 给财产加个“金钟罩”
- 穆迪料仁恒置地信用指标和流动性缓冲将在
- 谁花5555元买早餐了老板正找你!老板:百
- 天能动力(00819)发布中期业绩,股东应占
- 《最后的真相》成都路演:闫妮称黄晓明有
- 北京 演唱会 2021_sj北京演唱会
- 美军仓皇撤离阿富汗两周年丨美专家:战争
- 纳税人为工商户店名的,购房须提供营业执
- 谷歌Chrome浏览器带来新品!允许用户将密
- 长沙市第四医院:开展就医体验调研 让患
- 璞泰来上半年营收增13%净利降6.6% 股价涨1.61%
- 中报速递|时代中国上半年营收约99亿元
- 备孕需要吃什么维生素(备孕需要吃什么)
- 装甲核心6辅助装备推进器怎么获得 装甲
- 抖音推出“开学公开课”系列知识直播,10
- 争做社区共建小主人
- 河源市源城区新韵物业管理100%股权被挂牌
- 梦东方(00593.HK):延迟刊发2023年中期业绩
- 开个文具店大概要多少钱(开个文具店需要
- 张家界严查“摩电”交通违法 优化“创文
- 迪迩秀 | 金砖合作:强化南南关系与推
- 合肥百货:控股股东建投集团自愿承诺不减
- 中山街道超多公益课程来啦!大人、孩子都
- 涡阳县楚店镇:老有所学 快乐无限
- 学习语丨把铸牢中华民族共同体意识工作抓
- 凤竹纺织(600493)每日收评(08-30)
- 搭载“候鸟团”的车子趴窝在高速,幸亏他
- 华为Mate 60回归!红魔发海报欢迎 网友
- 机械键盘怎么打大写_机械键盘怎么打数字
- 青海有机枸杞产品远销世界30多个国家和地
- 深夜刷屏!苹果宣布大消息,英伟达又爆了
- 超200亿!票房成绩刷新暑期档影史纪录
- 海军某支队着力提升政治干部军事素质融入
- 肺部“大救星”找到了,不是莲藕!抓紧吃
- 滨江集团2023年8月29日晚间披露2023年半
- 香港恒生指数收涨1.95% 恒生科技指数涨2.59%
- 1-0,第42分钟,瓦伦西亚禁区内犯规,裁
- 新疆阿克苏地区库车市发生3.7级地震 震
- 风力太大 日本探月发射再次受挫
- 生益科技:覆铜板价格仍有压力
- 全民反诈齐行动 给财产加个“金钟罩”
- 穆迪料仁恒置地信用指标和流动性缓冲将在
- 谁花5555元买早餐了老板正找你!老板:百
- 天能动力(00819)发布中期业绩,股东应占
- 吉林省通化市2023-08-28 20:06发布山洪
- 伟禄集团(01196)发布中期业绩,股东应占
- 成都国际车展 兰博基尼中国总经理专访
- 两部门:自2023年8月28日起 证券交易印
- 适合宿舍用的高品质快充插座推荐
- Vlog|东北亚博览会中的衣食住行
- 粤东雷高速完成全线架梁施工 计划年底通车
- 郑州将打造“四新”一流国资国企
- 未成年充值手游万元,家长申诉退款通过后
- 余承东:新款问界M7预售价25.8万起 9月1
- 志愿者们,准备好了
- 证监会:将投资者融资买入证券时的融资保
- 一架美国军机在澳大利亚坠毁 3名美军人
- 大巴起火致车上7岁女孩烧伤,医院:伤情
- 相亲相爱一家人歌词完整版分别是谁唱的?_
- 《装甲核心6》Steam在线峰值破15万!位列
- 日本排污入海后:水产供应端格局生变 淡
- 【德州电锯杀人狂】新手向入坑简易指南&
- 郭艾伦:这时候最着急的就是李凯尔自己了
- 河南省委组织部发布4名同志拟任职公示