netty的启动过程是咋样的，就是那里启动了socket监听,咋处理请求的( 三 ) 从EchoServer

NioServerSocketChannel构造方法中我们看到已经创建了ServerSocketChannel，并且设置了IO模型，接下来我们关心的是ServerSocketChannel是在哪里注册监听Accept_Read事件的呢。我们从我们看fireChannelOpen(this)慢慢跟下去: public static void fireChannelOpen(Channel channel) { // Notify the parent handler. if (channel.getParent() != null) { fireChildChannelStateChanged(channel.getParent(), channel); } //封装一个UpstreamChannelStateEvent(channel, ChannelState.OPEN, Boolean.TRUE)，并发送一个上线的消息 channel.getPipeline().sendUpstream( new UpstreamChannelStateEvent( channel, ChannelState.OPEN, Boolean.TRUE)); }我们看到这个方法吧open这个事件封装成一个封装一个UpstreamChannelStateEvent传递下去了，那么它传递到哪了呢？接下来我们看SimpleChannelUpstreamHandler：
public void handleUpstream( ChannelHandlerContext ctx, ChannelEvent e) throws Exception { if (e instanceof MessageEvent) { messageReceived(ctx, (MessageEvent) e); } else if (e instanceof WriteCompletionEvent) { WriteCompletionEvent evt = (WriteCompletionEvent) e; writeComplete(ctx, evt); } else if (e instanceof ChildChannelStateEvent) { ChildChannelStateEvent evt = (ChildChannelStateEvent) e; if (evt.getChildChannel().isOpen()) { childChannelOpen(ctx, evt); } else { childChannelClosed(ctx, evt); } } else if (e instanceof ChannelStateEvent) { ChannelStateEvent evt = (ChannelStateEvent) e; switch (evt.getState()) { case OPEN: if (Boolean.TRUE.equals(evt.getValue())) { //UpstreamChannelStateEvent ChannelState.OPEN进到如下分之逻辑中 channelOpen(ctx, evt); } else { channelClosed(ctx, evt); } break; case BOUND: if (evt.getValue() != null) { channelBound(ctx, evt); } else { channelUnbound(ctx, evt); } break; case CONNECTED: if (evt.getValue() != null) { channelConnected(ctx, evt); } else { channelDisconnected(ctx, evt); } break; case INTEREST_OPS: channelInterestChanged(ctx, evt); break; default: ctx.sendUpstream(e); } } else if (e instanceof ExceptionEvent) { exceptionCaught(ctx, (ExceptionEvent) e); } else { ctx.sendUpstream(e); } }我们会发现SimpleChannelUpstreamHandler类中handleUpstream(ChannelHandlerContext ctx, ChannelEvent e) 方法主要负责处理各类的ChannelEvent，并将不同的event作不同的处理，而我们在前面传下来的UpstreamChannelStateEvent instanceof ChannelStateEvent，并且满足Boolean.TRUE.equals(evt.getValue()) 故封装成 channelOpen(ctx, evt);这个事件传递下去了。但是这里我们可能会疑惑，为什么上面的UpstreamChannelStateEvent事件会传到SimpleChannelUpstreamHandler类里面了，它是在哪里绑定的呢？我们回到上面的bindAsync方法中去，我们看这个Binder类，

netty的启动过程是咋样的，就是那里启动了socket监听,咋处理请求的( 三 )

推荐阅读

「大学生团员」镇江：战“疫”前后方团组织“大合唱”

饺子|今日冬至，记的吃碗饺子呀

高考志愿|高考志愿滑档是一种什么样的感受？把握这两点，远离滑档的拖累

林心如|林心如自曝：有次拍戏，导演让我跳臭水沟，后面就再没拍过他的戏

吃构杞子能提高性功能吗

职业装■上班怎么穿？不一样的职业装让你hold住全场

俄罗斯：希望七国集团正确看待恢复与俄罗斯关系问题

央视|国家外汇管理局：6月末我国外汇储备31123亿美元

不热爱生活，啥都觉得没意思

婴幼儿讲故事有哪些故事?给婴儿讲故事大全

老张爱篮球|就与詹娜深夜约会，还有小妹陪同，度假开启！布克离开园区第二天

笔记本|用上了这项新技术后笔记本的续航越来越差了

报复心理是什么,报复的意思-

穿越火线职业联赛|2020CFDL冠军杯战队排名数据汇总

央视新闻|大连新增本土确诊8例

慈禧墓中遗失的7件绝世珍宝?慈禧墓内部_1

已经有房有车的男人，咋样尽快实现财务自由综合稳定收入多少算财务自由

『就要买买买』红米K30再度降价200元，性价比超越荣耀30S！，迫于友商压力

异动|交易异动！卡倍亿：近3个交易日上涨34.13%，不存在未披露的重大事项

『』宝宝近视，最重要的还是预防