Netty中如何實現TimeServer

這篇文章主要介紹Netty中如何實現TimeServer，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

No1、什么是Netty

Netty是業界最流行的NIO框架之一，它的性能、健壯性、應用范圍等都在同類框架中首屈一指。例如RPC框架dubbo、Hadoop的RPC框架Avro就使用Netty作為底層的通信框架。

No2、JDK中的I/O的缺點

相信大家學過Socket編程的朋友們都看到過如下的代碼：

處理邏輯圖如下所示

這是一個最簡單的Socket程序，服務端接收到request后立即創建一個線程來處理這個request。看起來沒什么毛病，但是如果并發量稍稍大一點的話，server端創建線程、銷毀線程會特別消耗性能。有朋友一定會說，既然系統的瓶頸在線程的創建和銷毀上，用線程池不久可以了嗎？將系統創建的線程數控制在一定范圍內，不會因為并發量而耗盡系統線程。確實是這樣，但由于底層的通信依然采用同步阻塞模型，無法從根本上解決問題。

No3、為什么選擇Netty

不選擇JAVA原生NIO的原因如下：

• NIO庫和API復雜

• 代碼復雜

• 入門困難，需要大量JAVA知識儲備

• JDK NIO的Bug

• 。。。

選擇Netty的原因如下：

• API簡單，開發門檻低

• 功能強大，預置了多種編碼解碼功能

• 性能高，成熟穩定

• 社區活躍度高

• 修復了NIO中已發現的所有Bug

• 。。。

No4、Netty入門小Demo——TimeServer

好，下面我們就來寫一個最簡單的基于Netty的網絡小程序，程序功能是client鏈接到server，server給client返回當前的時間

Step1、工程搭建

創建一個maven工程，引入相關的依賴

Step2、編寫服務端——TimeServer

1. 創建兩個NioEventLoopGroup實例，NioEventLiipGroup是一個線程組，它包含了一組NIO線程。創建兩個的原因是一個用于服務端接收客戶端的連接，另一個用于Sockerchannel的讀寫。

2. 創建ServerBootstrap，它是Netty啟動服務的啟動類，將EventLoop Group傳入ServerBootstrap中，最后綁定I/O事件的處理類ChildChannelHandler。

3. bind端口，調用同步阻塞方法sync等待綁定操作完成，并返回一個ChannelFuture對象，它的功能類似于java.util.concurrent.Future，主要用于異步回調。

4. 等待服務器端鏈路關閉后main方法結束

   
   

   
   

I/O事件處理類ChildChannelHandler.java的實現

1. 將msg轉化為ByteBuf對象，此對象相當于byte[]，不過比byte[]封裝了更多操作。

2. ByteBuf的readableBytes()方法可以獲取緩沖區中可讀到的字節數，并將它寫入byte[]中

3. 創建響應，并寫給客戶端。

這就是server端的代碼，很簡單吧

Step3、編寫客戶端——TimeClient

1. 創建EventLoopGroup實例

2. 創建Bootstrap實例，與TimeServer不同的是，此處Channel需要設置為NioSockerChannel

3. 調用connect發起異步連接，然后調用sync等待連接成功

4. 關閉連接，釋放資源

TimeClientHandler.java的實現

1. 當client與server的TCP連接成功后，Netty的NIO線程調用channelActive方法，向服務器發送請求

2. 將byte[]數據封裝到ByteBuf中，并發送請求

3. 將響應msg轉化為ByteBuf對象，寫入byte[]中

4. 打印響應數據

以上是“Netty中如何實現TimeServer”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！