flash和后台通讯的方法

网上找到几篇文章，是flash和后台数据交换的几种方式，个人看重xml socket

[AS3]Flash与后台数据交换方法整理1-URLLoader(URLStream)篇
PS.
随着Flash Player 9的普及，AS3编程也越来越多了，所以这次重新整理AS3下几种与后台数据交换方法。
1.URLLoader(URLStream)
2.FlashRemoting
3.XMLSocket(Socket)
4.FMS/FCS

一、URLLoader(URLStream)篇
URLStream和URLLoader中URLLoaderDataFormat.BINARY类似，它提供对下载 URL 的低级访问方式，我在此不再重复了，有兴趣的，可以看Flash帮助中URLStream类。
Flash端

 1 /**
 2 * @author Kinglong
 3 * @link http://www.klstudio.com
 4 * @mail kinglong@gmail.com
 5 * @version 0.1
 6 */
 7 package project.test {
 8     import flash.display.*;
 9     import flash.events.*;
10     import flash.net.*;
11     public class TestURLLoader extends Sprite {
12         private var _loader:URLLoader;
13         public function TestURLLoader() {
14             //创建URLLoader对象;
15             _loader = new URLLoader();
16             //设置接收数据方式(文本、原始二进制数据、URL 编码变量);
17             _loader.dataFormat = URLLoaderDataFormat.VARIABLES;
18             //设置事件侦听器
19             configureListeners(_loader);
20             //设置传递参数;
21             var params:URLVariables = new URLVariables();
22             params.username = "kinglong";
23             params.password = "king";
24             //建立Request访问对象;
25             var request:URLRequest = new URLRequest("http://www.klstudio.com/none.jsp");
26             //设置参数;
27             request.data = params;
28             //设置访问模式(POST,GET);
29             request.method = URLRequestMethod.POST;
30             try {
31                 loader.load(request);
32             } catch (error:Error) {
33                 trace(error);
34             }
35         }
36         private function configureListeners(dispatcher:IEventDispatcher):void {
37             //加载完成事件;
38             dispatcher.addEventListener(Event.COMPLETE, loaderHandler);
39             //开始访问事件;
40             dispatcher.addEventListener(Event.OPEN, loaderHandler);
41             //加载进度事件;
42             dispatcher.addEventListener(ProgressEvent.PROGRESS, loaderHandler);
43             //跨域访问安全策略事件;
44             dispatcher.addEventListener(SecurityErrorEvent.SECURITY_ERROR, loaderHandler);
45             //Http状态事件;
46             dispatcher.addEventListener(HTTPStatusEvent.HTTP_STATUS, loaderHandler);
47             //访问出错事件;
48             dispatcher.addEventListener(IOErrorEvent.IO_ERROR, loaderHandler);
49         }
50         private function loaderHandler(event:*):void {
51             switch(event.type) {
52                 case Event.COMPLETE:
53                     trace(_loader.data.result);
54                     break;
55                 case Event.OPEN:
56                     trace("open: " + event);
57                     break;
58                 case ProgressEvent.PROGRESS:
59                     trace("progress: " + event);
60                     break;
61                 case SecurityErrorEvent.SECURITY_ERROR:
62                     trace("securityError: " + event);
63                     break;
64                 case HTTPStatusEvent.HTTP_STATUS:
65                     trace("httpStatus: " + event);
66                     break;
67                 case IOErrorEvent.IO_ERROR:
68                     trace("ioError: " + event);
69                     break;
70             }
71         }
72     }
73 }

服务端(jsp)

<%@ 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后，第一个字符不能以&开头，结尾部分建议以&_为结束比较好。

[AS3]Flash与后台数据交换方法整理2-FlashRemoting篇
1.URLLoader(URLStream)
2.FlashRemoting
3.XMLSocket(Socket)
4.FMS/FCS

二、FlashRemoting篇
相对于AS版FlashRemoting，客户端代码要简单多了，传递的数据更为丰富了。
客户端
RemotingService类

        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);   
            }   
        }      
    }

服务端
我这边还是以Coldfusion Component为例

<cfcomponent displayname="我的服务">
<cffunction name="getString" access="remote" returntype="string">
<cfargument name="name" type="string" required="true">
<cfset myResult = arguments.name & ",欢迎你!">
<cfreturn myResult>
</cffunction>
</cfcomponent>

优点：
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.如果使用虚拟主机的话配置起来比较麻烦。

