目录
一、 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
关注打赏
最近更新
- 深拷贝和浅拷贝的区别(重点)
- 【Vue】走进Vue框架世界
- 【云服务器】项目部署—搭建网站—vue电商后台管理系统
- 【React介绍】 一文带你深入React
- 【React】React组件实例的三大属性之state,props,refs(你学废了吗)
- 【脚手架VueCLI】从零开始,创建一个VUE项目
- 【React】深入理解React组件生命周期----图文详解(含代码)
- 【React】DOM的Diffing算法是什么?以及DOM中key的作用----经典面试题
- 【React】1_使用React脚手架创建项目步骤--------详解(含项目结构说明)
- 【React】2_如何使用react脚手架写一个简单的页面?