首页 > 代码库 > 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绑定过程分析
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。