// (一) 正确的接收处理
// 接收网络数据,先接收数据包的长度,在根据数据包的长度值来接收数据包本身
// 解决了flex socket在接收数据过程中可能出现的数据粘包问题
private function socketDataHander(event:ProgressEvent):void {
_onReceive.call(null,"message");
if(!_msgBuffer) {
_msgBuffer = new ByteArray();
}
while(true) {
if(_msgLength == 0) {
if(_socket.bytesAvailable < 4) {
return;
}
_msgLength = _socket.readInt();
}
if(_socket.bytesAvailable < _msgLength) {
return;
}
_socket.readBytes(_msgBuffer,0,_msgLength);
var message:String = new String(_msgBuffer);
_onReceived.call(null,message);
_msgLength = 0;
_msgBuffer.clear();
}
// (二)错误的接收处理
// 按照如下的数据接收方式是错误的,我在实际的项目中就遇到过这样的数据接收错误现象, 分析如下:
// 假如存在这样一种情形:
// 服务器端将A数据包完整地写在了客户端socket的输入流中,同时还写入了B数据包的开头一部分数据,
// 此时在flex客户端将只会触发一次ProgressEvent.SOCKET_DATA事件,
// 即只有等到服务器端下一次发送数据并在客户端检测到ProgressEvent.SOCKET_DATA事件时,
// 客户端就会误以为这就是B数据包的开始,但实际上B数据包的头部已经在前一次接收时获取到了,
// 所以将导致数据包接收错误!
// 如果B数据包正好是触发下一次通信的关键,将导致整个通信中断,那是很悲剧的!
/* trace("Receive data ... ");
_onReceive.call(null,"message"); // 告诉调用者此时有数据需要接收
var availableBytes:uint = _socket.bytesAvailable;
// 读取消息头:即消息体的长度
if(!_readHead && availableBytes >= 4) {
_msgLength = _socket.readInt();
_readHead = true;
}
// 读取了消息头之后紧接着读取socket中的消息体数据
if(_readHead && _offet < _msgLength) {
var available:uint = _socket.bytesAvailable; // socket中当前还能读取的数据
var readBytes:uint = 0; // 本次需要读取的数据
if((_offet+available) >= _msgLength) { // 已经出现了粘包现象
readBytes = _msgLength - _offet;
}else {
readBytes = available;
}
if(!_msgBuffer) {
_msgBuffer = new ByteArray();
}
_socket.readBytes(_msgBuffer,_offet,readBytes);
_offet += readBytes;
// 接收完一个完成的数据包之后要立刻将该消息派发给上层进行处理
if(_offet == _msgLength) {
_msgBuffer.uncompress();
var message:String = new String(_msgBuffer);
_onReceived.call(null,message);
_msgBuffer.clear();
_msgLength = 0;
_offet = 0;
_readHead = false; // 需要读取下一个消息的消息头
}
} */
}
分享到:
相关推荐
Socket编程TCP粘包问题及解决方案.docx
C#解决socket通信过程中粘包分包问题,本项目是一个只有6个C#代码文件的开源小工程,用来学习基于TCP的套接字通信包,可以自定义通信协议,处理分包和粘包,内置一个服务端和客户端的套接字程序,也有测试代码和对应...
Socket通信,通过异步,解决粘包问题
winsock socket网络通信_解决粘包问题.zip
Socket粘包问题终极解决方案-Netty版.docx
Socket粘包问题的3种解决方案,最后一种最完美.docx
GOLANG语言实现SOCKET通讯粘包问题解决示例,对于TCP传输分段,组合无明显界线,造成传输和接收数据包不完整的解决方法!
SuperSocket.ClientEngine.Core socket 客户端处理粘包半包,个人手撸代码
资料文件用于解决C#编程中发生的粘包问题的处理
主要为大家详细介绍了C#中TCP粘包问题的解决方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
C#实现Socket编程 (异步通讯,解决Tcp粘包)
flex socket 2030 错误 粘包.txt 看完就明白了
利用网络通信中,经常会出现粘包的问题,围绕着这个问题说原因和解决的蛮多帖子的,但是给出粘包代码的就好少,为了便于大家更好的理解粘包的问题,这里对客户端和服务器端出现的粘包问题进行模拟
Netty粘包拆包解决方案.docx
通过socket通讯实现服务器与客户端的连接。首先服务器利用udp广播发送自己的ip地址,客户端在收到广播后通过此ip以tcp连接的方式连接服务器来通讯。
linux网络编程之socket:tcp流协议产生的粘包问题和解决方案.docx
3、socket功能类库模块(其他项目也可以引用),socket类库模块功能齐全,只需调用其中方法即可,复用性较强,代码注释详细,实现了心跳,解决了粘包问题,异步发送接收数据,等等,bin目录下右运行日志方便查找程序...
Unity socket 案例包含粘包处理
一个简单的golang socket服务框架,使用简单的通信协议解决粘包问题,通过心跳计时的方式能-socket