AMF3Connection类-使用AMF3数据格式来请求服务端数据

发布:kinglong | 发布时间: 2010年6月11日

在Flash中使用AMF3数据格式有什么的好处我就不用重复说了，我主要把把代码贴出来，希望对相关人员有些帮助吧
AMF3Connection类

package com.klstudio.net { import com.klstudio.events.AMF3ConnectionEvent; import flash.events.EventDispatcher; import flash.net.URLRequest; import flash.net.ObjectEncoding; import flash.utils.ByteArray; import flash.net.URLLoaderDataFormat; import flash.net.URLLoader; import flash.events.SecurityErrorEvent; import flash.events.IOErrorEvent; import flash.events.Event; import flash.net.URLRequestMethod; import flash.utils.Dictionary; /** * amf3连接类 * @author Kinglong * @mail:kinglong@gmail.com * @since:2010-5-21 */ [Event(name="success", type="com.klstudio.events.AMF3ConnectionEvent")] [Event(name="failed", type="com.klstudio.events.AMF3ConnectionEvent")] public class AMF3Connection extends EventDispatcher{ private var _url:String; private var _requestMethod:String; private var _loaders:Dictionary; private var _compressed:Boolean; public function AMF3Connection(url:String,compressed:Boolean=false){ _url = url; _requestMethod = URLRequestMethod.POST; _loaders = new Dictionary(true); _compressed = compressed; } public function isCompressed():Boolean{ return _compressed; } public function get requestMethod():String{ return _requestMethod; } public function set requestMethod(value:String):void { _requestMethod = value; } public function get url():String{ return _url; } public function call(method:String,callback:Function=null,args:Array=null):void{ var request:AMF3Request = new AMF3Request(method, callback, args); trace(this,"request>" + request.toString()); var bytes:ByteArray = new ByteArray(); bytes.writeObject(request.data); bytes.objectEncoding = ObjectEncoding.AMF3; if(_compressed) { bytes.compress(); } trace(this,"url>" + url); var req:URLRequest = new URLRequest(url + "?r=" + Math.random()); req.method = requestMethod; req.data = bytes; var loader:URLLoader = new URLLoader(); addLoaderHandler(loader); loader.load(req); _loaders[loader] = request; } private function loaderHandler(event:Event):void{ var loader:URLLoader = event.target as URLLoader; removeLoaderHandler(loader); var request:AMF3Request = _loaders[loader]; var response:AMF3Response = new AMF3Response(request,"没有响应请求",AMF3Response.STATE_ERROR); trace(this,event.type); switch(event.type){ case Event.COMPLETE: try{ var bytes:ByteArray = loader.data as ByteArray; if(_compressed) { bytes.uncompress(); } response = AMF3Response.parse(request,bytes.readObject()); }catch(error:Error){ trace(this,error.message); response = new AMF3Response(request,"不能解析返回对象",AMF3Response.STATE_ERROR); } break; case IOErrorEvent.IO_ERROR: response = new AMF3Response(request,"访问地址["+url+"]出错",AMF3Response.STATE_ERROR); break; case SecurityErrorEvent.SECURITY_ERROR: response = new AMF3Response(request,"Flash不能跨域访问",AMF3Response.STATE_ERROR); break; } dispatchEvent(new AMF3ConnectionEvent(response.isSuccess()?AMF3ConnectionEvent.SUCCESS:AMF3ConnectionEvent.FAILED, response)); if(request.callback != null) { request.callback.call(null, response); } delete _loaders[loader]; loader.close(); loader = null; } private function addLoaderHandler(loader:URLLoader):void{ loader.dataFormat = URLLoaderDataFormat.BINARY; loader.addEventListener(Event.COMPLETE, loaderHandler); loader.addEventListener(IOErrorEvent.IO_ERROR, loaderHandler); loader.addEventListener(SecurityErrorEvent.SECURITY_ERROR, loaderHandler); } private function removeLoaderHandler(loader:URLLoader):void{ loader.removeEventListener(Event.COMPLETE, loaderHandler); loader.removeEventListener(IOErrorEvent.IO_ERROR, loaderHandler); loader.removeEventListener(SecurityErrorEvent.SECURITY_ERROR, loaderHandler); } } } 

AMF3ConnectionEvent类

package com.klstudio.events { import com.klstudio.net.AMF3Response; import flash.events.Event; /** * amf3连接事件 * @author Kinglong * @mail:kinglong@gmail.com * @web:http://www.klstudio.com * @since:2010-5-22 */ public class AMF3ConnectionEvent extends Event { public static const SUCCESS:String = "success"; public static const FAILED:String = "failed"; private var _response:AMF3Response; public function AMF3ConnectionEvent(type : String, response:AMF3Response,bubbles:Boolean=false,cancelable:Boolean=false) { super(type, bubbles, cancelable); _response = response; } public function get response():AMF3Response{ return _response; } override public function clone() : Event { return new AMF3ConnectionEvent(type,response,bubbles,cancelable); } } } 

