成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

拼多多面試:Netty如何解決粘包問題?

開發 架構
粘包問題是指在網絡通信中,發送方連續發送的多個小數據包被接收方一次性接收的現象。這可能是因為底層傳輸層協議(如 TCP)會將多個小數據包合并成一個大的數據塊進行傳輸,導致接收方在接收數據時一次性接收了多個數據包,造成粘連。

粘包和拆包問題也叫做粘包和半包問題,它是指在數據傳輸時,接收方未能正常讀取到一條完整數據的情況(只讀取了部分數據,或多讀取到了另一條數據的情況)就叫做粘包或拆包問題。

從嚴格意義上來說,粘包問題和拆包問題屬于兩個不同的問題,接下來我們分別來看。

1.粘包問題

粘包問題是指在網絡通信中,發送方連續發送的多個小數據包被接收方一次性接收的現象。這可能是因為底層傳輸層協議(如 TCP)會將多個小數據包合并成一個大的數據塊進行傳輸,導致接收方在接收數據時一次性接收了多個數據包,造成粘連。

例如以下案例,正常情況下客戶端發送了兩條消息,分別為“ABC”和“DEF”,那么接收端也應該收到兩條消息“ABC”和“DEF”才對,但是接收端卻收到了“ABCD”這樣的消息,這種情況就叫做粘包,如下圖所示:

2.拆包/半包問題

拆包問題是指發送方發送的一個大數據包被接收方拆分成多個小數據包進行接收的現象。這可能是因為底層傳輸層協議(如 TCP)將一個大數據包拆分成多個小的數據塊進行傳輸,導致接收方在接收數據時分別接收了多個小數據包,造成拆開。

例如以下案例,客戶端發送了一條消息“ABC”,而接收端卻收到了“AB”和“C”兩條信息,這種情況就叫做半包,如下圖所示:

PS:大部分情況下我們都把粘包問題和拆包問題看成同一個問題,所以下文就用粘包問題來替代粘包和拆包問題。

3.為什么會有粘包問題?

粘包問題通常發生在 TCP/IP 協議中,因為 TCP 是面向連接的傳輸協議,它是以“流”的形式傳輸數據的,而“流”數據是沒有明確的開始和結尾邊界的,所以就會出現粘包問題。

4.常見解決方案

粘包問題的常見解決方案有以下 3 種:

  • 固定大小方法:發送方和接收方固定發送數據大小,當字符長度不夠時用空字符彌補,有了固定大小之后就知道每條消息的具體邊界了,這樣就沒有粘包的問題了。
  • 自定義數據協議(定義數據長度):在 TCP 協議的基礎上封裝一層自定義數據協議,在自定義數據協議中,包含數據頭(存儲數據的大小)和 數據的具體內容,這樣服務端得到數據之后,通過解析數據頭就可以知道數據的具體長度了,也就沒有粘包的問題了。
  • 特殊分割符:以特殊的字符結尾,比如以“\n”結尾,這樣我們就知道數據的具體邊界了,從而避免了粘包問題。

以上三種方案中,第一種固定大小的方法可能會造成網絡流量的浪費,以及傳輸性能慢的問題;第二種解決方案實現難度大,且不利于維護,所以比較推薦的是第三種方案,使用特殊分隔符來區分消息的邊界,從而避免粘包問題。

5.Netty解決方案

Netty 解決方案也延續了上面的常見解決方案,它的解決方案有以下幾個:

  • 使用定長解碼器(FixedLengthFrameDecoder):每個數據包都擁有固定的長度,接收端根據固定長度對數據進行切分,從而解決了粘包問題。
  • 使用行分隔符解碼器(LineBasedFrameDecoder):以行為單位進行數據包的解碼,從而解決粘包問題。
  • 使用分隔符解碼器(DelimiterBasedFrameDecoder):使用特定的分隔符來標識消息邊界,這樣接收端可以根據分隔符正確切分消息。
  • 使用長度字段解碼器(LengthFieldBasedFrameDecoder):在消息頭部加入表示消息長度的字段,接收端根據長度字段來確定消息的邊界,而從解決粘包問題。

PS:在 Netty 中,解碼器(Decoder)起著非常重要的作用。解碼器主要負責將從網絡中接收到的原始字節流數據轉換為應用程序能夠理解的 Java 對象或消息格式。使用解碼器可以解決粘包和拆包問題、協議轉換問題、消息編碼(如文本轉換為字節流)等問題。

這些解碼器的使用如下。

