成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

分隔符和定長解碼器的應(yīng)用

lemon / 1103人閱讀

摘要：以流的方式進行數(shù)據(jù)傳輸上層的應(yīng)用協(xié)議為了對消息進行區(qū)分往往采用如下中方式消息長度固定累計讀取到長度總和為定長的報文后就認為讀到了一個完整的消息將計數(shù)器置位重新開始讀取下一個數(shù)據(jù)報將回車換行符作為消息結(jié)束符例如協(xié)議這種方式在文本協(xié)議中應(yīng)用比較

TCP 以流的方式進行數(shù)據(jù)傳輸, 上層的應(yīng)用協(xié)議為了對消息進行區(qū)分, 往往采用如下 4 中方式.

消息長度固定, 累計讀取到長度總和為定長 LEN 的報文后, 就認為讀到了一個完整的消息; 將計數(shù)器置位, 重新開始讀取下一個數(shù)據(jù)報;

將回車換行符作為消息結(jié)束符, 例如 FTP 協(xié)議, 這種方式在文本協(xié)議中應(yīng)用比較廣泛.

將特殊的分隔符最為消息的結(jié)束標志, 回車換行符就是一種特殊的結(jié)束分隔符;

通過在消息頭中定義長度字段來標識消息的總長度.

Netty 對上面 4 種應(yīng)用做了統(tǒng)一的抽象, 提供了 4 種解碼器來解決對應(yīng)用的問題.

之前我寫了 LineBasedFrameDecoder 解碼器的使用, 今天開始學習如何使用 DelimiterBasedFrameDecoder 和 FixedLengthFrameDecoder.

DelimiterBasedFrameDecoder 應(yīng)用開發(fā)

通過對 DelimiterBasedFrameDecoder 的使用, 我們可以自動完成以分隔符作為碼流結(jié)束標識的消息的解碼.

還是修改 initChannel 方法

ByteBuf delimiter = Unpooled.copiedBuffer("$_".getBytes());
ch.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, delimiter));
ch.pipeline().addLast(new StringDecoder());
ch.pipeline().addLast(new TimeServerHandler());

我們使用 $_ 作為分隔符, 創(chuàng)建 DelimiterBasedFrameDecoder 對象, 將其加入到 ChannelPipeline 中. DelimiterBasedFrameDecoder 有多個構(gòu)造方法, 這里我們傳遞兩個參數(shù): 第一個 1024 表示單條消息的最大長度, 當達到該長度后仍然沒有檢查到分隔符, 將拋出 TooLongFrameException 異常, 防止由于異常碼流缺失分隔符導致的內(nèi)存溢出, 這是 Netty 解碼器的可靠性保護; 第二個參數(shù)就是分隔符緩沖對象.

由于我們設(shè)置 DelimiterBasedFrameDecoder 過濾掉了分隔符, 所以返回給客戶端時需要在請求消息尾部拼接分隔符 $_.
FixedLengthFrameDecoder 應(yīng)用開發(fā)

FixedLengthFrameDecoder 是固定長度解碼器, 它能夠按照指定的長度對消息進行自動解碼.

ch.pipeline().addLast(new FixedLengthFrameDecoder(10));
ch.pipeline().addLast(new StringDecoder());
ch.pipeline().addLast(new TimeServerHandler());

利用 FixedLengthFrameDecoder 解碼器, 無論一次接收到多少數(shù)據(jù)報, 他都會按照構(gòu)造函數(shù)中設(shè)置的固定長度進行解碼, 如果是半包消息, FixedLengthFrameDecoder 會緩存半包消息并等待下個包到達后進行拼包, 直到讀取到一個完整的包.

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/72767.html

相關(guān)文章

  • 基于定長消息的java nio半包粘包處理

    摘要：接收方只需要等待，直到讀到確定數(shù)量的字節(jié)，然后處理即可。而這個字節(jié)流的前個字節(jié)用于表示對象的長度，接下來的字節(jié)就是傳輸?shù)膶ο蟮淖止?jié)流，最后不夠最大長度的用任意字節(jié)進行填充即可。 什么是tcp半包粘包？簡單來講就是接收到的tcp包并不一定是一個完整的包。它可能是1個包的一部分，也可能是多個完整包加上1個包的一部分。為什么？因為tcp的定義是面向字節(jié)流的傳輸協(xié)議，所以操作系統(tǒng)實現(xiàn)這個協(xié)議的...

    Loong_T 評論0 收藏0

  • netty

    摘要：設(shè)置每個數(shù)據(jù)包的大小如個字節(jié)，如果某個數(shù)據(jù)包不足個字節(jié)可能會出現(xiàn)丟包的情況，即該數(shù)據(jù)包未從一個端到另一個端，此時需要用空格或者既定的符號補充在數(shù)據(jù)包之間使用一些字符進行分割如號之類的，解析的時候先處理掉分隔符再拿到各個數(shù)據(jù)包就好了。 netty 概念: Netty是由JBOSS提供的一個java開源框架。Netty提供異步的、事件驅(qū)動的網(wǎng)絡(luò)應(yīng)用程序框架和工具，用以快速開發(fā)高性能、高可靠...

    cfanr 評論0 收藏0

  • 編碼解碼UNICODE

    摘要：其他編碼的可以參考，，的選擇不考慮隨機訪問，，查找第個字符時間復雜度隨機訪問，只用之內(nèi)的字符，，時間復雜度隨機訪問，超過了，詳解編碼 1.字符集vs字符編碼，編碼&解碼 Character----->code point----->bytes 前兩者字符集的關(guān)系，可以統(tǒng)稱為codepoint；從codepoint到在計算機上的存儲形式，稱為編碼，反過來稱為解碼； 字符集：單個符號（ch...

    baukh789 評論0 收藏0

  • Netty(三) 什么是 TCP 拆、粘包？如何解決？

    摘要：是一個面向字節(jié)流的協(xié)議，它是性質(zhì)是流式的，所以它并沒有分段。可基于分隔符解決。編解碼的主要目的就是為了可以編碼成字節(jié)流用于在網(wǎng)絡(luò)中傳輸持久化存儲。 showImg(https://segmentfault.com/img/remote/1460000015895049); 前言 記得前段時間我們生產(chǎn)上的一個網(wǎng)關(guān)出現(xiàn)了故障。 這個網(wǎng)關(guān)邏輯非常簡單，就是接收客戶端的請求然后解析報文最后發(fā)送...

    YanceyOfficial 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<