Netty中如何實(shí)現(xiàn)TimeServer

這篇文章主要介紹Netty中如何實(shí)現(xiàn)TimeServer，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

No1、什么是Netty

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

No2、JDK中的I/O的缺點(diǎn)

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

處理邏輯圖如下所示

這是一個(gè)最簡(jiǎn)單的Socket程序，服務(wù)端接收到request后立即創(chuàng)建一個(gè)線程來處理這個(gè)request?？雌饋頉]什么毛病，但是如果并發(fā)量稍稍大一點(diǎn)的話，server端創(chuàng)建線程、銷毀線程會(huì)特別消耗性能。有朋友一定會(huì)說，既然系統(tǒng)的瓶頸在線程的創(chuàng)建和銷毀上，用線程池不久可以了嗎？將系統(tǒng)創(chuàng)建的線程數(shù)控制在一定范圍內(nèi)，不會(huì)因?yàn)椴l(fā)量而耗盡系統(tǒng)線程。確實(shí)是這樣，但由于底層的通信依然采用同步阻塞模型，無法從根本上解決問題。

No3、為什么選擇Netty

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

• NIO庫(kù)和API復(fù)雜

• 代碼復(fù)雜

• 入門困難，需要大量JAVA知識(shí)儲(chǔ)備

• JDK NIO的Bug

• 。。。

選擇Netty的原因如下：

• API簡(jiǎn)單，開發(fā)門檻低

• 功能強(qiáng)大，預(yù)置了多種編碼解碼功能

• 性能高，成熟穩(wěn)定

• 社區(qū)活躍度高

• 修復(fù)了NIO中已發(fā)現(xiàn)的所有Bug

• 。。。

No4、Netty入門小Demo——TimeServer

好，下面我們就來寫一個(gè)最簡(jiǎn)單的基于Netty的網(wǎng)絡(luò)小程序，程序功能是client鏈接到server，server給client返回當(dāng)前的時(shí)間

Step1、工程搭建

創(chuàng)建一個(gè)maven工程，引入相關(guān)的依賴

Step2、編寫服務(wù)端——TimeServer

1. 創(chuàng)建兩個(gè)NioEventLoopGroup實(shí)例，NioEventLiipGroup是一個(gè)線程組，它包含了一組NIO線程。創(chuàng)建兩個(gè)的原因是一個(gè)用于服務(wù)端接收客戶端的連接，另一個(gè)用于Sockerchannel的讀寫。

2. 創(chuàng)建ServerBootstrap，它是Netty啟動(dòng)服務(wù)的啟動(dòng)類，將EventLoop Group傳入ServerBootstrap中，最后綁定I/O事件的處理類ChildChannelHandler。

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

4. 等待服務(wù)器端鏈路關(guān)閉后main方法結(jié)束

   
   

   
   

I/O事件處理類ChildChannelHandler.java的實(shí)現(xiàn)

1. 將msg轉(zhuǎn)化為ByteBuf對(duì)象，此對(duì)象相當(dāng)于byte[]，不過比byte[]封裝了更多操作。

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

3. 創(chuàng)建響應(yīng)，并寫給客戶端。

這就是server端的代碼，很簡(jiǎn)單吧

Step3、編寫客戶端——TimeClient

1. 創(chuàng)建EventLoopGroup實(shí)例

2. 創(chuàng)建Bootstrap實(shí)例，與TimeServer不同的是，此處Channel需要設(shè)置為NioSockerChannel

3. 調(diào)用connect發(fā)起異步連接，然后調(diào)用sync等待連接成功

4. 關(guān)閉連接，釋放資源

TimeClientHandler.java的實(shí)現(xiàn)

1. 當(dāng)client與server的TCP連接成功后，Netty的NIO線程調(diào)用channelActive方法，向服務(wù)器發(fā)送請(qǐng)求

2. 將byte[]數(shù)據(jù)封裝到ByteBuf中，并發(fā)送請(qǐng)求

3. 將響應(yīng)msg轉(zhuǎn)化為ByteBuf對(duì)象，寫入byte[]中

4. 打印響應(yīng)數(shù)據(jù)

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