开发者社区> shy丶gril> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

[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端

复制代码
  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?
<!---文件名为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;
}
}
}
}
复制代码

 

作者:Orson 
出处:http://www.cnblogs.com/java-class/ 
如果,您认为阅读这篇博客让您有些收获,不妨点击一下右下角的【推荐】 
如果,您希望更容易地发现我的新博客,不妨点击一下左下角的【关注我】 
如果,您对我的博客内容感兴趣,请继续关注我的后续博客,我是【Orson】 

本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段 声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。 

转载:http://www.cnblogs.com/java-class/p/4371641.html

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
hash处理海量数据及其实现
 【什么是Hash】   Hash,一般翻译做“散列”,也有直接音译为“哈希”的,就是把任意长度的输入(又叫做预映射, pre-image),通过散列算法,变换成固定长度的输出,该输出就是散列值。
855 0
九大数据分析方法:分层分析法
大家好,我是爱学习的小熊妹。 今天继续跟大家分享:分层分析法。这个方法也非常简单实用,即可以弥补矩阵分析法的缺陷,又是用户分群,商品ABC分析的基础,很实用哦。
89 0
数据处理 | 图谱精选课程
带你走入结构化查询语言
136 0
数据库原理——图书馆管理系统
数据库原理——图书馆管理系统
109 0
学会BS4,轻松解决数据提取!
大家好,我是志斌! 最近志斌在忙着考研复试,所以更新的有点慢,大家见谅哈!今天来给大家介绍用BeautifulSoup4来对数据进行解析和提取的方法。
19 0
Redis哨兵集群主库故障数据恢复
Redis哨兵集群主库故障数据恢复
85 0
Redis哨兵集群主库故障数据恢复(九)
Redis哨兵集群主库故障数据恢复 当主库修复后重新上线首先通过哨兵知道谁是当前的主库,然后就会去找主库同步数据,并且会自动修改配置文件,当数据同步后,想恢复的主库重新成为主库则需要把主库的权重调高,然后重新选举,这时原来的主库就能成为新的主库,调整完再将主库的权重值调成默认的
55 0
+关注
1876
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载