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绑定过程分析

最新文章

热门文章