【AS3】Flash與后台數據交換四種方法整理

 

隨着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端

view plaincopy to clipboardprint?
/**   
* @author Kinglong   
* @link http://www.klstudio.com   
* @mail [e-mail]   
* @version 0.1   
*/   
   
package project.test {    
   
        
    import flash.display.*;    
    import flash.events.*;    
    import flash.net.*;     
   
    public class TestURLLoader extends Sprite {    
        private var _loader:URLLoader;    
        public function TestURLLoader() {    
            //創建URLLoader對象;    
            _loader = new URLLoader();    
            //設置接收數據方式(文本、原始二進制數據、URL 編碼變量);    
            _loader.dataFormat = URLLoaderDataFormat.VARIABLES;    
                
            //設置事件偵聽器    
            configureListeners(_loader);    
                
            //設置傳遞參數;    
            var params:URLVariables = new URLVariables();    
            params.username = "kinglong";    
            params.password = "king";    
                
            //建立Request訪問對象;    
            var request:URLRequest = new URLRequest("http://www.klstudio.com/none.jsp");    
            //設置參數;    
            request.data = params;              
            //設置訪問模式(POST,GET);    
            request.method = URLRequestMethod.POST;             
                
            try {    
                loader.load(request);    
            } catch (error:Error) {    
                trace(error);    
            }    
   
                
        }    
        private function configureListeners(dispatcher:IEventDispatcher):void {    
            //加載完成事件;    
            dispatcher.addEventListener(Event.COMPLETE, loaderHandler);    
            //開始訪問事件;    
            dispatcher.addEventListener(Event.OPEN, loaderHandler);    
            //加載進度事件;    
            dispatcher.addEventListener(ProgressEvent.PROGRESS, loaderHandler);    
            //跨域訪問安全策略事件;    
            dispatcher.addEventListener(SecurityErrorEvent.SECURITY_ERROR, loaderHandler);    
            //Http狀態事件;    
            dispatcher.addEventListener(HTTPStatusEvent.HTTP_STATUS, loaderHandler);    
            //訪問出錯事件;    
            dispatcher.addEventListener(IOErrorEvent.IO_ERROR, loaderHandler);    
        }    
            
        private function loaderHandler(event:*):void {    
            switch(event.type) {    
                case Event.COMPLETE:    
                    trace(_loader.data.result);    
                    break;    
                case Event.OPEN:    
                    trace("open: " + event);    
                    break;    
                case ProgressEvent.PROGRESS:    
                    trace("progress: " + event);    
                    break;    
                case SecurityErrorEvent.SECURITY_ERROR:    
                    trace("securityError: " + event);    
                    break;    
                case HTTPStatusEvent.HTTP_STATUS:    
                    trace("httpStatus: " + event);    
                    break;    
                case IOErrorEvent.IO_ERROR:    
                    trace("ioError: " + event);    
                    break;    
                    
            }    
        }          
   
    }       
}   
/**
* @author Kinglong
* @link http://www.klstudio.com
* @mail [e-mail]
* @version 0.1
*/

package project.test {

 
 import flash.display.*;
 import flash.events.*;
 import flash.net.*;

 public class TestURLLoader extends Sprite {
  private var _loader:URLLoader;
  public function TestURLLoader() {
   //創建URLLoader對象;
   _loader = new URLLoader();
   //設置接收數據方式(文本、原始二進制數據、URL 編碼變量);
   _loader.dataFormat = URLLoaderDataFormat.VARIABLES;
   
   //設置事件偵聽器
   configureListeners(_loader);
   
   //設置傳遞參數;
   var params:URLVariables = new URLVariables();
   params.username = "kinglong";
   params.password = "king";
   
   //建立Request訪問對象;
   var request:URLRequest = new URLRequest("http://www.klstudio.com/none.jsp");
   //設置參數;
   request.data = params;   
   //設置訪問模式(POST,GET);
   request.method = URLRequestMethod.POST;   
   
            try {
                loader.load(request);
            } catch (error:Error) {
                trace(error);
            }

   
  }
  private function configureListeners(dispatcher:IEventDispatcher):void {
   //加載完成事件;
            dispatcher.addEventListener(Event.COMPLETE, loaderHandler);
   //開始訪問事件;
            dispatcher.addEventListener(Event.OPEN, loaderHandler);
   //加載進度事件;
            dispatcher.addEventListener(ProgressEvent.PROGRESS, loaderHandler);
   //跨域訪問安全策略事件;
            dispatcher.addEventListener(SecurityErrorEvent.SECURITY_ERROR, loaderHandler);
   //Http狀態事件;
            dispatcher.addEventListener(HTTPStatusEvent.HTTP_STATUS, loaderHandler);
   //訪問出錯事件;
            dispatcher.addEventListener(IOErrorEvent.IO_ERROR, loaderHandler);
        }
  
  private function loaderHandler(event:*):void {
   switch(event.type) {
    case Event.COMPLETE:
     trace(_loader.data.result);
     break;
    case Event.OPEN:
     trace("open: " + event);
     break;
    case ProgressEvent.PROGRESS:
     trace("progress: " + event);
     break;
    case SecurityErrorEvent.SECURITY_ERROR:
     trace("securityError: " + event);
     break;
    case HTTPStatusEvent.HTTP_STATUS:
     trace("httpStatus: " + event);
     break;
    case IOErrorEvent.IO_ERROR:
     trace("ioError: " + event);
     break;
    
   }
  }     

 } 
} 

服務端(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 [e-mail]   
* @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 [e-mail]
* @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 [e-mail]   
* @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 [e-mail]
* @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?
<!---文件名為myservice.cfc--->   
<cfcomponent   displayname="我的服務">     
     
<!---定義了getString方法,需將access設為remote,否則Flash   remoting無法調用此方法--->   
     
<cffunction name="getString" access="remote"   returntype="string">     
      
<cfargument name="name" type="string"   required="true">     
      
<cfset myResult = arguments.name &   ",歡迎你!">     
      
<cfreturn myResult>     
     
</cffunction>     
</cfcomponent>   
<!---文件名為myservice.cfc--->
<cfcomponent   displayname="我的服務"> 
 
<!---定義了getString方法,需將access設為remote,否則Flash   remoting無法調用此方法--->
 
<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.如果使用虛擬主機的話配置起來比較麻煩。
 
三、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為例,其他版本請參考上面提供的連接)
================================================================
<!---文件名為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> 

 

 

調用的時候，只要在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;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;
}
}
}
}