首页 > 代码库 > Netty3 源代码分析 - NIO server绑定过程分析

Netty3 源代码分析 - NIO server绑定过程分析

Netty3 源代码分析 - NIO server绑定过程分析

     一个框架封装的越好,越利于我们高速的coding。可是却掩盖了非常多的细节和原理。可是源代码可以揭示一切。

服务器端代码在指定好ChannelFactory。设定好选项。而后Bootstrap.bind操作就会开启server。接受对端的连接。

所以有必要对这后面的过程分析清楚,下图是关键流程。先是构建一个默认的Pipeline,为我们接下来要创建的监听通道服务。这个Pipeline里面会增加一个Binder的上行事件处理器。接下来创建了至关中的NioServerSocketChannel,在构造的过程中,调用了NIO中ServerSocketChannel的open方法打开套接字,设为非堵塞,然后会触发一个OPEN的上行 ChannelStateEvent(为后文买下伏笔),接下来Bootstrap就会等待着成功的信号。还有一方面,在将Binder这个Handler增加bossPipeline的时候,它就已经准备好运转了,在收到一个OPEN事件后,就会设置套接字选项,运行真正的套接字绑定,而后Future.setSuccess就会让前面的bind方法成功返回,開始运转。

代码例如以下:
public void channelOpen( ChannelHandlerContext ctx, ChannelStateEvent evt) {

            try {
                 // 内部类能够訪问外部类的方法 。如 getPipelineFactory()。
                evt.getChannel().getConfig().setPipelineFactory(getPipelineFactory());

                // Split options into two categories: parent and child.
                Map<String, Object> allOptions = getOptions();
                Map<String, Object> parentOptions = new HashMap<String, Object>();
                for (Entry<String, Object> e: allOptions.entrySet()) {
                    if (e.getKey().startsWith( "child.")) {
                        childOptions.put( e.getKey().substring(6), e.getValue());
                    } else if (!"pipelineFactory" .equals(e.getKey())) {
                        parentOptions.put(e.getKey(), e.getValue());
                    }
                }

                // Apply parent options.
                evt.getChannel().getConfig().setOptions(parentOptions);
            } finally {
                ctx.sendUpstream(evt);
            }

            //============ 真正的绑定套接字 =======
            evt.getChannel().bind( localAddress).addListener( new ChannelFutureListener() {
                public void operationComplete(ChannelFuture future) throws Exception {
                    if (future.isSuccess()) {
                      // 这里触发了 bind的成功
                        bindFuture.setSuccess();
                    } else {
                        bindFuture.setFailure(future.getCause());
                    }
                }
            });
        }


技术分享




更具体的理解看Netty3 源代码凝视,见Github。



Netty3 源代码分析 - NIO server绑定过程分析