Netty3:分隔符和定長解碼器

来源:https://www.cnblogs.com/xrq730/archive/2018/04/07/8733888.html
-Advertisement-
Play Games

回顧TCP粘包/拆包問題解決方案 上文詳細說了TCP粘包/拆包問題產生的原因及解決方式,並以LineBasedFrameDecoder為例演示了粘包/拆包問題的實際解決方案,本文再介紹兩種粘包/拆包問題的解決方案:分隔符和定長解碼器。在開始本文之前,先回顧一下解決粘包/拆包問題的幾個方式: 消息長度 ...


回顧TCP粘包/拆包問題解決方案

上文詳細說了TCP粘包/拆包問題產生的原因及解決方式,並以LineBasedFrameDecoder為例演示了粘包/拆包問題的實際解決方案,本文再介紹兩種粘包/拆包問題的解決方案:分隔符和定長解碼器。在開始本文之前,先回顧一下解決粘包/拆包問題的幾個方式:

  • 消息長度固定,累計讀取到長度總和為定長LEN的報文後,就認為讀取到了一個完整的消息,將計數器重置,重新讀取下一個消息
  • 將回車換行符作為消息結束符,例如FTP協議,這種方式在文本協議中應用比較廣泛
  • 將特殊的分隔符作為消息的結束標誌,回車換行符就是一種特殊的結束分隔符
  • 通過在消息頭中定義長度欄位來標誌消息的總長度

Netty對上面4種方式做了統一的抽象,提供了4種解碼器來解決對應的問題,使用起來非常方便,有了這些解碼器,用戶不需要自己對讀取的報文進行人工解碼,也不需要考慮TCP的粘包和拆包。

 

基於DelimiterBasedFrameDecoder的TCP粘包/拆包解決方案

使用DelimiterBasedFrameDecoder,我們可以自動完成以分隔符作為碼流結束標誌的消息的解碼,下麵通過例子來學習下DelimiterBasedFrameDecoder的使用。

首先寫一個EchoServer,和TimeServer差不多,主要是加上了DelimiterBasedFrameDecoder,分隔符定為"¥_":

 1 public class EchoServer {
 2 
 3     public void bind(int port) throws Exception {
 4         // NIO線程組
 5         EventLoopGroup bossGroup = new NioEventLoopGroup();
 6         EventLoopGroup workerGroup = new NioEventLoopGroup();
 7         
 8         try {
 9             ServerBootstrap b = new ServerBootstrap();
10             b.group(bossGroup, workerGroup)
11                 .channel(NioServerSocketChannel.class)
12                 .option(ChannelOption.SO_BACKLOG, 1024)
13                 .childHandler(new ChildChannelHandler());
14             
15             // 綁定埠,同步等待成功
16             ChannelFuture f = b.bind(port).sync();
17             // 等待服務端監聽埠關閉
18             f.channel().closeFuture().sync();
19         } finally {
20             // 優雅退出,釋放線程池資源
21             bossGroup.shutdownGracefully();
22             workerGroup.shutdownGracefully();
23         }
24     }
25     
26     private class ChildChannelHandler extends ChannelInitializer<SocketChannel> {
27         @Override
28         protected void initChannel(SocketChannel arg0) throws Exception {
29             ByteBuf delimiter = Unpooled.copiedBuffer("$_".getBytes());
30             
31             arg0.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, delimiter));
32             arg0.pipeline().addLast(new StringDecoder());
33             arg0.pipeline().addLast(new EchoServerHandler());
34         }
35     }
36     
37 }

接著是EchoServerHandler,將接收到的消息列印出來,並記錄收到的消息次數:

 1 public class EchoServerHandler extends ChannelHandlerAdapter {
 2 
 3     private int counter = 0;
 4     
 5     @Override
 6     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
 7         String body = (String)msg;
 8         System.out.println("This is " + ++counter + " times receive client:[" + body + "]");
 9         
10         body += "$_";
11         ByteBuf echo = Unpooled.copiedBuffer(body.getBytes());
12         ctx.writeAndFlush(echo);
13     }
14     
15     @Override
16     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
17         cause.printStackTrace();
18         ctx.close();
19     }
20     
21 }