(1)定長解碼器

定長解碼器(FixedLengthFrameDecoder)使用示例如下:

ChannelPipeline pipeline = ch.pipeline();
// 假設每條消息長度為 5
pipeline.addLast(new FixedLengthFrameDecoder(5)); 
pipeline.addLast(new StringDecoder());
pipeline.addLast(new YourBusinessLogicHandler());

(2)行分隔符解碼器

行分隔符解碼器(LineBasedFrameDecoder)使用示例如下:

ChannelPipeline pipeline = ch.pipeline();
// 設置行分隔符解碼器最大(幀)長度為 8192 字節
pipeline.addLast(new LineBasedFrameDecoder(8192)); 
pipeline.addLast(new StringDecoder()); // 添加字符串解碼器
pipeline.addLast(new SimpleChannelInboundHandler<String>() {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
        System.out.println("接收到消息:" + msg);
    }
});

(3)分隔符解碼器

分隔符解碼器(DelimiterBasedFrameDecoder)使用示例如下:

ChannelPipeline pipeline = ch.pipeline();
// 使用 \r\n 來進行分隔
ByteBuf delimiter = Unpooled.copiedBuffer("\r\n".getBytes());
pipeline.addLast(new DelimiterBasedFrameDecoder(1024, delimiter));
pipeline.addLast(new StringDecoder());
pipeline.addLast(new YourBusinessLogicHandler());

(4)長度字段解碼器

長度字段解碼器(LengthFieldBasedFrameDecoder)使用示例如下:

ChannelPipeline pipeline = ch.pipeline();
// 設置最大幀長度為 1024 字節,長度字段位于第 0 個字節,長度字段占用 4 個字節
pipeline.addLast(new LengthFieldBasedFrameDecoder(1024, 0, 4, 0, 4));
pipeline.addLast(new LengthFieldPrepender(4));
pipeline.addLast(new StringDecoder());
pipeline.addLast(new StringEncoder());
pipeline.addLast(new LengthFieldServerHandler());
責任編輯:姜華 來源: Java中文社群
相關推薦

2024-08-16 21:47:18

2021-07-15 10:35:16

NettyTCPJava

2019-08-05 10:03:49

技術面試互聯網

2020-01-06 15:23:41

NettyTCP粘包

2019-12-06 15:20:58

Redis獨立用戶數據庫

2021-01-13 10:18:29

SocketNetty粘包

2019-10-25 00:32:12

TCP粘包Netty

2024-04-23 08:46:45

消息積壓KafkaMQ

2012-09-05 11:09:15

SELinux操作系統

2022-09-07 07:05:25

跨域問題安全架構

2022-08-01 07:07:15

粘包半包封裝

2019-08-15 07:43:38

TCP網絡協議丟包

2025-04-10 10:15:30

2023-02-15 07:03:41

跨域問題面試安全

2010-04-29 17:46:31

Oracle死鎖

2023-11-29 20:03:03

2011-08-29 10:34:00

網絡安全云安全云計算

2021-06-06 13:05:15

前端跨域CORS

2011-03-23 14:42:47

CPU過度消耗

2010-07-16 13:52:26

telnet漏洞
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 黄色成人在线网站 | 天天操夜夜拍 | 久久久123| 精品亚洲一区二区 | 一级黄色裸片 | 婷婷午夜天| a久久久久久 | 国产欧美一区二区三区在线看 | 日韩精品成人在线 | 久久久久久精 | 曰韩一二三区 | 中文字幕日韩欧美一区二区三区 | 成人在线视频网址 | 欧美一区二区在线 | 欧美日韩精品中文字幕 | 在线视频第一页 | 亚洲毛片在线观看 | 精品一区二区久久久久久久网站 | 色综合欧美| 亚洲国产欧美精品 | 亚洲一区中文字幕 | 日韩av一区二区在线观看 | 少妇一区在线观看 | 看片一区| 亚洲一区二区在线 | 亚洲一区中文字幕在线观看 | 粉嫩一区二区三区国产精品 | 男人天堂午夜 | 久久亚洲综合 | 午夜小电影 | 成人免费在线视频 | 欧美日韩一区二区三区视频 | 91精品国产综合久久久久久丝袜 | 亚洲国产精品99久久久久久久久 | 三级黄色大片网站 | 一级网站 | 九九热国产精品视频 | 欧美成人精品二区三区99精品 | 国产视频精品在线观看 | 国产精品夜夜春夜夜爽久久电影 | 精品久久一区二区三区 |