服务端_说说Netty服务端启动流程

点击上方☝SpringForAll社区 轻松关注！及时获取有趣有料的技术文章

本文来源：http://yeming.me/2016/03/12/netty1/

netty服务端代码分析

服务端启动配置

对于 ServerBootstrap：ServerBootstrap继承于 AbstractBootstrap，它从父类继承了 EventLoopGroupgroup， ChannelFactoryextendsC>channelFactory，自己新增了 EventLoopGroupchildGroup， ChannelHandlerchildHandler。上面 b.group开始的链式代码就是初始化上面这些属性的值的。

bossgroup和 workergroup：可以看到都是 NioEventLoopGroup,可以理解成2个线程池。从 bossgroup中随便选一个作为 Reactor模型中的 acceptor，监听客户端连接，创建 socketChannel，然后从 workergroup选取一个io线程来处理 socketChannel的读取事件。

对于 NioEventLoopGroup和 NioEventLoop：先看下类图

可以看到 NioEventLoopGroup继承了 EventLoopGroupNioEventLoop实现了EventLoop,而EventLoop又继承自EventLoopGroup。eventloopgroup.next()又可以返回一个eventloop。可以看到EventLoop最终继承于线程池Executor。而最终NioEventLoopGroup又实现了EventLoop，接下来我们还会分析下NioEventLoopGroup

服务端注册感兴趣事件和监听端口

注册感兴趣事件

b.bind最终调用到AbstractBootstrop的以下方法

final ChannelFuture initAndRegister() {

this.group().register(channel);(中间省略)

}

这个this.group就是一开始设置的bossgroup(NioEventLoopGroup),看到这个方法基本可以想到这个应该是把channel注册到某个选择器上

MultithreadEventLoopGroup

public ChannelFuture register(Channel channel) {

return this.next().register(channel);

}

上面的类图已经可以看出 NioEventLoopGroup继承自 MultithreadEventLoopGroup，最终 this.next()又会返回 NioEventLoop，所以也就是可以理解是把 channel注册到 NioEventLoop上(我们猜想 NioEventLoop可以想象成封装了一个 selector)

this.next()返回 NioEventLoop继承于 SingleThreadEventLoopchannel.unsafe().register(this,promise);最终调用到 AbstractUnsafe的 register方法

eventLoop.execute(new OneTimeTask() {

public void run() {

AbstractUnsafe.this.register0(promise);

}

});

这里通过 bossgroup启动一个线程

最终调用到

protected void doRegister() throws Exception {

boolean selected = false;

while(true) {

try {

this.selectionKey = this.javaChannel().register(this.eventLoop().selector, 0, this);

return;

} catch (CancelledKeyException var3) {

if(selected) {

throw var3;

}

this.eventLoop().selectNow();

selected = true;

}

监听端口

可以看到第四张截图

ChannelFuture regFuture = this.initAndRegister();

if(regFuture.cause() != null) {

return regFuture;

} else if(regFuture.isDone()) {

doBind0(regFuture, channel, localAddress, promise1); return promise1;

} else {

AbstractBootstrap.doBind0(regFuture, channel, localAddress, promise); } }); return promise;

}

可以看到 initAndRegister()这个方法就是上面我们说的注册感兴趣的事件。后面的 elseif和 else都有 dobind0 方法，这个方法也是通过之前的线程池启动一个线程去监听一个端口。

参考

netty api说明http://www.boyunjian.com/javadoc/io.netty/netty-transport/4.0.0.Alpha7//io/netty/channel/DefaultChannelFuture.htmlNetty 4源码解析：服务端启动http://blog.csdn.net/dc726/article/details/47858077Netty 4源码解析：请求处理http://blog.csdn.net/dc726/article/details/48084367Netty系列之Netty线程模型(http://www.infoq.com/cn/articles/netty-threading-model?utmsource=infoq&utmmedium=popularlinks_homepage