学步园

用flash去开发应用，，免不了网络通讯，特别是网络游戏，需要用到即使通讯。 as3提供了两个支持即时通讯的类:XMLSocket和Socket，前者其实是只支持发送字符串，而后者就强大多了，支持发送字节，相对来说比较底层，而这也给我们更多的发挥空间。 其实，flash socket的网络底层接受数据，就以与C++服务器通讯为例子，C++服务器一般会发一段一段数据过来，每段数据都是由一定结构组成的，一般是消息头和消息头，然后再逐步分层解析。 在这里，我只说接受网络底层的处理，一般一段数据前面，还有有一个4个字节左右的数据，表示的是后面网络流里的数据有多少.... 看下简单示意图

我们网络底层需要做的处理，就是根据头4个字节判断出后面的数据大小，然后把那一整块取出来，抛给上层解析，然后又在不停地侦听，收到指定大小之后，又做类似的操作，下面看详细的代码

<br /> /** </p> <p> * @(#)NetBottomHandle.as </p> <p> * @author soda.C mail:sujun10@21cn.com </p> <p> * @version 1.0 </p> <p> * <br>Copyright (C), 2007 soda.C </p> <p> * <br>This program is protected by copyright laws. </p> <p> * <br>Program Name:GameHall </p> <p> * @data 2008-3-20 </p> <p> */ </p> <p>package org.sujun.net </p> <p>{ </p> <p> import flash.net.Socket; </p> <p> import flash.events.ProgressEvent; </p> <p> import flash.utils.ByteArray; </p> <p> /** </p> <p> * socket数据流里的底层处理,从这里接受到服务器的数据,满足条件后就会抛出需要的字节 </p> <p> * 对数据流的数据,不做任何处理 </p> <p> */ </p> <p> public class NetBottomHandle </p> <p> { </p> <p> private var socket :Socket; </p> <p> private var listener :Function; //接受网络解析出来的数据 </p> <p> private var msgLen :int; //消息长度 </p> <p> private var msgLenMax :int; //收到的消息最大长度 </p> <p> private var headLen :int; //消息头长度 </p> <p> private var isReadHead :Boolean; //是否已经读了消息头 </p> <p> private var bytes :ByteArray; //所读数据的缓冲数据，读出的数据放在这里 </p> <p> public function NetBottomHandle() </p> <p> { </p> <p> msgLenMax = 5000; //5000字节 </p> <p> headLen = 4; //4个字节 </p> <p> bytes = new ByteArray(); </p> <p> } </p> <p> /** </p> <p> * 设置一个网络通讯实例 </p> <p> */ </p> <p> public function setSocket(socket:Socket):void </p> <p> { </p> <p> this.socket = socket; </p> <p> //监听...... </p> <p> socket.addEventListener(ProgressEvent.SOCKET_DATA, onServerData,false,0,true); </p> <p> } </p> <p> /** </p> <p> * 接受在网络层里收到的原始数据,传递过来的数据为描述长度,以及ByteArray对象functon(len,bytes) </p> <p> * @param listener:接受数据函数 </p> <p> */ </p> <p> public function receiverNetData(listener:Function):void </p> <p> { </p> <p> this.listener = listener; </p> <p> } </p> <p> /** </p> <p> * 服务器发送过来的数据都在这里接收,最底层的 </p> <p> */ </p> <p> private function onServerData(event:ProgressEvent):void </p> <p> { </p> <p> //一有收到数据的事件，就通过这个函数进行检验 </p> <p> parseNetData(); </p> <p> } </p> <p> /** </p> <p> * 解析网络数据流 </p> <p> */ </p> <p> private function parseNetData():void </p> <p> { </p> <p> //如果需要读信息头 </p> <p> if(isReadHead) </p> <p> { </p> <p> if(socket.bytesAvailable >= headLen) </p> <p> { </p> <p> //读出指示后面的数据有多大 </p> <p> msgLen = socket.readUnsignedInt(); </p> <p> isReadHead = false; </p> <p> } </p> <p> } </p> <p> //如果已经读了信息头,则看能不能收到满足条件的字节数 </p> <p> if(!isReadHead && msgLen <= msgLenMax) </p> <p> { </p> <p> //如果为0,表示收到异常消息 </p> <p> if(msgLen == 0) </p> <p> { </p> <p> //一般消息长度为0的话，表示与服务器出了错，或者即将被断开等，通知客户端，进行特别处理 </p> <p> listener(msgLen,null); </p> <p> return ; </p> <p> } </p> <p> //数据流里的数据满足条件，开始读数据 </p> <p> if(socket.bytesAvailable >= msgLen) </p> <p> { </p> <p> //指针回归 </p> <p> bytes.position = 0; </p> <p> //取出指定长度的网络字节 </p> <p> socket.readBytes(bytes, 0, msgLen); </p> <p> listener(msgLen,bytes); </p> <p> } </p> <p> } </p> <p> isReadHead = false; </p> <p> //如果数据流里还满足读取数据条件，继续读取数据 </p> <p> if(socket.bytesAvailable >= headLen) </p> <p> { </p> <p> parseNetData(); </p> <p> } </p> <p> } </p> <p> } </p> <p>}  

代码我就不详细解说了，注释得很清楚，这段代码也是经过我写过几个版本锤炼过的。呵呵 在实际应用中，表现也是比较稳定的 当然，这是比较早期的了，以后再正正应用中，可能还需要做更多的处理，例如每个网络字节的缓冲，缓存等，以免过多字节造成socket出错等等 希望有兴趣的人继续留贴讨论，呵呵

 点击下载此文件