flash与后台数据交换方法整理4-XMLSocket篇

Submitted by kinglong on 2006-3-13 11:34:51

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

 

//=======================================;
// Client.java
//=======================================;
/*
* 创建日期2005-10-10
*
* TODO 要更改此生成的文件的模板，请转至
* 窗口－首选项－ Java －代码样式－代码模板
*/
package com.klstudio.socket.chat;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
//import com.klstudio.util.Logger;

/**
* @author kinglong
*
* TODO 要更改此生成的类型注释的模板，请转至窗口－首选项－ Java －代码样式－代码模板
*/
public class Client extends Thread {
private Socket clientSocket;
private String clientName;
private String clientIp;
private BufferedReader br;
private PrintStream ps;
//private Logger logger;
private ChatServer server;

public Client(Socket socket) {
//this.logger = new Logger(System.out);
this.clientSocket = socket;
try {
this.br = new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf-8"));
this.ps = new PrintStream(socket.getOutputStream(),true,"utf-8");
String info = this.br.readLine();

if(info!=null){
String[] info_arr = info.split(ChatServer.CommandDelimiters);
if(info_arr.length>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;
}
}
}
}



//注意，服务端向客户端发送的信息，必需以”\0”，空字符结尾，否则客户端也无法接收到信息！

Posted in Flash相关, Tags:flash  整理  XMLSocket  

Trackback:

TrackBack URL for this entry:
http://www.klstudio.com/cmd.asp?act=tb&id=57


Comments:

#68 On 2006-3-13 12:28:07 Danger (e) said,

辛苦了，Flash与后台通讯的所有API基本上都在这篇文档中。

http://www.macromedia.com/devnet/flashplayer/articles/fp8_security-related_apis.pdf

你最后一篇应该介绍Netconnection,NetStream了，呵呵。

#69 On 2006-3-13 14:26:30 kinglong (e) said,

Netconnection,NetStream主要是用于流媒体多,如果普通的数据交换的话,我是不推荐使用的!不过谢谢你提供的那个文档,我之前没有看过,如果看了的话,我可能懒得再写这些文章了,我是一个懒人!哈哈!又要去减肥了!

#70 On 2006-3-14 9:09:13 THOR (e) said,

不论是哪个版本的Flash的XMLSocket在向服务器端发送数据包时不需要加任何字节，你可能用的是别人现成的Socket服务程序，别人可能额外要求了那个\r字节...

#71 On 2006-3-14 9:20:44 kinglong (e) said,

因为服务端也是我用java开发的,如果不在后面加\r字符的话,java服务端始终,都是在等待!

#175 On 2006-5-12 13:36:02 nonocast (e) said,

觉得danger做人不太厚道
你看了怎么不写几篇通俗易懂的给大家看看
是吧
心态放放好

对了，顺便问kinglong一个问题，就是如果我要服务端主动给flash客户端发送数据是不是只能采用XMLSocket这种方式?
或是采用其他的呢?
谢谢

#177 On 2006-5-12 14:24:58 kinglong (e) said,

我觉得你对于danger的说法有点极端了,其实danger很不错的,他的网站资讯都是最新的,这一点我们大家也是有目共睹的!

服务端主动发送数据给你客户端,除了XMLSocket方式以外,还可以用FMS(FCS)技术来实现的

#178 On 2006-5-13 9:37:00 nonocast (e) said,

sorry for 我的极端
因为我初入AS，对行情不太了解，呵呵

我感觉如果不是实时性非常高的话用js做一个xmlhttp访问策略要比用flash的socket和FMS有更大的优势，主要在综合成本上面。
换句话说还是不能利用flash来很好的做到服务器的push机制。这个很好不是说做不到，而是说在合适的成本下面，包括安全策略和服务器成本。
不知道我这个想法正确吗?请指教

谢谢这么快的reply.thx:)

#292 On 2006-7-24 11:30:08 Sky (e) said,

老兄看了你的文章,写的非常好,能给一个简单的socket的例子吗,我是做java的,java做SocketServer对我来说很简单,可是用flash做Client,我就不行了,给个flash的client源码可以吗,很简单就行,或者其他方式实现flash与java的通讯.仅此学习! 谢谢!

#334 On 2006-8-4 17:10:32 jayshao (e) said,

我最近接到一个在线的游戏,用Flash来做,本来从没有接触过Flash ActionScript的开发,但看了一些资料后感觉都是很容易上手!kinglong写的东西很好,给了我不少的帮助,这里要向你道谢!我试过用BCB,java,VC来写Socket,感觉都是很简单的!Flash XMLSocket中也只不过是三个方法四个事件!对于Sky说给个简单的例子,我觉得你打开帮助看看里面的例子最好,我借了三本的flash ActionScript的书,看完后再看Flash自带的帮助,觉得还是Flash帮助定得好!其中socket.onData(data)事件接收的服务端的数据最后是要有一个0字节为结束的,要不接收到的信息不会触发事件,也就是收不到!服务端发送前加个"\0"就好!而onXML()其实是调用onData,然后把收到的文件以XML来解释!现在用FMS来做在线的视频系统,欢迎交流,我的QQ是:56220534

#463 On 2006-9-6 13:33:57 tom (e) said,

如果我是一使用ie去打开flash，我这边发现无法跟服务器连接，如何解决这个问题呢？

#477 On 2006-9-8 15:36:17 kinglong (e) said,

to Sky:
flash代码我已经提供了！这些代码再加上文本框组件就可能以了呀！

#478 On 2006-9-8 15:40:36 kinglong (e) said,

to tom:这个问题是因为flash player的安全策略引起的，如果建议你安装flash player本地程序，然后用它来打开flash文件，最终解决方法是把这个flash插入到页面里，然后通过http形式去访问(如http://localhost/page.html)

#599 On 2006-11-3 13:21:36 jackie (e) said,

SendData StrConv("tmd", vbUnicode) flash里的onXML被加载3次，每次读取一个字符，有没有办法让他一次接收3个呢，谢谢

#874 On 2007-1-20 15:20:06 79235798 (e) said,

你好啊，有些关于Flash数据交换的问题想和你讨论一下，如果方便，请加我QQ，或者send email。
79235798
joyalife#163.com

#2189 On 2007-8-9 8:17:21 sunoy (e) said,

FMS 用的正版吗？ 我在官方网站上看到价格 US $ 4,500 ，都能买两三台好服务器了.......

#2782 On 2007-11-10 20:58:38 闪族E兵 (e) said,

请教kinglong.我用FMS在线录制的一段FLV如何发送到另外一台专门用于存储的服务器上呢?能直接发送NetStream么?

#3908 On 2008-4-15 16:39:19 wuqq (e) said,

你好，我想请问一个问题，请问如果使用openamf调用服务器端的java类时（比如普通的java bean），该java类的运行机制是怎么样的，比如会不会存在多线程访问问题？

#4940 On 2008-7-28 11:45:05 zzcStudio (e) said,

我服务器端用得是c++，是在Windows平台上的Winsoket技术用得，能否提供一下这方面的信息？Java效率不是很高吧？



Post a comment:(为了防止垃圾留言信息,您的留言需要通过审核才能显示出来)

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