收到消息之後,將消息加上"$_"回給客戶端。看下客戶端EchoClient的寫法,也是一樣,加上DelimiterBasedFrameDecoder:

 1 public class EchoClient {
 2 
 3     public void connect(int port, String host) throws Exception {
 4         EventLoopGroup group = new NioEventLoopGroup();
 5         try {
 6             Bootstrap b = new Bootstrap();
 7             
 8             b.group(group)
 9                 .channel(NioSocketChannel.class)
10                 .option(ChannelOption.TCP_NODELAY, true)
11                 .handler(new ChannelInitializer<SocketChannel>() {
12                     protected void initChannel(SocketChannel ch) throws Exception {
13                         ByteBuf delimiter = Unpooled.copiedBuffer("$_".getBytes());
14                         
15                         ch.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, delimiter));
16                         ch.pipeline().addLast(new StringDecoder());
17                         ch.pipeline().addLast(new EchoClientHandler());
18                     };
19                 });
20             
21             // 發起非同步連接操作
22             ChannelFuture f = b.connect(host, port).sync();
23             // 等待客戶端連接關閉
24             f.channel().closeFuture().sync();
25         } finally {
26             // 優雅退出,釋放NIO線程組
27             group.shutdownGracefully();
28         }
29     }
30     
31 }

寫一個EchoClientHandler,發送10條消息到Server並記錄從Server回來的數據:

 1 public class EchoClientHandler extends ChannelHandlerAdapter {
 2 
 3     private int counter;
 4     
 5     private static final String ECHO_REQ = "Hi, RickyXu, Welcome to Netty.$_";
 6     
 7     public EchoClientHandler() {
 8         
 9     }
10     
11     @Override
12     public void channelActive(ChannelHandlerContext ctx) throws Exception {
13         for (int i = 0; i < 10; i++) {
14             ctx.writeAndFlush(Unpooled.copiedBuffer(ECHO_REQ.getBytes()));
15         }
16     }
17     
18     @Override
19     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
20         System.out.println("This is" + ++counter + " times receive server:[" + msg + "]");
21     }
22     
23     @Override
24     public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
25         ctx.flush();
26     }
27     
28     @Override
29     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
30         cause.printStackTrace();
31         ctx.close();
32     }
33     
34 }

先運行服務端代碼再運行客戶端代碼,看下服務端收到的數據為:

This is 1 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 2 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 3 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 4 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 5 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 6 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 7 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 8 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 9 times receive client:[Hi, RickyXu, Welcome to Netty.]
This is 10 times receive client:[Hi, RickyXu, Welcome to Netty.]

一模一樣收到10條且末尾的分隔符被忽略,客戶端收到的響應為:

This is 1 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 2 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 3 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 4 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 5 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 6 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 7 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 8 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 9 times receive server:[Hi, RickyXu, Welcome to Netty.]
This is 10 times receive server:[Hi, RickyXu, Welcome to Netty.]

同樣收到了10條數據且忽略了末尾的換行符。

這樣我們就通過一個示例演示了使用DelimiterBasedFrameDecoder解決TCP粘包/拆包,下麵看一下使用FixedLengthFrameDecoder解決TCP粘包/拆包的示例。

 

基於FixedLengthFrameDecoder的TCP粘包/拆包解決方案

FixedLengthFrameDecoder是固定長度解碼器,它能夠按照指定的長度對消息進行自動解碼,開發者不需要考慮TCP的粘包/拆包問題,非常實用,

同樣看一下例子,先寫一個EchoServer,加入FixedLengthFrameDecoder:

public class EchoServer {

    public void bind(int port) throws Exception {
        // NIO線程組
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .option(ChannelOption.SO_BACKLOG, 1024)
                .childHandler(new ChildChannelHandler());
            
            // 綁定埠,同步等待成功
            ChannelFuture f = b.bind(port).sync();
            // 等待服務端監聽埠關閉
            f.channel().closeFuture().sync();
        } finally {
            // 優雅退出,釋放線程池資源
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
    
    private class ChildChannelHandler extends ChannelInitializer<SocketChannel> {
        @Override
        protected void initChannel(SocketChannel arg0) throws Exception {
            arg0.pipeline().addLast(new FixedLengthFrameDecoder(20));
            arg0.pipeline().addLast(new StringDecoder());
            arg0.pipeline().addLast(new EchoServerHandler());
        }
    }
    
}

接著下一下EchoServerHandler,EchoServerHandler比較簡單:

public class EchoServerHandler extends ChannelHandlerAdapter {

     @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("Receive client:[" + msg + "]");
    }
    
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
    }
    
}