AMF3Request类

package com.klstudio.net { /** * amf3请求类 * @author Kinglong * @mail:kinglong@gmail.com * @web:http://www.klstudio.com * @since:2010-5-21 */ public class AMF3Request { private var _method:String; private var _callback:Function; private var _args:Array; public function AMF3Request(method:String,callback:Function=null,args:Array=null){ _method = method; _callback = callback; _args = args; } public function get method():String{ return _method; } public function get callback():Function{ return _callback; } public function get args():Array{ return _args; } public function get data():Object{ if(args == null || args.length == 0){ return {method:method}; }else{ return {method:method,args:args}; } } public function toString():String{ return "AMF3Request[method="+method+",callback="+((callback == null)?"null":"Function")+",args=["+args+"]]"; } } } 

AMF3Response类

package com.klstudio.net { /** * amf3响应类 * @author Kinglong * @mail:kinglong@gmail.com * @web:http://www.klstudio.com * @since:2010-5-22 */ public class AMF3Response { public static const STATE_SUCCESS:String = "00"; public static const STATE_ERROR:String = "99"; private var _message:String; private var _result:Object; private var _state:String; private var _request:AMF3Request; public static function parse(request:AMF3Request,obj:Object):AMF3Response{ if(obj == null) return null; if(!obj.hasOwnProperty("state")) return null; if(!obj.hasOwnProperty("message") && !obj.hasOwnProperty("result")) return null; var response:AMF3Response; if(obj["state"] == AMF3Response.STATE_SUCCESS){ response = new AMF3Response(request,obj["result"]); }else{ response = new AMF3Response(request,obj["message"],obj["state"]); } return response; } public function AMF3Response(request:AMF3Request,context:*,state:String="00") { _request = request; _state = state; if(isSuccess()) { _result = context; } else { _message = context; } } public function get request():AMF3Request{ return _request; } public function get message():String{ return _message; } public function get result():Object{ return _result; } public function get state():String{ return _state; } public function isSuccess():Boolean{ return _state == AMF3Response.STATE_SUCCESS; } public function toString() : String { return "AMF3Response[request="+request+",state="+state+",message="+message+",result="+result+"]"; } } } 
调用实例

import com.klstudio.net.AMF3Connection; import com.klstudio.net.AMF3Response; AMF3Connection amf3conn = new AMF3Connection(url,true); function callback(response:AMF3Response){ trace(response); } amf3conn.call("checkLogin", callback);

标签:

AMF3Connection amf3 AMF3Request AMF3Response

发布:kinglong | 分类:Flash技术 | 评论:4 | 引用:0 | 浏览: | TrackBack引用地址

相关文章:
使用URLLoader类来传输AMF3格式数据的调用实例  (2010-4-29 16:45:41)
[Socket+AMF3]现公布原来mina和amf3结合的服务端代码  (2009-9-17 16:42:49)
[AS3]BaseSocket类-可以提升Socket数据传输效率  (2008-11-21 14:31:51)
[Socket+AMF3]Socket安全策略问题的解决  (2008-11-20 11:48:42)
[Socket+AMF3]给合Flash的Socket和AMF3来尝试开发web游戏引擎  (2008-11-19 10:57:52)
[Socket+AMF3]对Flash的Socket和AMF3的研究心得  (2008-11-18 15:22:25)

1.路人甲
好人啊
2010-8-2 17:23:36 回复该留言

2.ddssdd
http://dfsfdfsdfsdf
return {method:method,args:args};
这一句不明白是什么意思,冒号后面的是类型吗?
admin 于 2010-12-21 22:20:18 回复
这个是对象的一种表示方式而已，你可以用
var obj:Object = new Object();
obj.method = method;
obj.args=args
return obj;
2010-12-21 9:05:55 回复该留言

3.flex
抱歉，能不能贴出java服务端的代码？
2011-7-27 16:48:15 回复该留言

4.flex
顺便补充一句： bytes.compress();这句压缩ByteArray后，为什么我在服务端java中读取Object的时候就不向下执行了？代码：
Amf3Input amf3Input = new Amf3Input(context) ;
amf3Input.setInputStream(new DataInputStream(request.getInputStream())) ;
try {
Object obj = amf3Input.readObject() ;
System.out.println(obj.toString());
} catch (ClassNotFoundException e) {
e.printStackTrace();
}

执行到Object obj = amf3Input.readObject() ;后就不向下执行，如果compress解压缩设置为false，就没有问题！求解
2011-7-27 16:52:11 回复该留言

发表评论

◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。

Kinglong's Blog

关于本博客

AMF3Connection类-使用AMF3数据格式来请求服务端数据

发表评论

搜索内容

最近发表

最新评论及回复

最近留言