随着Flash Player 9的普及,AS3编程也越来越多了,所以这次重新整理AS3下几种与后台数据交换方法。1.URLLoader(URLStream)2.FlashRemoting3.XMLSocket(Socket) 4.FMS/FCS
一、URLLoader(URLStream)篇
URLStream和URLLoader中URLLoaderDataFormat.BINARY类似,它提供对下载 URL 的低级访问方式,我在此不再重复了,有兴趣的,可以看Flash帮助中URLStream类。Flash端1 view plaincopy to clipboardprint? 2 /** 3 * @author Kinglong 4 * @link http://www.klstudio.com 5 * @mail kinglong@gmail.com 6 * @version 0.1 7 */ 8 9 package project.test { 10 11 12 import flash.display.*; 13 import flash.events.*; 14 import flash.net.*; 15 16 public class TestURLLoader extends Sprite { 17 private var _loader:URLLoader; 18 public function TestURLLoader() { 19 //创建URLLoader对象; 20 _loader = new URLLoader(); 21 //设置接收数据方式(文本、原始二进制数据、URL 编码变量); 22 _loader.dataFormat = URLLoaderDataFormat.VARIABLES; 23 24 //设置事件侦听器 25 configureListeners(_loader); 26 27 //设置传递参数; 28 var params:URLVariables = new URLVariables(); 29 params.username = "kinglong"; 30 params.password = "king"; 31 32 //建立Request访问对象; 33 var request:URLRequest = new URLRequest("http://www.klstudio.com/none.jsp"); 34 //设置参数; 35 request.data = params; 36 //设置访问模式(POST,GET); 37 request.method = URLRequestMethod.POST; 38 39 try { 40 loader.load(request); 41 } catch (error:Error) { 42 trace(error); 43 } 44 45 46 } 47 private function configureListeners(dispatcher:IEventDispatcher):void { 48 //加载完成事件; 49 dispatcher.addEventListener(Event.COMPLETE, loaderHandler); 50 //开始访问事件; 51 dispatcher.addEventListener(Event.OPEN, loaderHandler); 52 //加载进度事件; 53 dispatcher.addEventListener(ProgressEvent.PROGRESS, loaderHandler); 54 //跨域访问安全策略事件; 55 dispatcher.addEventListener(SecurityErrorEvent.SECURITY_ERROR, loaderHandler); 56 //Http状态事件; 57 dispatcher.addEventListener(HTTPStatusEvent.HTTP_STATUS, loaderHandler); 58 //访问出错事件; 59 dispatcher.addEventListener(IOErrorEvent.IO_ERROR, loaderHandler); 60 } 61 62 private function loaderHandler(event:*):void { 63 switch(event.type) { 64 case Event.COMPLETE: 65 trace(_loader.data.result); 66 break; 67 case Event.OPEN: 68 trace("open: " + event); 69 break; 70 case ProgressEvent.PROGRESS: 71 trace("progress: " + event); 72 break; 73 case SecurityErrorEvent.SECURITY_ERROR: 74 trace("securityError: " + event); 75 break; 76 case HTTPStatusEvent.HTTP_STATUS: 77 trace("httpStatus: " + event); 78 break; 79 case IOErrorEvent.IO_ERROR: 80 trace("ioError: " + event); 81 break; 82 83 } 84 } 85 86 } 87 } 88 /** 89 * @author Kinglong 90 * @link http://www.klstudio.com 91 * @mail kinglong@gmail.com 92 * @version 0.1 93 */ 94 95 package project.test { 96 97 98 import flash.display.*; 99 import flash.events.*;100 import flash.net.*;101 102 public class TestURLLoader extends Sprite {103 private var _loader:URLLoader;104 public function TestURLLoader() {105 //创建URLLoader对象;106 _loader = new URLLoader();107 //设置接收数据方式(文本、原始二进制数据、URL 编码变量);108 _loader.dataFormat = URLLoaderDataFormat.VARIABLES;109 110 //设置事件侦听器111 configureListeners(_loader);112 113 //设置传递参数;114 var params:URLVariables = new URLVariables();115 params.username = "kinglong";116 params.password = "king";117 118 //建立Request访问对象;119 var request:URLRequest = new URLRequest("http://www.klstudio.com/none.jsp");120 //设置参数;121 request.data = params; 122 //设置访问模式(POST,GET);123 request.method = URLRequestMethod.POST; 124 125 try {126 loader.load(request);127 } catch (error:Error) {128 trace(error);129 }130 131 132 }133 private function configureListeners(dispatcher:IEventDispatcher):void {134 //加载完成事件;135 dispatcher.addEventListener(Event.COMPLETE, loaderHandler);136 //开始访问事件;137 dispatcher.addEventListener(Event.OPEN, loaderHandler);138 //加载进度事件;139 dispatcher.addEventListener(ProgressEvent.PROGRESS, loaderHandler);140 //跨域访问安全策略事件;141 dispatcher.addEventListener(SecurityErrorEvent.SECURITY_ERROR, loaderHandler);142 //Http状态事件;143 dispatcher.addEventListener(HTTPStatusEvent.HTTP_STATUS, loaderHandler);144 //访问出错事件;145 dispatcher.addEventListener(IOErrorEvent.IO_ERROR, loaderHandler);146 }147 148 private function loaderHandler(event:*):void {149 switch(event.type) {150 case Event.COMPLETE:151 trace(_loader.data.result);152 break;153 case Event.OPEN:154 trace("open: " + event);155 break;156 case ProgressEvent.PROGRESS:157 trace("progress: " + event);158 break;159 case SecurityErrorEvent.SECURITY_ERROR:160 trace("securityError: " + event);161 break;162 case HTTPStatusEvent.HTTP_STATUS:163 trace("httpStatus: " + event);164 break;165 case IOErrorEvent.IO_ERROR:166 trace("ioError: " + event);167 break;168 169 }170 } 171 172 } 173 }
服务端(jsp)
view plaincopy to clipboardprint?<%@ page contentType="text/html; charset=utf-8" language="java" import="java.sql.*" errorPage="" %> <% String username = request.getParameter("username"); String password = request.getParameter("password"); boolean result = false; //访问数据...; out.println("result="+result+"&_"); %> <%@ page contentType="text/html; charset=utf-8" language="java" import="java.sql.*" errorPage="" %><%String username = request.getParameter("username");String password = request.getParameter("password");boolean result = false;//访问数据...;out.println("result="+result+"&_");%>
优点:
1、flash代码实现起来简单,方便。2、服务端接收页面和接收一个表单过来的数据一样处理,不需要专门的技术,所有服务端程序都可以实现! 3、可以发送字符串变量,也可以发送文件流([AS3]URLLoader+URLRequest+JPGEncoder实现BitmapData图片数据保存)。4、可以结合AMF3接收更为丰富的数据类型([AS3]AMF3+JAVA的调用范例)。缺点:1、传递的变量不宜过多。2、变量传递的值不宜过长。注意:如果接收数据类型设置成URLLoaderDataFormat.VARIABLES后,第一个字符不能以&开头,结尾部分建议以&_为结束比较好。
二、FlashRemoting篇
相对于AS版FlashRemoting,客户端代码要简单多了,传递的数据更为丰富了。客户端RemotingService类view plaincopy to clipboardprint?/** * @author Kinglong * @link http://www.klstudio.com * @mail kinglong@gmail.com * @version 0.1 */ package com.klstudio.remoting{ import flash.net.NetConnection; import flash.net.ObjectEncoding; public class RemotingService extends NetConnection{ function RemotingService(url:String,amf:uint=ObjectEncoding.AMF0){ this.objectEncoding = amf; this.connect(url); } } } /*** @author Kinglong* @link http://www.klstudio.com* @mail kinglong@gmail.com* @version 0.1*/package com.klstudio.remoting{ import flash.net.NetConnection; import flash.net.ObjectEncoding; public class RemotingService extends NetConnection{ function RemotingService(url:String,amf:uint=ObjectEncoding.AMF0){ this.objectEncoding = amf; this.connect(url); } }} TestFlashRemoting类view plaincopy to clipboardprint?/** * @author Kinglong * @link http://www.klstudio.com * @mail kinglong@gmail.com * @version 0.1 */ package project.test { import flash.display.*; import flash.events.*; import flash.net.*; import com.klstudio.remoting.RemotingService; public class TestFlashRemoting extends Sprite { private var _service:RemotingService; public function TestFlashRemoting() { //创建服务 _service = new RemotingService("http://localhost:8500/flashservices/gateway"); //调用FlashRemoting方法 /* * RemotingService.call([方法名],[返回结果],[输入参数]...); */ _service.call("myservice.getString",new Responder(onResult, onFault),"kinglong"); } //返回正确结果; private function onResult(result:Object):void { trace("result:"+result); } //返回错误信息 private function onFault(fault:Object):void { trace("fault:"+fault.details); } } } /*** @author Kinglong* @link http://www.klstudio.com* @mail kinglong@gmail.com* @version 0.1*/package project.test { import flash.display.*; import flash.events.*; import flash.net.*; import com.klstudio.remoting.RemotingService; public class TestFlashRemoting extends Sprite { private var _service:RemotingService; public function TestFlashRemoting() { //创建服务 _service = new RemotingService("http://localhost:8500/flashservices/gateway"); //调用FlashRemoting方法 /* * RemotingService.call([方法名],[返回结果],[输入参数]...); */ _service.call("myservice.getString",new Responder(onResult, onFault),"kinglong"); } //返回正确结果; private function onResult(result:Object):void { trace("result:"+result); } //返回错误信息 private function onFault(fault:Object):void { trace("fault:"+fault.details); } } } 服务端我这边还是以Coldfusion Component为例view plaincopy to clipboardprint?
优点:
1.传输数据类型比较丰富。2.可以支持AMF0,AMF3两种数据封装类型,AMF3是Flash Player 9或更高级才能支持,有了AMF3,可以直接传送二进制文件流数据。3.传输效率相对比较高。4.对各种后台的支持也比较好。FDS(LCDS) - 是Adobe主推的FlashRemoting服务端,功能强大(当然也支持AMF0,AMF3格式,java和net平台都支持),质量也不错,可惜这个是需要银子的。Blazeds - 是Adobe另外一个开源的FlashRemoting项目,基于Java平台的,支持AMF0,AMF3格式Amfphp - 一种基于PHP的RPC工具,支持FlashRemoting中AMF0和AMF3两种格式,开源项目。Openamf - 一种基于Java的FlashRemoting开源项目,目前只支持AMF0格式。GDS(Granite Data Services) - 也是一个基于Java平台的FlashRemoting项目,支持AMF3的。WebORB - 一个支持.net,java,php,ruby等开发平台的FlashRemoting项目,也支持AMF0和AMF3。FluorineFx - 一个支持.net开发平台的FlashRemoting开源项目, AMF0, AMF3 ,RTMP, RTMPT 。缺点:
1.需要后台服务端装相应版本的Flash Remoting模块才可以使用。2.如果使用虚拟主机的话配置起来比较麻烦。 三、WebService 个人觉得WebService的数据访问速度,仅次于Remoting,但WebService是一种通用型的接口,一般服务端技术都支持的! WebService的优点: 1.WebService的接口支持比较广泛(Java,ASP.Net,PHP,Coldfusion-我下面举例用); 2.WebService是一个通用型的接口,所以服务端写的接口,不局限于Flash使用,其他程序也可以调用,"一举两得"! 3.WebService和Remoting一样,支持多种数据类型! 4.今天还发现FMS除了支持Remoting接口,也支持WebService接口了:) WebService的缺点: Flash客户端到是没有什么问题,Flash的开发工具就自带了(WebServiceConnector 组件),但服务端虽说大多都支持这个接口技术,但除了Coldfusion生成WebService方便外,其他的实现都挺复杂的!//=======================================;// Flash客户端代码;// 对于代码不是很熟悉的可以直接使用WebServiceConnector 组件,进行设置设置就可以了。// 我这里主要是写用代码来调用WebService方法。// 当然这个前提是你要把WebServiceConnector 组件先放到库里,否则类就无法引用了。//=======================================;stop();//引用WebService类;import mx.services.WebService;//定义WebService的路径;var ws_url:String = http://localhost:8500/klstudio/myservice.cfc?wsdl;//定义WebService对象;var ws:WebService = new WebService(ws_url);//调用WebService方法;var callObject = ws.getString("kinglong");//设置返回结果对象;callObject.onResult = function(result){ trace("result:"+result);}//如果调用错误返回信息(这个是可选的);callObject.onFault = function(fault){ trace("fault:"+fault.faultstring);} 注意:如果返回结果是一个数据集的话,那每个字段名都要用大写,不管你的服务端是否大写! ================================================================ 服务端方法定义(我这里仍以Coldfusion Component为例,其他版本请参考上面提供的连接)================================================================
调用的时候,只要在cfc路径后面加"?wsdl"就可以了,方便吧! :
四、XMLSocket
这是LoadVars(XML)、Flash Remoting、Webservice、XMLSocket四种方法整理的最后一篇,也让大家久等了(没想到前几篇的文章在网上挺受欢迎的,其中还有一人给我发邮件,相看我这个最后一篇,哈哈,还是挺欣慰的。对转载我要声明一下,首先这几篇文章欢迎转载的,但要说明文章的作者,以及文章的原址吧,我发现有些网站转载,连作者都不写了或者写的就不对。这一点会影响我以后写文章的心情的,特此说明一下!)。现在接下来转入正题了!
XMLSocket主要用于与服务端进行即时通信,目前的应用领域主要是Flash文本聊天和Flash在线游戏等方面。 XMLSocket的优点: 1、能和服务端即时通信; 2、Flash Player 5.0以上的版本内置类,不需另装组件或插件; 3、因为XMLSocket就是相当于一个Socket客户端,所以一般的中间件都支持的(如java,.Net等) XMLSocket的缺点: 1、XMLSocket只能传字符串或xml格式的文本,数据类型单一; 2、XMLSocket服务端自行开发的话,需要对Socket技术比较了解才行,好在网上有现成的服务端软件(商业的XMLSocket Server 有Unity、Fortress;开源的XMLSocket Server 有Oregano Multiuser Server); 3、还有就是XMLSocket的80端口与flash安全策略问题。(网上有一个解决方法,不知是否可行,请自行验证)
//=======================================;// Flash客户端(以Flash文本聊天为例);//=======================================;var paramObj:Object = new Object();//命令分隔符;paramObj.CommandDelimiters = "-@@##@@-";//用户列表分隔符;paramObj.PeopleDelimiters = "-@#@-";//建立XMLSocket对象;var socket:XMLSocket = new XMLSocket();//连接状态事件;socket.onConnect = function(success) {trace("socket.onConnect:"+success);if (!success) {trace("服务器连接失败,请检查网络状态!");}};//关闭事件;socket.onClose = function() {trace("服务端已关闭!");logoutChat();};//数据通信事件;socket.onData = function(src) {//trace("socket.onData:"+src);doCommand(getCmdArrayByMsg(trim(src)));};//用户登录;function loginChat():Void {//连接Socket服务端;socket.connect(“localhost”, “8888”);sendSocket("INFO"+paramObj.CommandDelimiters+msg);}//用户注销;function logoutChat(b:Boolean):Void {sendSocket("QUIT");}//显示聊天信息;function showChat(msg:String):Void {trace(“聊天信息:”+msg);}//发送聊天信息;function sendChat(msg:String):Void{sendSocket("MSG"+paramObj.CommandDelimiters+msg+paramObj.CommandDelimiters+msg);}//向服务端发送信息;function sendSocket(msg:String):Void {socket.send(msg+"\r");}//处理服务端返回信息;function getCmdArrayByMsg(msg:String):Array {if (msg.charCodeAt(0) == 13 && msg.charCodeAt(1) == 10) {msg = msg.substr(2);}return msg.split(paramObj.CommandDelimiters);}function doCommand(arr:Array):Void {switch (arr[0]) {case "MSG" :showChat(arr[1]);break;case "TAKEN" :trace("你的登录名已经有了,请重新换一个登录名!");break;case "PEOPLE" :doPeople(arr[1]);break;}}//显示在线用户列表;function doPeople(msg:String):Void {var people_arr:Array = msg.split(paramObj.PeopleDelimiters);trace(people_arr);} //上面与XMLSocket有关的主要代码,显示方面自己添加相关组件就行了!//有一个注意点,在flash向服务端发送的命令的最后一定要加上“\r”,否则服务端无法收到消息(我的服务端是用Java开发的) //=======================================;// 服务端代码(我用java开发的,其他版本自行研究);// ChatServer.java//=======================================;package com.klstudio.socket.chat;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.Vector;//import com.klstudio.util.Logger;/*** @author kinglong* * TODO 要更改此生成的类型注释的模板,请转至窗口-首选项- Java -代码样式-代码模板*/public class ChatServer {//private Logger logger;private static Vector clients = new Vector();private static ServerSocket server = null;private static Socket socket = null;public static String CommandDelimiters = "-@@##@@-";public static String PeopleDelimiters = "-@#@-";public ChatServer() {}public static void notifyRoom() {StringBuffer people = new StringBuffer("PEOPLE"+CommandDelimiters+"所有的人");for (int i = 0; i < clients.size(); i++) {Client client = (Client) clients.elementAt(i);people.append(PeopleDelimiters+client.getClientName());}sendClients(people);}public staticboolean checkName(Client newClient){for(int i=0;i0){Client client = (Client) clients.firstElement();try {client.getClientSocket().close();} catch (IOException e) {// TODO 自动生成 catch 块//Logger logger = new Logger(System.out);//logger.log("错误-" + e.toString());} finally {clients.removeElement(client);}}}public static synchronized void disconnect(Client client) {client.send(new StringBuffer("QUIT"));try {client.getClientSocket().close();} catch (IOException e) {// TODO 自动生成 catch 块//Logger logger = new Logger(System.out);//logger.log("错误-" + e.toString());} finally{clients.removeElement(client);}}public static synchronized void sendClients(StringBuffer sb) {for(int i=0;i 欢迎你进入!"));}else{client.send(new StringBuffer("MSG"+CommandDelimiters+"系统信息>["+ownerClient.getClientName()+"]用户进入!"));}}}public static void main(String[] args) {int port = 8888; if(args.length>0){port = Integer.parseInt(args[0]);}//Logger logger = new Logger(System.out);//logger.log("信息-ChatServer["+port+"]服务正在启动...");try {server = new ServerSocket(port);} catch (IOException e) {// TODO 自动生成 catch 块//logger.log("错误-"+e.toString());}while(true){if(clients.size()<5){try {socket = server.accept();if(socket != null){//logger.log("信息-"+socket.toString()+"连接");}} catch (IOException e) {// TODO 自动生成 catch 块//logger.log("错误-"+e.toString());}int i=0;do{Client client = new Client(socket);if(client.getClientName() != null){clients.addElement(client);if(checkName(client)){//logger.log("信息-"+"目前有["+clients.size()+"]个用户已连接");sendClients(client);client.start();notifyRoom();}else{client.send(new StringBuffer("TAKEN"));disconnect(client);}i++;}break;}while(i 1){this.clientName = info_arr[1];}this.clientIp = socket.getRemoteSocketAddress().toString();}else{socket.close();}} catch (IOException e) {// TODO 自动生成 catch 块//this.logger.log("错误-" + e.toString());}}/*** @return 返回 ip。*/public String getClientIp() {return clientIp;}/*** @return 返回 name。*/public String getClientName() {return clientName;}/*** @return 返回 socket。*/public Socket getClientSocket() {return clientSocket;}public void send(StringBuffer msg){this.ps.println(msg.toString()+"\0");//this.ps.flush();}public void run() {while (true) {String line = null;try {line = this.br.readLine();} catch (IOException e) {// TODO 自动生成 catch 块//this.logger.log("错误-" + e.toString());ChatServer.disconnect(this);ChatServer.notifyRoom();return;}if (line == null) {//this.logger.log("信息-[" + this.clientName + this.clientIp + "]用户离开!");ChatServer.disconnect(this);ChatServer.notifyRoom();if(this.clientName != null){ChatServer.sendClients(new StringBuffer("MSG"+ChatServer.CommandDelimiters+"系统信息>[" + this.clientName + "]用户离开!"));}return;}//this.logger.log("信息-"+line);String[] cmd_arr = line.split(ChatServer.CommandDelimiters);String keyword = cmd_arr[0];keyword = keyword.substring(1);if(keyword.equals("MSG")){StringBuffer msg = new StringBuffer("MSG"+ChatServer.CommandDelimiters);msg.append(this.clientName+">");msg.append(cmd_arr[1]);ChatServer.sendClients(msg,this.clientName,cmd_arr[2]);}else if(keyword.equals("QUIT")){//this.logger.log("信息-[" + this.clientName + this.clientIp + "]用户离开!");ChatServer.disconnect(this);ChatServer.notifyRoom();ChatServer.sendClients(new StringBuffer("MSG"+ChatServer.CommandDelimiters+"系统信息>[" + this.clientName + "]用户离开!"));this.stop();return;}}}}