這裡只列印接收到的數據,因為我們使用telnet來模擬發送請求而不是寫一個EchoClient。首先telnet一下localhost 8080:

接著使用"Ctrl+]":

輸入回車,這樣就變成了回顯模式,即輸入什麼看到什麼,簡單說一下telnet原理:

  1. 建立與伺服器的TCP連接
  2. 從鍵盤上接收輸入的字元
  3. 把輸入的字元變成標準格式併發送給伺服器
  4. 從伺服器接收輸出的信息
  5. 輸出的信息顯示在屏幕/控制臺上

註意一下第2點+第3點,這裡是鍵盤上輸入一個字元就會發送這個字元到服務端的,對這點有疑問的可以在FixedLengthFrameDecoder的decode方法上打斷點,就可以看到每輸入一個字元,斷點就會進入一次。

接著我們"0123456789"這樣一直迴圈輸入,FixedLengthFrameDecoder設置的Length是20,按照上面的解釋,這樣的話應該輸入兩輪"0123456789"即第二個9輸入之後,控制臺上就會列印了:

看一下控制台:

Receive client:[01234567890123456789]

沒毛病,證明瞭FixedLengthFrameDecoder確實是按照定長接收包的,如果收到的包是半包消息,FixedLengthFrameDecoder會緩存半包消息並等待下個包到達之後進行拼包,直到讀取到一個完整的包


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 上篇文章總結了《深入實踐Spring Boot》的第一部分,這篇文章介紹第二部分:分散式應用開發,以及怎麼構建一個高性能的服務平臺。 主要從以下幾個方面總結: Spring Boot SSO 使用分散式文件系統 雲應用開發 構建高性能的服務平臺 <!-- more --> Spring Boot S ...
  • 1、利用迴圈輸出:************************* 2、輸出九九乘法表 3、求 a+aa+aaa+...+aaaaaaaa=? 其中a為1到9之間的一個數,項數也可以指定 4、計算圓周率 PI = 4-4/3+4/5-4/7+... 列印出第一個大於3.1415小於3.1416的數 ...
  • 案例: 輸出結果: 以下只列舉 mimi 。 1.(當某1個 Cat 對象被 new 出來的時候,)數據區裡面有一個靜態變數 sid(new 不 new 都有一個 sid,它屬於整個類,不屬於單個對象,有沒有對象都可以訪問靜態變數)。 2.Cat.sid = 100;。 2.1. 首先主函數先進棧, ...
  • 關於字元的常用操作:(字元為不可變長度的類型,故不能“增”、“刪”等改變長度的操作) 1、改:改變字元串中的某個值。但為淺改變; 若想要改變“name”則可以用下邊的代碼: 2、string.isdigit() ,判斷string中是否全為數字類型的字元 3、查找指定的字元在字元中的索引 4、str ...
  • 前言 清明不小心就拖了兩天沒更了~~ 這是十道演算法題的第二篇了 ~上一篇回顧: "十道簡單演算法題" 最近在回顧以前使用C寫過的數據結構和演算法的東西,發現自己的演算法和數據結構是真的薄弱,現在用Java改寫一下,重溫一下。 只能說慢慢積累吧~下麵的題目難度都是簡單的,演算法的大佬可直接忽略這篇文章了~入門 ...
  • Java單例模式主要作用是保證在Java應用程式中,一個類Class只有一個實例存在。 使用單例模式的好處還在於可以節省記憶體,因為它限制了實例的個數,有利於Java垃圾回收(garbage collection)。 所有人都共用同一份數據。 單例模式能夠保證一個類僅有唯一的實例,並提供一個全局訪問點 ...
  • 聊到二進位以及位運算就不得不說說,原碼,反碼,補碼了,網上對於原碼反碼補碼的解釋過於複雜,我這裡把教程里的一些總結搬出來讓大家參考一下:對於有符號的而言; 1.二進位最高位是符號位,0表示正數,1表示負數; 2.正數的原碼反碼補碼都一樣; 3.負數的反碼等於它的原碼符號位不變,其他位取反,1變0,0 ...
  • 參考資料:網易雲網課李興華:http://study.163.com/course/courseMain.htm?courseId=1455026 一、字元串一旦定義不可改變 一開始也許並不太好理解,先觀察以下代碼 結果: 以上代碼似乎主觀上覺得String內容不是改變了嗎,但並不是這樣的,下麵通過 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...