================================================================
  服务端方法定义(我这里仍以Coldfusion Component为例,其他版本请参考上面提供的连接)
================================================================
<!---文件名为myservice.cfc--->
<cfcomponent displayname="我的服务"> 
  <!---定义了getString方法,需将access设为remote,否则WebService无法调用此方法--->
  <cffunction name="getString" access="remote" returntype="string"> 
   <cfargument name="name" type="string" required="true"> 
   <cfset myResult = arguments.name & ",欢迎你!"> 
   <cfreturn myResult> 
  </cffunction>
</cfcomponent>

三、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);
}

四、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安全策略问题。（网上有一个解决方法，不知是否可行，请自行验证）

 1 //=======================================;
 2 // Flash客户端（以Flash文本聊天为例）;
 3 //=======================================;
 4 var paramObj:Object = new Object();
 5 //命令分隔符；
 6 paramObj.CommandDelimiters = "-@@##@@-";
 7 //用户列表分隔符；
 8 paramObj.PeopleDelimiters = "-@#@-";
 9 //建立XMLSocket对象；
10 var socket:XMLSocket = new XMLSocket();
11 //连接状态事件；
12 socket.onConnect = function(success) {
13 trace("socket.onConnect:"+success);
14 if (!success) {
15 trace("服务器连接失败,请检查网络状态!");
16 }
17 };
18 //关闭事件；
19 socket.onClose = function() {
20 trace("服务端已关闭！");
21 logoutChat();
22 };
23 //数据通信事件；
24 socket.onData = function(src) {
25 //trace("socket.onData:"+src);
26 doCommand(getCmdArrayByMsg(trim(src)));
27 };
28 //用户登录；
29 function loginChat():Void {
30 //连接Socket服务端；
31 socket.connect(“localhost”, “8888”);
32 sendSocket("INFO"+paramObj.CommandDelimiters+msg);
33 }
34 //用户注销；
35 function logoutChat(b:Boolean):Void {
36 sendSocket("QUIT");
37 }
38 //显示聊天信息；
39 function showChat(msg:String):Void {
40 trace(“聊天信息：”+msg);
41 }
42 //发送聊天信息；
43 function sendChat(msg:String):Void{
44 sendSocket("MSG"+paramObj.CommandDelimiters+msg+paramObj.CommandDelimiters+msg);
45 }
46 //向服务端发送信息；
47 function sendSocket(msg:String):Void {
48 socket.send(msg+"
");
49 }
50 
51 //处理服务端返回信息；
52 function getCmdArrayByMsg(msg:String):Array {
53 
54 if (msg.charCodeAt(0) == 13 && msg.charCodeAt(1) == 10) {
55 
56 msg = msg.substr(2);
57 
58 }
59 
60 return msg.split(paramObj.CommandDelimiters);
61 
62 }
63 
64 function doCommand(arr:Array):Void {
65 switch (arr[0]) {
66 case "MSG" :
67 showChat(arr[1]);
68 break;
69 case "TAKEN" :
70 trace("你的登录名已经有了,请重新换一个登录名!");
71 break;
72 case "PEOPLE" :
73 doPeople(arr[1]);
74 break;
75 }
76 }
77 //显示在线用户列表；
78 function doPeople(msg:String):Void {
79 var people_arr:Array = msg.split(paramObj.PeopleDelimiters);
80 trace(people_arr);
81 }

//=======================================;
// 服务端代码(我用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;i<clients.size();i++){
Client client = (Client) clients.elementAt(i);
if(client != newClient && client.getClientName().equals(newClient.getClientName())){
return false;
}
}
return true;
}
public static void closeAll(){
while(clients.size()>0){
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<clients.size();i++){
Client client = (Client) clients.elementAt(i);
client.send(sb);
}
}

public static synchronized void sendClients(StringBuffer sb,String ownerName,String toName) {
for(int i=0;i<clients.size();i++){
Client client = (Client) clients.elementAt(i);
if(toName.equals(client.getClientName()) || toName.equals("所有的人") || ownerName.equals(client.getClientName())){
client.send(sb);
}
}
}

