Flash Socket 底层接受数据的初级处理(as3.0)
2012-04-01 00:18
351 查看
flash去开发应用,,免不了网络通讯,特别是网络游戏,需要用到即使通讯。 as3提供了两个支持即时通讯的类:XMLSocket和Socket,前者其实是只支持发送字符串,而后者就强大多了,支持发送字节,相对来说比较底层,而这也给我们更多的发挥空间。 其实,flash socket的网络底层接受数据,就以与C++服务器通讯为例子,C++服务器一般会发一段一段数据过来,每段数据都是由一定结构组成的,一般是消息头和消息头,然后再逐步分层解析。 在这里,我只说接受网络底层的处理,一般一段数据前面,还有有一个4个字节左右的数据,表示的是后面网络流里的数据有多少....
看下简单示意图
们网络底层需要做的处理,就是根据头4个字节判断出后面的数据大小,然后把那一整块取出来,抛给上层解析,然后又在不停地侦听,收到指定大小之后,又做类似的操作,下面看详细的代码
[plain]
view plaincopyprint?
/**
* @(#)NetBottomHandle.as
* @author soda.C mail:sujun10@21cn.com
* @version 1.0
* <br>Copyright (C), 2007 soda.C
* <br>This program is protected by copyright laws.
* <br>Program Name:GameHall
* @data 2008-3-20
*/
package org.sujun.net
{
import flash.net.Socket;
import flash.events.ProgressEvent;
import flash.utils.ByteArray;
/**
* socket数据流里的底层处理,从这里接受到服务器的数据,满足条件后就会抛出需要的字节
* 对数据流的数据,不做任何处理
*/
public class NetBottomHandle
{
private var socket :Socket;
private var listener :Function; //接受网络解析出来的数据
private var msgLen :int; //消息长度
private var msgLenMax :int; //收到的消息最大长度
private var headLen :int; //消息头长度
private var isReadHead :Boolean; //是否已经读了消息头
private var bytes :ByteArray; //所读数据的缓冲数据,读出的数据放在这里
public function NetBottomHandle()
{
msgLenMax = 5000; //5000字节
headLen = 4; //4个字节
bytes = new ByteArray();
}
/**
* 设置一个网络通讯实例
*/
public function setSocket(socket:Socket):void
{
this.socket = socket;
//监听......
socket.addEventListener(ProgressEvent.SOCKET_DATA, onServerData,false,0,true);
}
/**
* 接受在网络层里收到的原始数据,传递过来的数据为描述长度,以及ByteArray对象functon(len,bytes)
* @param listener:接受数据函数
*/
public function receiverNetData(listener:Function):void
{
this.listener = listener;
}
/**
* 服务器发送过来的数据都在这里接收,最底层的
*/
private function onServerData(event:ProgressEvent):void
{
//一有收到数据的事件,就通过这个函数进行检验
parseNetData();
}
/**
* 解析网络数据流
*/
private function parseNetData():void
{
//如果需要读信息头
if(isReadHead)
{
if(socket.bytesAvailable >= headLen)
{
//读出指示后面的数据有多大
msgLen = socket.readUnsignedInt();
isReadHead = false;
}
}
//如果已经读了信息头,则看能不能收到满足条件的字节数
if(!isReadHead && msgLen <= msgLenMax)
{
//如果为0,表示收到异常消息
if(msgLen == 0)
{
//一般消息长度为0的话,表示与服务器出了错,或者即将被断开等,通知客户端,进行特别处理
listener(msgLen,null);
return ;
}
//数据流里的数据满足条件,开始读数据
if(socket.bytesAvailable >= msgLen)
{
//指针回归
bytes.position = 0;
//取出指定长度的网络字节
socket.readBytes(bytes, 0, msgLen);
listener(msgLen,bytes);
}
}
isReadHead = false;
//如果数据流里还满足读取数据条件,继续读取数据
if(socket.bytesAvailable >= headLen)
{
parseNetData();
}
}
}
}
看下简单示意图
们网络底层需要做的处理,就是根据头4个字节判断出后面的数据大小,然后把那一整块取出来,抛给上层解析,然后又在不停地侦听,收到指定大小之后,又做类似的操作,下面看详细的代码
[plain]
view plaincopyprint?
/**
* @(#)NetBottomHandle.as
* @author soda.C mail:sujun10@21cn.com
* @version 1.0
* <br>Copyright (C), 2007 soda.C
* <br>This program is protected by copyright laws.
* <br>Program Name:GameHall
* @data 2008-3-20
*/
package org.sujun.net
{
import flash.net.Socket;
import flash.events.ProgressEvent;
import flash.utils.ByteArray;
/**
* socket数据流里的底层处理,从这里接受到服务器的数据,满足条件后就会抛出需要的字节
* 对数据流的数据,不做任何处理
*/
public class NetBottomHandle
{
private var socket :Socket;
private var listener :Function; //接受网络解析出来的数据
private var msgLen :int; //消息长度
private var msgLenMax :int; //收到的消息最大长度
private var headLen :int; //消息头长度
private var isReadHead :Boolean; //是否已经读了消息头
private var bytes :ByteArray; //所读数据的缓冲数据,读出的数据放在这里
public function NetBottomHandle()
{
msgLenMax = 5000; //5000字节
headLen = 4; //4个字节
bytes = new ByteArray();
}
/**
* 设置一个网络通讯实例
*/
public function setSocket(socket:Socket):void
{
this.socket = socket;
//监听......
socket.addEventListener(ProgressEvent.SOCKET_DATA, onServerData,false,0,true);
}
/**
* 接受在网络层里收到的原始数据,传递过来的数据为描述长度,以及ByteArray对象functon(len,bytes)
* @param listener:接受数据函数
*/
public function receiverNetData(listener:Function):void
{
this.listener = listener;
}
/**
* 服务器发送过来的数据都在这里接收,最底层的
*/
private function onServerData(event:ProgressEvent):void
{
//一有收到数据的事件,就通过这个函数进行检验
parseNetData();
}
/**
* 解析网络数据流
*/
private function parseNetData():void
{
//如果需要读信息头
if(isReadHead)
{
if(socket.bytesAvailable >= headLen)
{
//读出指示后面的数据有多大
msgLen = socket.readUnsignedInt();
isReadHead = false;
}
}
//如果已经读了信息头,则看能不能收到满足条件的字节数
if(!isReadHead && msgLen <= msgLenMax)
{
//如果为0,表示收到异常消息
if(msgLen == 0)
{
//一般消息长度为0的话,表示与服务器出了错,或者即将被断开等,通知客户端,进行特别处理
listener(msgLen,null);
return ;
}
//数据流里的数据满足条件,开始读数据
if(socket.bytesAvailable >= msgLen)
{
//指针回归
bytes.position = 0;
//取出指定长度的网络字节
socket.readBytes(bytes, 0, msgLen);
listener(msgLen,bytes);
}
}
isReadHead = false;
//如果数据流里还满足读取数据条件,继续读取数据
if(socket.bytesAvailable >= headLen)
{
parseNetData();
}
}
}
}
相关文章推荐
- Flash Socket 底层接受数据的初级处理(as3.0)
- Flash Socket 底层接受数据的初级处理(as3.0)
- Flash Socket 底层接受数据的初级处理(as3.0)
- Flash Socket底层接受数据的初级处理
- [AS3]Flash Socket底层接受数据的初级处理(转)
- [AS3]Flash Socket底层接受数据的初级处理
- Flash Socket底层接收数据的初级处理
- postgresql集群方案hot standby初级测试(二) ——处理数据能力
- flex ArrayCollection接受xml数据是时,只有一个值时出错处理
- 再谈网络游戏底层的数据处理
- ijkplayer播放器的read_thread数据接受线程在处理音频的时候如果首个数据包没有发现audio stream 以后就不会有音频数据
- 遇到的问题(一):智能家居中WIFI模块设备在接收底层家具设备串口数据时由于断帧而出现的指令丢失的情况处理
- 基于c++基础上的数据编辑处理系统的底层处理
- AJAX异步请求,底层使用hibernate查询后的数据json封装之前的处理
- 通用权限管理系统底层的软删除数据的处理方法介绍
- loction.search 通过地址栏实现页面之间的数据传输、接受、展示、处理方法
- 【学习摘记】马士兵bbs改良版_课时27-28_发表新主题:接受数据和处理数据写入同一个页面
- Android初级教程对大量数据的做分页处理理论知识
- 利用jQuery接受和处理xml数据
- Intel DAAL AI加速——支持从数据预处理到模型预测,数据源必须使用DAAL的底层封装库