粘包/半包及解决方案

一、粘包/半包介绍

1：粘包

粘包（Packet Concatenation）通常发生在基于流式传输协议（如 TCP）的通信中，因为 TCP 是面向流的传输协议，它不保证数据包的边界，而是将数据视为连续的字节流，它表示客户端发送多条消息，服务端只收到了一条消息

2：半包

半包（Half Packet）与粘包问题相反。在半包问题中，接收端接收到的数据包不完整，即接收到的数据包只是完整数据包的一部分，无法完整地解析和处理。

3：原因

①网络延迟/阻塞

②发送方连续发送数据

③接收端缓冲区大小限制

④数据包丢失

二、粘包/半包解决方案

1：长度信息法

在每个数据包前面加上长度信息，每次接收数据后，先读取长度，如果缓冲区数据长度大于要取的字节数，则取出相应字节，否则等待下一次接收,举个例子

①客户端第一次发送包含长度信息的内容

②客户端第二次发送包含长度信息的内容

③服务端第一次接收到了4个字节，存入缓冲区，但是这时候并不处理，因为收到了10，所以要等到11个字节完整再处理

④服务端等到客户端发送剩下的7个字节，但是第二次接收到了9个字节，服务端把之前的6个字节再读取，然后拼接，把10helloworld进行处理，读取到标志长度4，等待下次处理

⑤服务端最后一次收到ove，就把之前的l一起拼接，返回完整的4love

*一般的游戏是16位的整型数来存放长度信息

2：固定长度法

每次都发送相同长度的数据，一次不足的数据用.来补充，.位补充字符，没有实际意义

如果接收到的字符数大于10，就只提取前10个字符

3：结束符号法

规定一个结束符号作为消息的分隔符，比如Hello$World就是两条信息

三、代码示例

1：发送数据
        byte[] bodyBytes = System.Text.Encoding.Default.GetBytes(SendStr);Int16 len = (Int16)bodyBytes.Length;//把长度转化为Int16byte[] lenBytes = BitConverter.GetBytes(len);//此时SendBytes包含长度字符串和内容字符串byte[] sendBytes = lenBytes.Concat(bodyBytes).ToArray();

2：接收数据

定义一个接收缓冲区和接收缓冲区长度。缓冲区会保存尚未处理的数据

    //接收缓冲区byte[] readBuff = new byte[1024];//接收缓冲区长度int buffCount = 0;

之前的BeginReceive函数原型如下：

public IAsyncResult BeginReceive (  byte[] buffer,  int offset,  int size,  SocketFlags socketFlags,  AsyncCallback callback, object state )

现在的参数应该写成这个样子：

socket.BeginReceive(readBuff, buffCount 1024-buffCount, 0,  ReceiveCallback, socket);

readBuff 是缓冲区

buffCount 是开始读取的位置

1024 - buffCount 是剩余多少可读取的大小

3：处理数据

public void OnReceiveData(){//消息长度小于2，直接返回等待下一次接收if(buffCount <= 2)return;//消息的长度Int16 bodyLength = BitConverter.ToInt16(readBuff, 0);//消息体//如果消息长度小于我消息内容和长度的字节，就返回继续读取if(buffCount < 2+bodyLength)return;//如果长度够用，就转化为string类型string s = System.Text.Encoding.UTF8.GetString(readBuff, 2,buffCount);//更新缓冲区int start = 2 + bodyLength;int count = buffCount - start;//Copy函数把缓冲区后面的内容提到前面Array.Copy(readBuff, start, readBuff, 0, count);buffCount -= start;//继续读取消息if(readBuff.length > 2){OnReceiveData();}
}

Copy的原型函数如下：

public static void Copy(Array sourceArray,//源数组long sourceIndex,//目标数据Array destinationArray,//目标数组long destinationIndex,//目标数组起始位置long length//复制消息的长度
)

四、完整示例

