- 浏览: 85169 次
- 性别:
- 来自: 北京
最新评论
-
A5121612886:
好文要顶!
Flash Builder 编译器选项 -
谁在哀伤望月:
非常好,谢谢分享
Flash builder4 插件终极破解方法
问题:
服务端Mina 前台接收Flex
参照的原型为http://www.klstudio.com/post/202.html
<[Socket
+AMF3]给合Flash的Socket和AMF3来尝试开发
web游戏
>
经过个人调试 分别在服务端和客户端收发消息时进行长度处理
但是在服务端大量发送数据
时,还是会发生客户端粘包的状况,导致发生错误,而且也比较频繁。
求服务端与客户端的收发代码
段。要实用的。
(最好是经过一定压力测试的。或者发上来我压一下。)
补充说明一次我打断点跟踪到的情况:
客户端接收到信息:
获取了长度:长度为34字节 查看socket里面也确实还有34字节的内容
但是这时候就读取object就会出现异常
flex
.messaging.io.UnknownTypeException: Unknown AMF type '120'
120这个就是34字节当中的第一个的内容 还有其他的比如 -124 之类的等等。
解答:
这个基本是socket编程都会遇到的经典问题
amf本身是一种2进制封装,连发时接收方可能会因为数据堆积在一起而分不清包的头尾,造成映射错误。
解决办法就是在发包前对amf进行简单封包,因为amf本身就是2进制格式,那么只需要在其之前写入amf长度(即正文长度),接收方,先读取包头的长度,再固定取出其后的正文。取完正文,再取包头,依次取完。
每个发出的包,结构为
struct
{
DWORD Data_LEN //包长
CHAR[..] //内容
}
理论说完,就给出关键代码,相信认真研究过socket的一看就知:
as3 ---> Server 发送部分
public function send(obj:Object) { var objByte:ByteArray = new ByteArray(); objByte.writeObject(obj); // objByte.compress(); //压缩,可以省略 var msgByte:ByteArray = new ByteArray(); msgByte.writeInt(objByte.length); msgByte.writeBytes(objByte, 0, objByte.length); sk.writeBytes(msgByte); sk.flush(); }
server --> as3 接收部分
//一接受到数据就尝试读 private function onSkData(e:ProgressEvent):void { this.readData(); } private function readData():void { //如果还没读过头部则读一次。 if (!this.isReadHead && this.sk.bytesAvailable > 4) { var lenByte:ByteArray = new ByteArray(); sk.readBytes(lenByte, 0, 4); this.msgLen = lenByte.readInt(); //trace("新的消息长度:" + this.msgLen); this.isReadHead = true; } //如果读了头部,并且当前可读长度大于等于消息长度,则开始读取 if (isReadHead && this.sk.bytesAvailable >= this.msgLen) { var objByte:ByteArray = new ByteArray(); sk.readBytes(objByte, 0, this.msgLen); this.isReadHead = false; //objByte.uncompress(); var obj:Object = objByte.readObject(); this.readMsg(obj); //读完了,可以去解释了 } //如果是读过头,则如果当前消息大于消息长度则再次调用读取,否则则判断是否可读头部 this.sk.bytesAvailable > 0 && this.readData(); }
至于server端,其原理是一样的,都是读的时候先读头,发的时候也是先发个头。
补充server端代码(C#,解码类为FluorineFx,仅供参考思路)
server -> as3 发送
public void send(object obj) { try { ByteArray objByte = new ByteArray(); objByte.WriteObject(obj); // objByte.Compress(); byte[] objBuff = new byte[objByte.Length]; objByte.Position = 0; objByte.ReadBytes(objBuff, (uint)0, (uint)objBuff.Length); ByteArray msgByte = new ByteArray(); msgByte.WriteInt(objBuff.Length); msgByte.WriteBytes(objBuff, 0, objBuff.Length); byte[] msgBuff = new byte[msgByte.Length]; msgByte.Position = 0; msgByte.ReadBytes(msgBuff, (uint)0, (uint)msgBuff.Length); //发送 this.ng.sk.BeginSend(msgBuff, 0, msgBuff.Length, SocketFlags.None, onSendOver, this.ng); } catch { Core.mainForm.addLog("发送失败"); } }
as3 -> server 接受
//接收完的回调 private void receOver(IAsyncResult ar) { NetGate ng = (NetGate)ar.AsyncState; int size = ng.sk.EndReceive(ar); // Core.mainForm.addLog("接受到总长度:" + size); int ind = 0; if (size > 0) { while (size > 0) { //读消息头 MemoryStream lenMs = new MemoryStream(ng.buff, ind, 4); ByteArray lenByte = new ByteArray(lenMs); Int32 len = lenByte.ReadInt(); // Core.mainForm.addLog("消息长度:" + len.ToString()); if (len == 0) { break; } //根据头长度取内容 MemoryStream ms = new MemoryStream(ng.buff, ind + 4, len); ByteArray ba = new ByteArray(ms); // ba.Uncompress(); object obj = ba.ReadObject(); this.readMsg(obj); ind += (len + 4); size -= (len + 4); } this.ng.buff.Initialize(); ng.sk.BeginReceive(this.ng.buff, 0, this.ng.buffSize, SocketFlags.None, this.onReceOver, this.ng); } else { ng.sk.Close(); this.offLine(); } }
发表评论
-
全面提升你的程序效率 之细说 bitmapdata AS3 Bitmap 抠图(透明部分)和碰撞(点击)检测
2012-06-05 09:54 7180如果你是刚接触as编程 ... -
PureMVC MultiCore报错 multitonKey for this Notifier not yet initialized!
2012-05-23 16:08 996multitonKey for this Notifier n ... -
关于优化
2012-05-21 14:58 9801. Avoid the new operator whe ... -
AS3经验之谈
2012-05-11 10:56 1097【改变输出swf的尺度,背景颜色 ... -
AS3动态获得类名及类的方法
2012-05-08 13:50 28161.获得某个实例对象的类名:getQualifiedClass ... -
Flex 应用内存泄露的分析与诊断
2012-05-03 11:32 710http://www.ibm.com/developerwor ... -
Flash Builder 编译器选项
2012-05-02 10:30 6393-benchmark 输出性 ... -
【AS3】为什么AS3.0事件流机制会有捕获阶段、目标阶段、冒泡阶段三个阶段
2012-04-26 10:03 3830原问题:事件机制有三个步骤,捕获,目标和冒泡。请问,在目标阶段 ... -
[AS3]事件流那点事儿
2012-04-26 09:36 1237在群里有人问了个问 ... -
AS3事件中target和currentTarget的区别
2012-04-12 15:40 1930在事件处理过程中,会 ... -
ActionScript垃圾回收
2012-04-12 15:04 1406在《给AS程序员的一点建议一文 》中我提到了释放资源的重 ... -
updateAfterEvent的作用
2012-04-10 17:26 1234flash中一共有三个类具 ... -
深入理解flash重绘
2012-04-10 17:21 1175Flash Player 会以SWF内 ... -
[AS3]registerClassAlias的用法
2012-03-20 10:35 1085registerClassAlias在利用AMF3进行序列话网 ... -
navigateToURL
2012-03-09 15:51 1164navigateToURL整理总结一些关于navigate ... -
flash中cacheAsBitmap的使用
2012-03-09 11:59 817缓存显示对象 如果 Flash 中的设计尺寸增大,无论创建 ... -
Debug和Release之本质区别
2012-02-27 11:41 1176关于Debug和Release之本质区别 使用条件编译来完成区 ... -
AS3中super的用法[转自A闪]
2012-02-13 10:19 1230super它到底是什么?这是我第一个问题,在帮助中石这样说明的 ... -
AS3.0的Dictionary类
2012-02-10 11:00 822AS3中的Dictionary类(flash. ... -
AS3中public internal private protected的区别
2012-02-10 10:43 2536protected Java與AS3中的 ...
相关推荐
NULL 博文链接:https://leopard0825.iteye.com/blog/644028
自己写的flash webgame 搭建的java 后台 解决了安全沙箱问题,可以进行聊天,和后台java函数的请求及响应。amf3 编码。
NULL 博文链接:https://sjkgxf7191.iteye.com/blog/572828
之前测试解析amf3协议数据进行树化便于观察的,解析的有可能不是很完美,正常用来观察里面的数据没什么问题
AMF3 C++ 源码 修改版 支持序列化和对象化的AMF3解析
amf3_spec amf3_spec amf3_spec amf3_spamf3_specec
AMF3 C++ AMF3 C++ 源码库码库
AMF3协议中文版定义.pdf
amf3_spec_05_05_08.pdf amf3_spec_05_05_08.pdf amf3_spec_05_05_08.pdf
一个用C++编写的,amf3协议解析模块,可以实现flash通信协议的解析
amf3 的格式说明,英文版,做rtmp协议或者做与flash数据交互服务器端必备的参考
PHP的amfext扩展,pecl.php.net上提供的0.9.2无法兼容php5.4+的版本,这个资源能确保amfext扩展在php5.4+的环境下编译成功。 本人分别在php5.4/5.5的生产环境中使用,一切正常,各位可以放心使用。
Action Message Format AMF3中英文对照 本人翻译 Abstract Action Message Format AMF is a compact binary format that is used to serialize ActionScript object graphs Once serialized an AMF encoded object ...
支持AS3的ByteArray序列化对象的AMF格式编码、解码( readObject、writeObject )。 支持AS3的ByteArray的compress、uncompress压缩算法:DEFLATE、LZIB、LZMA。 支持直接修改AS3的ByteArray字节流内编码的对象。 ...
amf0 原版文档 完整版
Adobe Flash AMF3 specification for flash player 9 and above serialization and communication.
易语言amf解析构造源码,amf解析构造,分析amf,取短整数_字节集,时间到双精度,到时间_双精度,取整数_字节集,integer_字节集,取双精度_字节集,amf3型数据,十六进制转字节集,分析数据段,解析amf数据,解析amf3数据,Utf8转...
这实现了几乎所有AMF3功能,但对于长尾负载而言,性能至少提高了一个数量级。 作为“项目的一部分而编写。 安装: npm install node_amf_cc 用法: var amfcc = require('node_amf_cc'); var encoded = amfcc....
AMF1.0(AMP).zip 代码