在使用Netty進行網路程式設計的時候，通常需要在網路連線的不同階段進行相應的操作，比如在連線建立時，客戶端向服務端發起認證，在接收到資料時對資料內容進行解析等等。那麼，連線的不同階段在netty中如何表示呢？ 這便是本文討論的內容，Netty中ChannelHandller的生命週期。 首先我們先分析小網路連線的生命週期，連線建立 ---> 資料互動 ---> 連線斷開，在資料互動階段，包括從連線中讀取資料和向連線中寫入資料。知道了連線的生命週期，就可以按圖索驥的在各個階段進行想要的操作。而在Netty中，網路連線的不同生命週期都可以通過回撥的方式來繫結相應的邏輯，這個回撥介面就是`ChannelHandler`,這裡主要我們以`ChannelInboundHandler`為例進行分析。在`ChannelInboundHandler`中定義瞭如下和生命週期相關的介面： * channelRegistered * channelUnregistered * channelActive * channelInactive * channelRead * channelReadComplete 加上在父類``中定義的兩個: * handlerAdded * handlerRemoved 這些回撥介面的呼叫書序是什麼呢?我們通過寫一個`LifeCycleHandler`來看下ChannelInboundHandler的生命週期的順序。 ```java public class LifeCycleInBoundHandler extends ChannelInboundHandlerAdapter { @Override public void channelRegistered(ChannelHandlerContext ctx) throws Exception { out.println("channelRegistered: channel註冊到NioEventLoop"); super.channelRegistered(ctx); } @Override public void channelUnregistered(ChannelHandlerContext ctx) throws Exception { out.println("channelUnregistered: channel取消和NioEventLoop的繫結"); super.channelUnregistered(ctx); } @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { out.println("channelActive: channel準備就緒"); super.channelActive(ctx); } @Override public void channelInactive(ChannelHandlerContext ctx) throws Exception { out.println("channelInactive: channel被關閉"); super.channelInactive(ctx); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { out.println("channelRead: channel中有可讀的資料" ); super.channelRead(ctx, msg); } @Override public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { out.println("channelReadComplete: channel讀資料完成"); super.channelReadComplete(ctx); } @Override public void handlerAdded(ChannelHandlerContext ctx) throws Exception { out.println("handlerAdded: handler被新增到channel的pipeline"); super.handlerAdded(ctx); } @Override public void handlerRemoved(ChannelHandlerContext ctx) throws Exception { out.println("handlerRemoved: handler從channel的pipeline中移除"); super.handlerRemoved(ctx); } } ``` 啟動伺服器和Client，連線成功後，斷開client的連線，Server端輸出結果如下： ``` handlerAdded: handler被新增到channel的pipeline channelRegistered: channel註冊到NioEventLoop channelActive: channel準備就緒 channelRead: channel中有可讀的資料 channelReadComplete: channel讀資料完成 channelReadComplete: channel讀資料完成 channelInactive: channel被關閉 channelUnregistered: channel取消和NioEventLoop的繫結 handlerRemoved: handler從channel的pipeline中移除 ``` 從上面結果可以知道，從連線建立到連線斷開，handler的生命週期回撥介面呼叫順序如下： ``` handlerAdded -> channelRegistered -> channelActive -> channelRead -> channelReadComplete -> channelInactive -> channelUnRegistered -> handlerRemoved ``` 下面具體說下每個回撥的具體含義： 1. handlerAdded: 新建立的連線會按照初始化策略，把handler新增到該channel的pipeline裡面，也就是channel.pipeline.addLast(new LifeCycleInBoundHandler)執行完成後的回撥； 2. channelRegistered: 當該連線分配到具體的worker執行緒後，該回調會被呼叫。 3. channelActive：channel的準備工作已經完成，所有的pipeline新增完成，並分配到具體的線上上，說明該channel準備就緒，可以使用了。 4. channelRead：客戶端向服務端發來資料，每次都會回撥此方法，表示有資料可讀； 5. channelReadComplete：服務端每次讀完一次完整的資料之後，回撥該方法，表示資料讀取完畢； 6. channelInactive：當連線斷開時，該回調會被呼叫，說明這時候底層的TCP連線已經被斷開了。 7. channelUnREgistered: 對應channelRegistered，當連線關閉後，釋放繫結的workder執行緒； 8. handlerRemoved： 對應handlerAdded，將handler從該channel的pipeline移除後的回撥方法。

相關推薦