100元话费+500莫元咨询TCP 黏包服务器怎么处理的问题-第13页回答

STT

1楼-- · 2020-01-11 06:53

我们做的是7e开始 7ej结束遇到7e转义 7e==>7d 5e 7d==>7d 5d 两个7e间就是数据

lindabell

2楼-- · 2020-01-11 12:23

STT 发表于 2017-1-13 16:34
我们做的是7e开始 7ej结束遇到7e转义 7e==>7d 5e 7d==>7d 5d 两个7e间就是数据 ...

这种协议我也写过，汽车行业里的一个国标协议。
服务器人能力不行，这个他肯定也搞不出来；最好搞个json给他就满意了。

lindabell

3楼-- · 2020-01-11 12:23

styleno1 发表于 2017-1-13 16:18
Modbus over TCP文档是这样指导的：

印象中modbus是靠时间间隔来区分帧的，所以会这样写。

kevin_ares

4楼-- · 2020-01-11 12:56

55AA+MAC+len+CRC8
随便写个函数截断就行了
其实不你只是要解决粘包,还要解决一个数据包分两次收到

落叶知秋

5楼-- · 2020-01-11 15:07

精彩回答 2 元偷偷看……

huchunlei

6楼-- · 2020-01-11 17:43

本帖最后由 huchunlei 于 2017-1-13 21:39 编辑

楼主最近做的事跟我做的类似，我也是做单片机的，但是服务器没人写，我只有自己写了。我用的是 UDP，设备端用的是透传的 GPRS DTU，设备传过来的数据会发生，一包分成2包，或者多包和并在一起。所以，我这个数据处理也有你这个问题。不过花了几天时间，问题基本上解决了。
大体思路如下：

1、接收的数据进行初步的判断，同一个IP地址发过来的数据进行连接。
2、将连接后的数据进行识别，也就是最笨的办法，从前往后遍历，遇到包头，就按照协议规则去计算验证码，验证码正确，就把这部分数据提取出来。然后前面多出来的数据是无效数据，而后面多出来的数据要留着，需要跟新接收过来的数据包进行连接。
3、对提取出来的数据进行处理。

我的C# 代码如下，供你参考：（声明一下，我是做单片机的，上位机我非专业人事，所以代码风格很烂，仅供参考）

1、数据处理代码：（处理代码是单独一个线程运行的，所以里面是个大的死循环）

private void ServiceProcess()
{
byte[] PendingDataBuffer = null; //待处理流数据缓存
IPEndPoint PendingRemote = null; //待处理流数据的来源地址
while (true)
{
//读取并缓存原始数据
List<UdpReceiveDataStruct> ReceiveOrgList = ServiceUdpClient.GetReceiveData();
while (ReceiveOrgList.Count > 0)
{
UdpReceiveDataStruct ReceiveOrg = ReceiveOrgList[0];
lock (UdpReceiveOrgListLocker)
{
UdpReceiveOrgList.Add(ReceiveOrg);
ReceiveOrgList.RemoveAt(0);
}
}
//由于原始数据可能存在错误的分包、组包，需要对数据进行识别并缓存有效数据
while (UdpReceiveOrgList.Count > 0)
{
UdpReceiveDataStruct ReceiveOrg;
//通信总数+1
lock (CommunicatorStateLocker)
{
CommunicatorState.CommunicationTotalCount++;
}
//取出一条原始数据
lock (UdpReceiveOrgListLocker)
{
ReceiveOrg = UdpReceiveOrgList[0];
UdpReceiveOrgList.RemoveAt(0);
}
//初步判断数据是否有效，并合并
if (PendingDataBuffer == null) //待处理流数据为空
{
PendingDataBuffer = (byte[])ReceiveOrg.DataContent.Clone();
PendingRemote = ReceiveOrg.Remote;
}
else
{
if (PendingRemote.Address == ReceiveOrg.Remote.Address) //判断数据来源是否相同，如果相同，连接数据
{
byte[] newBuffer = (byte[])PendingDataBuffer.Clone();
PendingDataBuffer = newBuffer.Concat(ReceiveOrg.DataContent).ToArray();
PendingRemote = ReceiveOrg.Remote; //为防止来源地址其他属性发生变化，进行更新
}
else //如果不同，丢弃原来的数据，并把丢弃的数据通过Log输出
{
//输出Log
string str = "【" + ProjectSetting.ProjectCode + "】" + "NWGY接收数据出现无效数据段：" + PendingRemote.Address.ToString() + ":" + PendingRemote.Port.ToString() + "，";
foreach (byte d in PendingDataBuffer)
{
str += d.ToString("X2") + " ";
}
Log.WriteLine(str);
//通信错误数+1
lock (CommunicatorStateLocker)
{
CommunicatorState.CommunicationErrorCount++;
}
PendingDataBuffer = (byte[])ReceiveOrg.DataContent.Clone();
PendingRemote = ReceiveOrg.Remote;
}
}
//将初步处理的数据，进行识别
while (true) //进行多次识别，直到不存在有效数据
{
if (PendingDataBuffer == null)
{
break;
}
//识别连接后的数据，输出有效数据、无效数据、未完成数据
//有效数据存入
DataIdentResultStruct DataIdentResult = HelperNWGY10Encoding.IdentData(PendingDataBuffer);
if (DataIdentResult == null)
{
break;
}
if (DataIdentResult.InvalidData != null) //无效数据通过LOG输出
{
string str = "【" + ProjectSetting.ProjectCode + "】" + "NWGY数据识别出现无效数据段：" + PendingRemote.Address.ToString() + ":" + PendingRemote.Port.ToString() + "，";
foreach (byte d in PendingDataBuffer)
{
str += d.ToString("X2") + " ";
}
Log.WriteLine(str);
//通信错误数+1
lock (CommunicatorStateLocker)
{
CommunicatorState.CommunicationErrorCount++;
}
}
PendingDataBuffer = DataIdentResult.IncompleteData; //未完成数据进行缓存，以便进行下一次识别
if (DataIdentResult.ValidData != null) //存在有效数据，进行缓存，并进行下一次识别，否则跳出识别循环
{
UdpReceiveDataStruct ReceiveData = new UdpReceiveDataStruct();
ReceiveData.Remote = PendingRemote;
ReceiveData.DataContent = (byte[])DataIdentResult.ValidData.Clone();
lock (UdpReceiveDataListLocker)
{
UdpReceiveDataList.Add(ReceiveData);
}
}
else
{
break;
}
}
}
//这里是对识别好的数据进行处理的部分了，删去了。
...
//数据处理部分结束
if (ServiceStopFlag == true)
{
break;
}
//挂起一下，防止CPU利用率过高
Thread.Sleep(10);
}
}

