目录
一、 ByteBuffer消息粘包、消息半包的概述
- 一、 ByteBuffer消息粘包、消息半包的概述
- 二、示例需求
- 三、示例代码
- NIO是面向缓冲区进行通信的,不是面向流的。既然是缓冲区,那它一定存在一个固定大小。这样一来通常会遇到两个问题:
- 消息粘包:当缓冲区足够大,由于网络不稳定种种原因,可能会有多条消息从通道读入缓冲区,此时如果无法分清数据包之间的界限,就会导致粘包问题;
- 消息半包:若消息没有接收完,缓冲区就被填满了,会导致从缓冲区取出的消息不完整,即半包的现象。
网络上有多条数据发送给服务端,数据之间使用 \n 进行分隔,但由于某种原因这些数据在接收时,被进行了重新组合,例如原始数据有3条:
- Hello,world\n
- I’m zhangsan\n
- How are you?\n
变成了下面的两个 byteBuffer (黏包,半包)
- Hello,world\nI’m zhangsan\nHo
- w are you?\n
现在要求你编写程序,将错乱的数据恢复成原始的按 \n 分隔的数据
三、示例代码-
需求代码
package com.example.nettytest.nio.day1; import java.nio.ByteBuffer; import static com.example.nettytest.nio.day1.ByteBufferUtil.debugAll; /** * @description: * @author: xz * @create: 2022-07-26 21:10 */ public class TestByteBufferExam { public static void main(String[] args) { //分配一个新的字节缓冲区,容量为50 ByteBuffer sourceByteBuffer = ByteBuffer.allocate(50); //写入数据 sourceByteBuffer.put("Hello,world\nI'm zhangsan\nHo".getBytes()); split(sourceByteBuffer); //再次写入数据 sourceByteBuffer.put("w are you?\n".getBytes()); split(sourceByteBuffer); } /** * 将错乱的数据恢复成原始的按 \n 分隔的数据方法 * */ public static void split(ByteBuffer sourceByteBuffer){ //flip 切换到读模式 sourceByteBuffer.flip(); for(int i = 0; i > 4]; private static final String[] BYTE2HEX = new String[256]; private static final String[] BYTEPADDING = new String[16]; static { final char[] DIGITS = "0123456789abcdef".toCharArray(); for (int i = 0; i 4 & 0x0F]; HEXDUMP_TABLE[(i
关注打赏
热门博文
- Netty——网络编程 NIO(Selector处理accept事件)代码示例
- CompletableFuture异步编排(多任务组合)
- CompletableFuture异步编排(线程串行化代码示例)
- CompletableFuture异步编排(handle最终处理)
- CompletableFuture异步编排(计算完成回调代码示例)
- hutool工具导出excel代码示例
- java 获取音频、视频文件时长代码示例
- PostMan发送请求参数带有路径特殊字符会返回400错误(与URL字符及URL编码值有关)
- Rabbitmq与Erlang安装包下载图解
- idea2021.1版本SpringBoot项目日志的说明及使用