服务端_说说Netty服务端启动流程
本文來源：http://yeming.me/2016/03/12/netty1/
netty服務(wù)端代碼分析
服務(wù)端啟動(dòng)配置
對于 ServerBootstrap：ServerBootstrap繼承于 AbstractBootstrap，它從父類繼承了 EventLoopGroupgroup， ChannelFactoryextendsC>channelFactory，自己新增了 EventLoopGroupchildGroup， ChannelHandlerchildHandler。上面 b.group開始的鏈?zhǔn)酱a就是初始化上面這些屬性的值的。
bossgroup和 workergroup：可以看到都是 NioEventLoopGroup,可以理解成2個(gè)線程池。從 bossgroup中隨便選一個(gè)作為 Reactor模型中的 acceptor，監(jiān)聽客戶端連接，創(chuàng)建 socketChannel，然后從 workergroup選取一個(gè)io線程來處理 socketChannel的讀取事件。
對于 NioEventLoopGroup和 NioEventLoop：先看下類圖
可以看到 NioEventLoopGroup繼承了 EventLoopGroupNioEventLoop實(shí)現(xiàn)了EventLoop,而EventLoop又繼承自EventLoopGroup。eventloopgroup.next()又可以返回一個(gè)eventloop。可以看到EventLoop最終繼承于線程池Executor。而最終NioEventLoopGroup又實(shí)現(xiàn)了EventLoop，接下來我們還會(huì)分析下NioEventLoopGroup
服務(wù)端注冊感興趣事件和監(jiān)聽端口
注冊感興趣事件
b.bind最終調(diào)用到AbstractBootstrop的以下方法
final ChannelFuture initAndRegister() {
this.group().register(channel);(中間省略)
}
這個(gè)this.group就是一開始設(shè)置的bossgroup(NioEventLoopGroup),看到這個(gè)方法基本可以想到這個(gè)應(yīng)該是把channel注冊到某個(gè)選擇器上
MultithreadEventLoopGroup
public ChannelFuture register(Channel channel) {
return this.next().register(channel);
}
上面的類圖已經(jīng)可以看出 NioEventLoopGroup繼承自 MultithreadEventLoopGroup，最終 this.next()又會(huì)返回 NioEventLoop，所以也就是可以理解是把 channel注冊到 NioEventLoop上(我們猜想 NioEventLoop可以想象成封裝了一個(gè) selector)
this.next()返回 NioEventLoop繼承于 SingleThreadEventLoopchannel.unsafe().register(this,promise);最終調(diào)用到 AbstractUnsafe的 register方法
eventLoop.execute(new OneTimeTask() {
public void run() {
AbstractUnsafe.this.register0(promise);
}
});
這里通過 bossgroup啟動(dòng)一個(gè)線程
最終調(diào)用到
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;
}
}
}
監(jiān)聽端口
可以看到第四張截圖
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()這個(gè)方法就是上面我們說的注冊感興趣的事件。后面的 elseif和 else都有 dobind0 方法，這個(gè)方法也是通過之前的線程池啟動(dòng)一個(gè)線程去監(jiān)聽一個(gè)端口。
參考
netty api說明http://www.boyunjian.com/javadoc/io.netty/netty-transport/4.0.0.Alpha7//io/netty/channel/DefaultChannelFuture.htmlNetty 4源碼解析：服務(wù)端啟動(dòng)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
●?Spring IOC流程清楚不？聊聊看
●?面試官：ScheduleThreadPoolExecutor了解不？
●?配置中心只有Apollo么？看看點(diǎn)評的Lion
●?面試官說從源碼角度說說Java線程池
●?JedisPool連接池相關(guān)配置
●?Hystrix初探
●?別再關(guān)注刪庫跑路了，談?wù)剶?shù)據(jù)庫架構(gòu)
●?那些年非常火的MyCAT是什么？
●?Java14帶來了許多新功能
●?關(guān)于爛代碼的那些事(上)
●?關(guān)于整潔代碼的那些事(中)
●?關(guān)于整潔代碼的那些事(下)
●?面試官說Spring AOP 實(shí)現(xiàn)原理給我說說
●?深入理解JVM - 方法調(diào)用
●?Spring Boot神操作-多個(gè)數(shù)據(jù)源Service層封裝
●?Lombok經(jīng)常用，但是你知道它的原理是什么嗎？
總結(jié)
以上是生活随笔為你收集整理的服务端_说说Netty服务端启动流程的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： excel打开空白_啥？下载的文件显示“
- 下一篇： crc java_java实现CRC16