复制代码

2、处理处理代码中使用的数据识别提取函数

public static DataIdentResultStruct IdentData(byte[] Data)
{
if (Data == null)
{
return (null);
}
DataIdentResultStruct DataIdentResult = new DataIdentResultStruct();
byte[] OrgData = (byte[])Data.Clone();
//查找数据包起始码
for (int i = 0; i < OrgData.Length; i++)
{
if (OrgData[i] == 0x68)
{
//找到一个起始码，计算剩下的数据长度是否可能构成一个数据包
if (i + 12 > OrgData.Length) //数据长度不够
{
if (i > 0)
{
DataIdentResult.InvalidData = OrgData.Take(i).ToArray();
}
DataIdentResult.IncompleteData = OrgData.Skip(i).ToArray();
return DataIdentResult;
}
//根据协议计算剩下的数据长度是否可构成一个数据包
int DataSegLenth = OrgData[i + 8] * 256 + OrgData[i + 9];
int PacketLenth = 12 + DataSegLenth;
if(i+ PacketLenth> OrgData.Length) //数据长度不够
{
if (i > 0)
{
DataIdentResult.InvalidData = OrgData.Take(i).ToArray();
}
DataIdentResult.IncompleteData = OrgData.Skip(i).ToArray();
return DataIdentResult;
}
//判断数据包结束码
if (OrgData[i + PacketLenth - 1] != 0x16) //结束码不正确，继续循环
{
continue;
}
//计算SUM是否正确
if (SumCalc(OrgData, i + 1, PacketLenth - 3) != OrgData[i + PacketLenth - 2]) //SUM不正确，继续循环
{
continue;
}
//能运行至此，说明数据包是正确的
if (i > 0)
{
DataIdentResult.InvalidData = OrgData.Take(i).ToArray();
}
DataIdentResult.ValidData = OrgData.Skip(i).Take(PacketLenth).ToArray();
if (i + PacketLenth < OrgData.Length)
{
DataIdentResult.IncompleteData = OrgData.Skip(i + PacketLenth).ToArray();
}
return DataIdentResult;
}
}
//如果循环执行到结束了，说明没找到有效的数据包,所有的数据均为未完成数据
DataIdentResult.IncompleteData = (byte[])OrgData.Clone();
return DataIdentResult;
}

复制代码

100元话费+500莫元咨询TCP 黏包服务器怎么处理的问题

一周热门更多>

相关问题

相关文章

100元话费+500莫元咨询TCP 黏包服务器怎么处理的问题

打开微信“扫一扫”，打开网页后点击屏幕右上角分享按钮

一周热门 更多>

相关问题

相关文章

采纳回答

编辑标签

举报内容

检举类型

检举原因

检举说明(必填)

一周热门更多>