备注一个flex socket通信关于粘包问题的解决方案

// (一)?正确的接收处理

// 接收网络数据,先接收数据包的长度,在根据数据包的长度值来接收数据包本身

// 解决了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,_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; // 需要读取下一个消息的消息头

}

} */

}