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绑定过程分析相关推荐

Android系统进程间通信（IPC）机制Binder中的Server启动过程源代码分析
原文地址: http://blog.csdn.net/luoshengyang/article/details/6629298 在前面一篇文章浅谈Android系统进程间通信(IPC)机制Binder ...
Android应用程序绑定服务（bindService）的过程源代码分析
Android应用程序组件Service与Activity一样,既可以在新的进程中启动,也可以在应用程序进程内部启动:前面我们已经分析了在新的进程中启动Service的过程,本文将要介绍在应用程序内部 ...
Android系统进程间通信（IPC）机制Binder中的Client获得Server远程接口过程源代码分析(2)...
注意,这里的参数reply = 0,表示这是一个BC_TRANSACTION命令. 前面我们提到,传给驱动程序的handle值为0,即这里的tr->target.handle = ...
Android应用程序进程启动过程的源代码分析（1）
Android应用程序框架层创建的应用程序进程具有两个特点,一是进程的入口函数是ActivityThread.main,二是进程天然支持Binder进程间通信机制:这两个特点都是在进程的初始化过程中实 ...
Android系统进程Zygote启动过程的源代码分析
原文地址:http://blog.csdn.net/luoshengyang/article/details/6747696 Android应用程序框架层创建的应用程序进程具有两个特点,一是进程的入口 ...
Android应用Activity、Dialog、PopWindow、Toast窗体加入机制及源代码分析
[工匠若水 http://blog.csdn.net/yanbober 转载烦请注明出处.尊重劳动成果] 1 背景之所以写这一篇博客的原因是由于之前有写过一篇<Android应用setCont ...
Bind9源代码分析
Bind9源代码分析 1.串一遍resolver.c和dispacth.c里面的内容 dns_resolver_prime(请求解析器开始一个fetch启动,如果它还没有启动.一些启动判断,然后进行了 ...
Hadoop源代码分析
http://wenku.baidu.com/link?url=R-QoZXhc918qoO0BX6eXI9_uPU75whF62vFFUBIR-7c5XAYUVxDRX5Rs6QZR9hrBnUdM ...
SRS4.0源代码分析之RTMP拉流处理
目标: 上一节分析了SRS针对推流客户端的处理逻辑,这里接下来分析针对拉流客户端的处理逻辑. SRS拉流端处理逻辑简单说就是SrsRtmpConn::do_playing()协程从SrsLiveCon ...

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

Netty3 源代码分析 - NIO server绑定过程分析相关推荐

最新文章

热门文章