1：客户端
using System;
using System.Linq;
using System.Net.Sockets;
using UnityEngine;
using UnityEngine.UI;public class SendScr : MonoBehaviour
{Socket socket;public InputField inputField;public Text text;byte[] readBuff = new byte[1024];int buffCount = 0;//缓冲区数据长度string recvStr = "";public void Connection(){socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);socket.Connect("127.0.0.1", 8888);socket.BeginReceive(readBuff, buffCount, 1024 - buffCount, 0, ReceiveCallback, socket);}private void ReceiveCallback(IAsyncResult ar){try{Socket socket = (Socket)ar.AsyncState;//获取接收数据长度int count = socket.EndReceive(ar);buffCount += count;//处理二进制消息OnReceiveData();//继续接收数据socket.BeginReceive(readBuff, buffCount, 1024 - buffCount, 0, ReceiveCallback, socket);}catch (SocketException ex){Debug.Log("Socket Receive fail" + ex.ToString());}}private void OnReceiveData(){Debug.Log("[Recv 1] buffCount = " + buffCount);Debug.Log("[Recv 2] readbuff = " + BitConverter.ToString(readBuff));if (buffCount <= 2) return;Int16 bodyLength = BitConverter.ToInt16(readBuff, 0);Debug.Log("[Recv 3] bodyLength=" + bodyLength);//消息体if (buffCount < 2 + bodyLength) return;string s = System.Text.Encoding.UTF8.GetString(readBuff, 2, buffCount);Debug.Log("[Recv 4] s=" + s);//更新缓冲区int start = 2 + bodyLength;int count = buffCount - start;Array.Copy(readBuff, start, readBuff, 0, count);buffCount -= start;Debug.Log("[Recv 5] buffCount=" + buffCount);//消息处理recvStr = s + "\n" + recvStr;//继续读取消息OnReceiveData();}public void Send(){string sendStr = inputField.text;byte[] bodyBytes = System.Text.Encoding.Default.GetBytes(sendStr);Int16 len = (Int16)bodyBytes.Length;byte[] lenBytes = BitConverter.GetBytes(len);//此时SendBytes包含长度字符串和内容字符串byte[] sendBytes = lenBytes.Concat(bodyBytes).ToArray();socket.Send(sendBytes);Debug.Log("[Send]" + BitConverter.ToString(sendBytes));}private void Update(){text.text = recvStr;}}

捋一下客户端的功能：

当进入场景点击Connection，创建新的Socket连接，绑定服务端口，开始接收信息

这里的BeginReceive就是我们接受消息的函数，它传入我们的缓冲区readBuff，缓冲区长度buffCount，1024 - buffCount表示我们还剩多少字节数据，然后进入回调函数

Receive回调函数中创建新的Socket对象来解析获取到的socket对象，count用于跟踪每次异步接收操作实际接收到的数据长度，然后把count加到buffCount上，这样更新了缓冲区的长度

然后使用OnReceiveData处理数据，继续读取数据，点击发送就调用Send()

2：服务端
using System.Net.Sockets;
using System.Net;
internal class ClientState
{public Socket socket;public byte[] readBuff = new byte[1024];
}
class Class
{static Socket listenfd;static Dictionary<Socket, ClientState> clients = new Dictionary<Socket, ClientState>();public static void Main(string[] args){listenfd = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);IPAddress ipAdr = IPAddress.Parse("127.0.0.1");IPEndPoint ipEp = new IPEndPoint(ipAdr, 8888);listenfd.Bind(ipEp);listenfd.Listen(0);Console.WriteLine("[服务器]启动成功");List<Socket> checkRead = new List<Socket>();while (true){//填充checkRead列表checkRead.Clear();checkRead.Add(listenfd);foreach (ClientState s in clients.Values){checkRead.Add(s.socket);}//selectSocket.Select(checkRead, null, null, 1000);//检查可读对象foreach (Socket s in checkRead){if (s == listenfd){ReadListenfd(s);}else{ReadClientfd(s);}}}}public static void ReadListenfd(Socket listenfd){Console.WriteLine("Accept");Socket clientfd = listenfd.Accept();ClientState state = new ClientState();state.socket = clientfd;clients.Add(clientfd, state);}public static bool ReadClientfd(Socket clientfd){ClientState state = clients[clientfd];//接收int count = clientfd.Receive(state.readBuff);if (count == 0){clientfd.Close();clients.Remove(clientfd);Console.WriteLine("Socket Close");return false;}//广播string recvStr = System.Text.Encoding.Default.GetString(state.readBuff, 2, count - 2);Console.WriteLine("Receive" + recvStr);byte[] sendBytes = new byte[count];Array.Copy(state.readBuff, 0, sendBytes, 0, count);foreach (ClientState cs in clients.Values){cs.socket.Send(sendBytes);}return true;}
}

这里的服务端代码和Select部分的代码基本相同

3：测试

打开服务器，客户端连接后输入UNITY

①客户端反馈

Recv1的buffCount就是接收到服务端所返回的消息，服务端所返回的信息是客户端发送的拼接数组，就是UNITY+lenBytes，就是7

Rec2的readbuff就是缓冲区存储的内容

Recv3是当消息没有接受完整的时候的消息本体长度

Recv4是完整的消息内容

Recv5是接受完成UNITY后更新后的新buffCount新长度，因为没有后续的，所以是0

②服务端反馈

服务端接受到的消息

四、模拟粘包

客户端修改

using System;
using System.Linq;
using System.Net.Sockets;
using UnityEngine;
using UnityEngine.UI;public class SendScr : MonoBehaviour
{Socket socket;public InputField inputField;public Text text;byte[] readBuff = new byte[1024];int buffCount = 0;//缓冲区数据长度string recvStr = "";public void Connection(){socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);socket.Connect("127.0.0.1", 8888);socket.BeginReceive(readBuff, buffCount, 1024 - buffCount, 0, ReceiveCallback, socket);}private void ReceiveCallback(IAsyncResult ar){try{Socket socket = (Socket)ar.AsyncState;//获取接收数据长度int count = socket.EndReceive(ar);buffCount += count;//处理二进制消息OnReceiveData();System.Threading.Thread.Sleep(1000*30);//继续接收数据socket.BeginReceive(readBuff, buffCount, 1024 - buffCount, 0, ReceiveCallback, socket);}catch (SocketException ex){Debug.Log("Socket Receive fail" + ex.ToString());}}private void OnReceiveData(){Debug.Log("[Recv 1] buffCount = " + buffCount);Debug.Log("[Recv 2] readbuff = " + BitConverter.ToString(readBuff));if (buffCount <= 2) return;Int16 bodyLength = BitConverter.ToInt16(readBuff, 0);Debug.Log("[Recv 3] bodyLength=" + bodyLength);//消息体if (buffCount < 2 + bodyLength) return;string s = System.Text.Encoding.UTF8.GetString(readBuff, 2, buffCount);Debug.Log("[Recv 4] s=" + s);//更新缓冲区int start = 2 + bodyLength;int count = buffCount - start;Array.Copy(readBuff, start, readBuff, 0, count);buffCount -= start;Debug.Log("[Recv 5] buffCount=" + buffCount);//消息处理recvStr = s + "\n" + recvStr;//继续读取消息OnReceiveData();}public void Send(){string sendStr = inputField.text;byte[] bodyBytes = System.Text.Encoding.Default.GetBytes(sendStr);Int16 len = (Int16)bodyBytes.Length;byte[] lenBytes = BitConverter.GetBytes(len);//此时SendBytes包含长度字符串和内容字符串byte[] sendBytes = lenBytes.Concat(bodyBytes).ToArray();socket.Send(sendBytes);Debug.Log("[Send]" + BitConverter.ToString(sendBytes));}private void Update(){text.text = recvStr;}}

*在接收数据的时候，强制等待30s再进行下一次接收，ReceiveCallback是在子线程执行，调用Sleep函数并不会卡住主线程，客户端不会被卡住，在30s内多次发送数据，经由服务端转发，再次调用BeginReceive的时候，缓冲区有很多数据，会产生粘包。

客户端快速发送三条消息，发送不会堵塞，每次接收都会等待30s，但是接收到的消息不是在一起的，而是分开的

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/770452.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

密码学及其应用1 —— 密码学概述

密码学及其应用1 —— 密码学概述

1 密码学的基本概念 1.1 网络安全的定义 网络安全是网络领域的一个专业领域&#xff0c;它涵盖了在基础计算机网络基础设施中所采取的措施、网络管理员为保护网络及网络可访问资源免受未授权访问而采纳的政策&#xff0c;以及对其有效性&#xff08;或无效性&#xff09;的持续…
阅读更多...
2024年2月线上助听器综合电商（京东天猫淘宝）热销排行榜

2024年2月线上助听器综合电商（京东天猫淘宝）热销排行榜

鲸参谋监测的综合电商平台&#xff08;京东天猫淘宝&#xff09;2月份助听器品牌销量销额排行榜已揭晓&#xff01; 根据鲸参谋电商大数据显示&#xff0c;2月助听器在综合电商平台销量约为19万&#xff0c;环比上个月下滑了2%&#xff0c;同比去年下滑了25%&#xff1b;销售额…
阅读更多...
基于nodejs+vue发艺美发店管理系统python-flask-django-php

基于nodejs+vue发艺美发店管理系统python-flask-django-php

系统根据现有的管理模块进行开发和扩展&#xff0c;采用面向对象的开发的思想和结构化的开发方法对发艺美发店管理的现状进行系统调查。采用结构化的分析设计&#xff0c;该方法要求结合一定的图表&#xff0c;在模块化的基础上进行系统的开发工作。在设计中采用“自下而上”的…
阅读更多...
javaSwing愤怒的小鸟游戏

javaSwing愤怒的小鸟游戏

一、简介 游戏名称是“愤怒的小鸟”&#xff0c;英文称为“AngryBird”。 “愤怒的小鸟”是著名游戏公司Rovio偶然间开发出来的益智游戏&#xff0c;从2009年12月上市到iOS。&#xff0c;讲述了鸟类和猪因为猪偷鸟蛋反生的一系列故事。游戏的类型版本是横向版本的水平视角&…
阅读更多...
6、运行时数据区

6、运行时数据区

Java虚拟机在运行Java程序过程中管理的内存区域&#xff0c;称之为运行时数据区。《Java虚拟机规范》中规定了每一部分的作用。 3.1 程序计数器 程序计数器&#xff08;Program Counter Register&#xff09;也叫PC寄存器&#xff0c;每个线程会通过程序计数器记录当前要执行的…
阅读更多...
opencv各个模块介绍（1）

opencv各个模块介绍（1）

Core 模块&#xff1a;核心模块&#xff0c;提供了基本的数据结构和功能。 常用的核心函数&#xff1a; cv::Mat&#xff1a;表示多维数组的数据结构&#xff0c;是OpenCV中最常用的类之一&#xff0c;用于存储图像数据和进行矩阵运算。 cv::Scalar&#xff1a;用于表示多通道…
阅读更多...
网络分层协议和应用模型

网络分层协议和应用模型

分层模型 五层网络模型 MAC地址跟IP地址的区别&#xff1a;MAC地址是唯一的&#xff0c;相当于每个人的指纹&#xff0c;出生时就是唯一的&#xff1b;IP地址就相当于是你当前的住址&#xff0c;是会发生变化的&#xff0c;但是是动态唯一的。 应用层协议 URL URL&#xff…
阅读更多...
基于Colab训练的yolov4-tiny自定义数据集（可用于OpenCV For Unity）

基于Colab训练的yolov4-tiny自定义数据集（可用于OpenCV For Unity）

参考资料文档和视频。 1.打开文档，点击【文件】【在云端硬盘中保存一份副本】，即将文档复制到自己云端硬盘。 2.打开该文件，按文中提示进行。 【代码执行程序】【更改运行时类型】修改运行时为GPU（免费的GPU不好用，收费的好用，某宝上几十元就可用一个月） 步骤1） !git…
阅读更多...
如何调用occtproxy放入自己的wpf文件

如何调用occtproxy放入自己的wpf文件

1.创建一个wpf程序 2.添加项目occtproxy.vcxproj 3.把该项目配置类型设为dll 4.添加引用 5.报错显示&#xff0c;这是因为还没有生成dll 6.把occtproxy设为启动项目运行&#xff0c;设定输出目录在该目录下&#xff0c;生成dll 7.再运行&#xff0c;即可
阅读更多...
一文整合工厂模式、模板模式、策略模式

一文整合工厂模式、模板模式、策略模式

为什么使用设计模式 今天终于有时间系统的整理一下这几个设计模式了&#xff0c; 这几个真是最常用的&#xff0c;用好了它们&#xff0c;你就在也不用一大堆的if else 了。能更好的处理大量的代码冗余问题。 在我们的实际开发中&#xff0c;肯定会有这样的场景&#xff1a;我…
阅读更多...
2024年云仓酒庄新动态：铸就新篇章

2024年云仓酒庄新动态：铸就新篇章

原标题&#xff1a;刘总出席成都糖酒会&#xff1a;信任铸就云仓酒庄新篇章&#xff0c;共襄盛举展未来近日&#xff0c;备受瞩目的成都糖酒会盛大开幕&#xff0c;吸引了来自全国各地的业界精英和代表。在这场盛大的行业盛会上&#xff0c;云仓酒庄的刘总亲临现场。 现场&…
阅读更多...
以XX大学校园为例的智慧能源管理系统建设方案【能源物联网+智能微电网数字校园、节能校园、低碳校园】

以XX大学校园为例的智慧能源管理系统建设方案【能源物联网+智能微电网数字校园、节能校园、低碳校园】

建设背景 贯彻落实《中共中央 国务院关于完整准确全面贯彻新发展理念做好碳达峰碳中和工作的意见》和《国务院关于印发2030年前碳达峰行动方案的通知》要求&#xff0c;把绿色低碳发展纳入国民教育体系。 2021年3月26日为推动信息技术与教育教学深度融合&#xff0c;教育部印…
阅读更多...
2.6 IDE（集成开发环境）是什么

2.6 IDE（集成开发环境）是什么

IDE&#xff08;集成开发环境&#xff09;是什么 IDE 是 Integrated Development Environment 的缩写&#xff0c;中文称为集成开发环境&#xff0c;用来表示辅助程序员开发的应用软件&#xff0c;是它们的一个总称。 通过前面章节的学习我们知道&#xff0c;运行 C 语言&…
阅读更多...
eclipse导入svn项目

eclipse导入svn项目

1、配置maven 2、用svn引入项目 3一直点击next,到最后选完成。
阅读更多...
基于springboot的房屋租赁管理系统+数据库+免费远程调试

基于springboot的房屋租赁管理系统+数据库+免费远程调试

项目介绍: 基于springboot的房屋租赁管理系统。Javaee项目&#xff0c;springboot项目&#xff0c;采用M&#xff08;model&#xff09;V&#xff08;view&#xff09;C&#xff08;controller&#xff09;三层体系结构&#xff0c;通过Spring SpringBoot JspMaven来实现。MyS…
阅读更多...
Qt_day4:2024/3/25

Qt_day4:2024/3/25

作业1&#xff1a; 完善对话框&#xff0c;点击登录对话框&#xff0c;如果账号和密码匹配&#xff0c;则弹出信息对话框&#xff0c;给出提示”登录成功“&#xff0c;提供一个Ok按钮&#xff0c;用户点击Ok后&#xff0c;关闭登录界面&#xff0c;跳转到其他界面 如果账号和…
阅读更多...
【iOS ARKit】播放3D音频

【iOS ARKit】播放3D音频

3D音频 在前面系列中&#xff0c;我们了解如何定位追踪用户&#xff08;实际是定位用户的移动设备&#xff09;的位置与方向&#xff0c;然后通过摄像机的投影矩阵将虚拟物体投影到用户移动设备屏幕。如果用户移动了&#xff0c;则通过VIO 和 IMU更新用户的位置与方向信息&…
阅读更多...
钡铼技术R40路由器助力构建无人值守的智能化污水处理厂

钡铼技术R40路由器助力构建无人值守的智能化污水处理厂

钡铼技术R40路由器作为智能化污水处理厂的关键网络设备&#xff0c;发挥着至关重要的作用&#xff0c;助力构建无人值守的智能化污水处理系统。在现代社会&#xff0c;污水处理是城市环境保护和可持续发展的重要组成部分&#xff0c;而智能化污水处理厂借助先进的技术和设备&am…
阅读更多...
后端常问面经之Java基础

后端常问面经之Java基础

基本数据类型 Java中有8种基本数据类型&#xff1a; 6种数字类型&#xff1a; 4种整数型&#xff1a;byte、short、int、long 2种浮点型&#xff1a;float、double 1种字符类型&#xff1a;char 1种布尔类型&#xff1a;boolean 数据类型的默认值以及所占空间如下&#x…
阅读更多...
由浅到深认识Java语言（25）：正则表达式

由浅到深认识Java语言（25）：正则表达式

该文章Github地址&#xff1a;https://github.com/AntonyCheng/java-notes 在此介绍一下作者开源的SpringBoot项目初始化模板&#xff08;Github仓库地址&#xff1a;https://github.com/AntonyCheng/spring-boot-init-template & CSDN文章地址&#xff1a;https://blog.c…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023