废话不说了,直接上段代码:
private void DetectPacket()
{
int offset = 0;
while (m_receiveLen > 0)
{
if (m_receiveLen < 4) break;
int packetLen = BitConverter.ToInt32(m_receiveBuffer, 0);
if (m_receiveLen < packetLen + 4)
{
break;
}
Message message = new Message();
message.m_data = new byte[packetLen];
Array.Copy(m_receiveBuffer, offset + 4, message.m_data, 0, packetLen);
m_receiveMessages.Enqueue(message);
offset += (packetLen + 4);
m_receiveLen -= (packetLen + 4);
}
if (offset > 0 && m_receiveLen > 0)
{
Array.Copy(m_receiveBuffer, offset, m_receiveBuffer, 0, m_receiveLen);
}
}
解释每行的意思: while的主循环的主要目的是,分析接收到的数据包含多少个有效的数据包。直到不能组成一个完整的数据包终止循环。
int offset=0; 这里定义一个包的开始位置。
if (m_receiveLen < 4) break; 如果数据长度小于四个字节,那么也就是说,连包的长度我都没获取到,则直接终止循环,继续接收数据吧。
否则的话,则取出包的长度,这里使用的函数BitConverter.ToInt32方法,从m_receiveBuffer的0位置开始,读取四个字节,就是数据包的长度。 int packetLen = BitConverter.ToInt32(m_receiveBuffer, 0); if (m_receiveLen < packetLen + 4) { break; }
取到长度之后,判断接收的数据长度是否小于包长度+4,如果小于,则说明还不是一个完整的包,则依然终止循环,继续接收数据吧。
经过前面的两个条件检测之后,如果还能成功。那么说明,接收的数据已经足够一个包体了。则要进行分析包了。 Message message = new Message(); message.m_data = new byte[packetLen]; Array.Copy(m_receiveBuffer, offset + 4, message.m_data, 0, packetLen); m_receiveMessages.Enqueue(message); offset += (packetLen + 4); m_receiveLen -= (packetLen + 4); 这6行代码,分别是: 创建一个我们自定义的消息对象。 对message对象的成员m_data赋值,长度为packetLen。 然后从源数组m_receiveBuffer的offset+4开始处,拷贝到message.m_data的0位置,拷贝长度为packetLen。 然后压入队列。 offset则要进行偏移,偏移距离是包体长度+4个字节。 然后接收的有效数据,减去包体长度,减去4个字节。
然后再判断m_receiveLen是否大于0,如果还大于0则继续while分析包。
ok,分析到此似乎一切都是正常的。 那么while跳出之后,还有两行代码,是看是否有剩余的数据,也就是说,如果我们包体长度是100个字节,而一次接收了120个字节,而下一个包比如150个字节,那么剩余的20个字节则不构成一个整包了。 于是乎,从 100字节开始,将剩余的20个字节向前挪动到m_receiveBuffer的开始位置。 这就是: if (offset > 0 && m_receiveLen > 0) { Array.Copy(m_receiveBuffer, offset, m_receiveBuffer, 0, m_receiveLen); } 这行代码的意思。
|