public static synchronized void sendClients(Client ownerClient) {
for(int i=0;i<clients.size();i++){
Client client = (Client) clients.elementAt(i);
if(client.getClientName().equals(ownerClient.getClientName())){
client.send(new StringBuffer("MSG"+CommandDelimiters+"系统信息>欢迎你进入!"));
}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<clients.size());

}else{
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO 自动生成 catch 块
//logger.log("错误-"+e.toString());
}
}
}
}
}

  1 //=======================================;
  2 // Client.java
  3 //=======================================;
  4 /*
  5 * 创建日期2005-10-10
  6 *
  7 * TODO 要更改此生成的文件的模板，请转至
  8 * 窗口－首选项－ Java －代码样式－代码模板
  9 */
 10 package com.klstudio.socket.chat;
 11 
 12 import java.io.BufferedReader;
 13 import java.io.IOException;
 14 import java.io.InputStreamReader;
 15 import java.io.PrintStream;
 16 import java.net.Socket;
 17 //import com.klstudio.util.Logger;
 18 
 19 /**
 20 * @author kinglong
 21 *
 22 * TODO 要更改此生成的类型注释的模板，请转至窗口－首选项－ Java －代码样式－代码模板
 23 */
 24 public class Client extends Thread {
 25 private Socket clientSocket;
 26 private String clientName;
 27 private String clientIp;
 28 private BufferedReader br;
 29 private PrintStream ps;
 30 //private Logger logger;
 31 private ChatServer server;
 32 
 33 public Client(Socket socket) {
 34 //this.logger = new Logger(System.out);
 35 this.clientSocket = socket;
 36 try {
 37 this.br = new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf-8"));
 38 this.ps = new PrintStream(socket.getOutputStream(),true,"utf-8");
 39 String info = this.br.readLine();
 40 
 41 if(info!=null){
 42 String[] info_arr = info.split(ChatServer.CommandDelimiters);
 43 if(info_arr.length>1){
 44 this.clientName = info_arr[1];
 45 }
 46 this.clientIp = socket.getRemoteSocketAddress().toString();
 47 }else{
 48 socket.close();
 49 }
 50 } catch (IOException e) {
 51 // TODO 自动生成 catch 块
 52 //this.logger.log("错误-" + e.toString());
 53 }
 54 }
 55 
 56 /**
 57 * @return 返回 ip。
 58 */
 59 public String getClientIp() {
 60 return clientIp;
 61 }
 62 /**
 63 * @return 返回 name。
 64 */
 65 public String getClientName() {
 66 return clientName;
 67 }
 68 
 69 /**
 70 * @return 返回 socket。
 71 */
 72 public Socket getClientSocket() {
 73 return clientSocket;
 74 }
 75 public void send(StringBuffer msg){
 76 this.ps.println(msg.toString()+"");
 77 //this.ps.flush();
 78 }
 79 public void run() {
 80 while (true) {
 81 String line = null;
 82 try {
 83 line = this.br.readLine();
 84 } catch (IOException e) {
 85 // TODO 自动生成 catch 块
 86 //this.logger.log("错误-" + e.toString());
 87 ChatServer.disconnect(this);
 88 ChatServer.notifyRoom();
 89 return;
 90 }
 91 if (line == null) {
 92 //this.logger.log("信息-[" + this.clientName + this.clientIp + "]用户离开!");
 93 ChatServer.disconnect(this);
 94 ChatServer.notifyRoom();
 95 if(this.clientName != null){
 96 ChatServer.sendClients(new StringBuffer("MSG"+ChatServer.CommandDelimiters+"系统信息>[" + this.clientName + "]用户离开!"));
 97 }
 98 return;
 99 }
100 //this.logger.log("信息-"+line);
101 String[] cmd_arr = line.split(ChatServer.CommandDelimiters);
102 String keyword = cmd_arr[0];
103 keyword = keyword.substring(1);
104 if(keyword.equals("MSG")){
105 StringBuffer msg = new StringBuffer("MSG"+ChatServer.CommandDelimiters);
106 msg.append(this.clientName+">");
107 msg.append(cmd_arr[1]);
108 ChatServer.sendClients(msg,this.clientName,cmd_arr[2]);
109 }else if(keyword.equals("QUIT")){
110 //this.logger.log("信息-[" + this.clientName + this.clientIp + "]用户离开!");
111 ChatServer.disconnect(this);
112 ChatServer.notifyRoom();
113 ChatServer.sendClients(new StringBuffer("MSG"+ChatServer.CommandDelimiters+"系统信息>[" + this.clientName + "]用户离开!"));
114 this.stop();
115 return;
116 }
117 }
118 }
119 }

flash和后台通讯的方法

[AS3]Flash与后台数据交换方法整理2-FlashRemoting篇

flash与后台数据交换方法整理3-WebService篇