二、Netty服务端/客户端启动整体流程
生活随笔
收集整理的這篇文章主要介紹了
二、Netty服务端/客户端启动整体流程
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
一、綜述
Netty 的整體流程相對來說還是比較復雜的，初學者往往會被繞暈。所以這里總結了一下整體的流程，從而對 Netty 的整體服務流程有一個大致的了解。從功能上，流程可以分為服務啟動、建立連接、讀取數據、業務處理、發送數據、關閉連接以及關閉服務。整體流程如下所示(圖中沒有包含關閉的部分)：
- Server端工作原理
每個boss NioEventLoop循環執行的任務包含3步：
- 第1步：輪詢accept事件；
- 第2步：處理io任務，即accept事件，與client建立連接，生成NioSocketChannel，并將NioSocketChannel注冊到某個worker NioEventLoop的selector上；
- 第3步：處理任務隊列中的任務，runAllTasks。任務隊列中的任務包括用戶調用eventloop.execute或schedule執行的任務，或者其它線程提交到該eventloop的任務。
每個worker NioEventLoop循環執行的任務包含3步：
- 第1步：輪詢read、write事件；
- 第2步：處理io任務，即read、write事件，在NioSocketChannel可讀、可寫事件發生時進行處理；
- 第3步：處理任務隊列中的任務，runAllTasks。
- Client端工作原理
client端啟動時connect到server，建立NioSocketChannel，并注冊到某個NioEventLoop的selector上。client端只包含1個NioEventLoopGroup，每個NioEventLoop循環執行的任務包含3步：
- 第1步：輪詢connect、read、write事件；
- 第2步：處理io任務，即connect、read、write事件，在NioSocketChannel連接建立、可讀、可寫事件發生時進行處理；
- 第3步：處理非io任務，runAllTasks。
二、啟動流程概述
- Netty服務端的啟動流程如下：
啟動流程大致分為五步
- netty客戶端啟動流程
- 關鍵步驟：
- 結合代碼解析：
三、NettyServer啟動源碼
public class NettyServer {public static void main(String[] args) throws Exception {//創建BossGroup 和 WorkerGroup//說明//1. 創建兩個線程組 bossGroup 和 workerGroup//2. bossGroup 只是處理連接請求 , 真正的和客戶端業務處理，會交給 workerGroup完成//3. 兩個都是無限循環//4. bossGroup 和 workerGroup 含有的子線程(NioEventLoop)的個數// 默認實際 cpu核數 * 2EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup(); //8try {//創建服務器端的啟動對象，配置參數ServerBootstrap bootstrap = new ServerBootstrap();//使用鏈式編程來進行設置bootstrap.group(bossGroup, workerGroup) //設置兩個線程組.channel(NioServerSocketChannel.class) //使用NioSocketChannel 作為服務器的通道實現.option(ChannelOption.SO_BACKLOG, 128) // 設置線程隊列得到連接個數.childOption(ChannelOption.SO_KEEPALIVE, true) //設置保持活動連接狀態 // .handler(null) // 該 handler對應 bossGroup , childHandler 對應 workerGroup.childHandler(new ChannelInitializer<SocketChannel>() {//創建一個通道初始化對象(匿名對象)//給pipeline 設置處理器@Overrideprotected void initChannel(SocketChannel ch) throws Exception {System.out.println("客戶socketchannel hashcode=" + ch.hashCode()); //可以使用一個集合管理 SocketChannel， 再推送消息時，可以將業務加入到各個channel 對應的 NIOEventLoop 的 taskQueue 或者 scheduleTaskQueuech.pipeline().addLast(new NettyServerHandler());}}); // 給我們的workerGroup 的 EventLoop 對應的管道設置處理器System.out.println(".....服務器 is ready...");//綁定一個端口并且同步, 生成了一個 ChannelFuture 對象//啟動服務器(并綁定端口)ChannelFuture cf = bootstrap.bind(6668).sync();//給cf 注冊監聽器，監控我們關心的事件cf.addListener(new ChannelFutureListener() {@Overridepublic void operationComplete(ChannelFuture future) throws Exception {if (cf.isSuccess()) {System.out.println("監聽端口 6668 成功");} else {System.out.println("監聽端口 6668 失敗");}}});//對關閉通道進行監聽cf.channel().closeFuture().sync();}finally {bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}} }- 簡要流程圖
- boosGroup和workerGroup內部結構圖
- 源碼解析：
- group : 兩個Reactor線程組（bossEventLoopGroup， workEventLoopGroup）
- channel: 服務端Channel
- option: 服務端socket參數配置 例如SO_BACKLOG指定內核未連接的Socket連接排隊個數
- handler 服務端Channel對應的Handler
- childHandler 客戶端請求Channel對應的Handler
這篇文章主要是分析Netty的啟動流程。我們直接看b.bind(PORT).sync()的源碼。bind 發現該方法內部實際調用的doBind(final SocketAddress localAddress)方法
- bind方法
doBind主要做了兩個事情
- initAndRegister() 初始化Channel
- doBind0 綁定監聽端口
channelFactory.newChannel()其實就是通過反射創建配置的服務端Channel類，在這里是NioServerSocketChannel
創建完成的NioServerSocketChannel進行一些初始化操作，例如將我們配置的Handler加到服務端Channel的pipeline中
將Channel注冊到EventLoopGroup中一個EventLoop上
下面我們來看下NioServerSocketChannel類的構造方法，看看它到底初始化了哪些東西，先看下其繼承結構
- NioServerSocketChannel初始化
下面是它的構造方法的調用順序，依次分為了四步
// 1 public NioServerSocketChannel() { // 通過 SelectProvider來初始化一個Java NioServerChannelthis(newSocket(DEFAULT_SELECTOR_PROVIDER)); }// 2. public NioServerSocketChannel(ServerSocketChannel channel) {super(null, channel, SelectionKey.OP_ACCEPT);// 創建一個配置類，持有Java Channelconfig = new NioServerSocketChannelConfig(this, javaChannel().socket()); }// 3. protected AbstractNioChannel(Channel parent, SelectableChannel ch, int readInterestOp) {super(parent);this.ch = ch;this.readInterestOp = readInterestOp;try {// 設置Channel為非阻塞ch.configureBlocking(false);} catch (IOException e) {try {ch.close();} catch (IOException e2) {logger.warn("Failed to close a partially initialized socket.", e2);}throw new ChannelException("Failed to enter non-blocking mode.", e);} }// 4 protected AbstractChannel(Channel parent) {this.parent = parent;// 生成一個channel Idid = newId();// 創建一個 unSafe 類，unsafe封裝了Netty底層的IO讀寫操作unsafe = newUnsafe();// 創建一個 pipeline類pipeline = newChannelPipeline(); }可以看到NioServerSocketChannel的構造函數主要是初始化并綁定了以下3類
init(Channel channel)
void init(Channel channel) { // 設置Socket參數setChannelOptions(channel, newOptionsArray(), logger);setAttributes(channel, attrs0().entrySet().toArray(EMPTY_ATTRIBUTE_ARRAY));ChannelPipeline p = channel.pipeline();// 子EventLoopGroup用于完成Nio讀寫操作final EventLoopGroup currentChildGroup = childGroup;// 為workEventLoop配置的自定義Handlerfinal ChannelHandler currentChildHandler = childHandler;final Entry<ChannelOption<?>, Object>[] currentChildOptions;synchronized (childOptions) {currentChildOptions = childOptions.entrySet().toArray(EMPTY_OPTION_ARRAY);}// 設置附加參數final Entry<AttributeKey<?>, Object>[] currentChildAttrs = childAttrs.entrySet().toArray(EMPTY_ATTRIBUTE_ARRAY);// 為服務端Channel pipeline 配置 對應的Handlerp.addLast(new ChannelInitializer<Channel>() {@Overridepublic void initChannel(final Channel ch) {final ChannelPipeline pipeline = ch.pipeline();ChannelHandler handler = config.handler();if (handler != null) {pipeline.addLast(handler);}ch.eventLoop().execute(new Runnable() {@Overridepublic void run() {pipeline.addLast(new ServerBootstrapAcceptor(ch, currentChildGroup, currentChildHandler, currentChildOptions, currentChildAttrs));}});}}); }這里主要是為服務端Channel配置一些參數，以及對應的處理器ChannelHandler，注意這里不僅僅會把我們自定義配置的ChannelHandler加上去，同時還會自動幫我們加入一個系統Handler(ServerBootstrapAcceptor)，這就是Netty用來接收客戶端請求的Handler，在ServerBootstrapAcceptor內部會完成SocketChannel的連接，EventLoop的綁定等操作，之后我們會著重分析這個類
Channel的注冊
// MultithreadEventLoopGroup public ChannelFuture register(Channel channel) { // next()會選擇一個EventLoop來完成Channel的注冊return next().register(channel); }// SingleThreadEventLoop public ChannelFuture register(Channel channel) {return register(new DefaultChannelPromise(channel, this)); } // AbstractChannel public final void register(EventLoop eventLoop, final ChannelPromise promise) {ObjectUtil.checkNotNull(eventLoop, "eventLoop");if (isRegistered()) {promise.setFailure(new IllegalStateException("registered to an event loop already"));return;}if (!isCompatible(eventLoop)) {promise.setFailure(new IllegalStateException("incompatible event loop type: " + eventLoop.getClass().getName()));return;}AbstractChannel.this.eventLoop = eventLoop;if (eventLoop.inEventLoop()) {// 注冊邏輯register0(promise);} .... }完成注冊流程
到這里為止，其實Netty服務端已經基本啟動完成了，就差綁定一個監聽端口了。可能讀者會很詫異，怎么沒有看到Nio線程輪詢 IO事件的循環呢，講道理肯定應該有一個死循環才對？那我們下面就把這段代碼找出來
在之前的代碼中，我們經常會看到這樣一段代碼
// 往EventLoop中丟了一個異步任務（其實是同步的，因為只有一個Nio線程，不過因為是事件循環機制（丟到一個任務隊列中），看起來像是異步的） eventLoop.execute(new Runnable() {@Overridepublic void run() {...} });eventLoop.execute到底做了什么事情？
private void execute(Runnable task, boolean immediate) {boolean inEventLoop = inEventLoop();// 把當前任務添加到任務隊列中addTask(task);// 不是Nio線程自己調用的話，則表明是初次啟動if (!inEventLoop) {// 啟動EventLoop的Nio線程startThread();...}... }/*** 啟動EventLoop的Nio線程*/ private void doStartThread() {assert thread == null;// 啟動Nio線程executor.execute(new Runnable() {@Overridepublic void run() {thread = Thread.currentThread();if (interrupted) {thread.interrupt();}boolean success = false;updateLastExecutionTime();try {SingleThreadEventExecutor.this.run();success = true;} catch (Throwable t) {logger.warn("Unexpected exception from an event executor: ", t);} finally {... }通過上面的代碼可以知道這里主要做了兩件事情
NioEventLoop的Run方法實現
到這里的代碼是不是就非常熟悉了，熟悉的死循環輪詢事件
- doBind0
實際的Bind邏輯在 NioServerSocketChannel中執行，我們直接省略前面一些冗長的調用，來看下最底層的調用代碼，發現其實就是調用其綁定的Java Channel來執行對應的監聽端口綁定邏輯
四、Netty服務端詳細的工作流程圖
流程圖
參考文章1
參考文章2
參考文章3
總結
以上是生活随笔為你收集整理的二、Netty服务端/客户端启动整体流程的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 互联网晚报 | 8月26日 星期四 |
- 下一篇： 苏杰专访：产品创新好方向=几十年不变的需