`
hereson
  • 浏览: 1453945 次
  • 性别: Icon_minigender_1
  • 来自: 苏州
社区版块
存档分类
最新评论

FLEX提高篇---------FMS简易聊天室加强版

    博客分类：
  • fms2
FlexCSSAdobe.net 
阅读更多

今天写了下简易聊天室的加强版 , 其实功能也十分有很 , 不过比前面提到的简易聊天室要智能了许多 , 这个聊天室的主要功能有以下 :

 

<!---->1.       <!---->同一用户不能重复登陆 , 否则服务端拒绝 ;

<!---->2.       <!---->可以得到聊天室里人员的列表 ;

<!---->3.       <!---->新用户上线提示 ;

<!---->4.       <!---->用户离线提示 ;

<!---->5.       <!---->发送文本消息 ;

<!---->6.       <!---->新用户上线 , 更新所有聊天室成员列表名单 ;

<!---->7.       <!---->用户离线 , 更新所有聊天室成员列表名单 ;

 

技术上并没有什么花样儿 , 还是如下几个 :

<!---->1.       <!---->客户端与服务端的建立连接 ;

<!---->2.       <!---->监听连接状态 ;

<!---->3.       <!---->客户端调用服务端函数 ;

<!---->4.       <!---->服务端调用客户端函数

 

先看看粗糙的效果图:

 

 

 

 

 

 

 

再看看代码吧:

 

先看客户端的:

 

Java代码 复制代码
  1. <?xml version="1.0" encoding="utf-8"?>   
  2. <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="vertical" xmlns:com="com.*" backgroundColor="white">   
  3.     <mx:Style source="css.css"></mx:Style>   
  4.     <mx:Script>   
  5.         <![CDATA[   
  6.             import com.client.clientInvockObj;   
  7.             import mx.controls.TextInput;   
  8.             import com.carlcalderon.arthropod.Debug;   
  9.             import mx.utils.StringUtil;   
  10.             public var nc:NetConnection;   
  11.                
  12.             private static const RTMP_URL:String="rtmp://localhost/chatinglist";   
  13.             public var loginName:String;   
  14.             private var isConnectSuccess:Boolean;   
  15.                
  16.                
  17.             private function initApp():void{   
  18.                 nc=new NetConnection();   
  19.                 nc.connect(RTMP_URL,loginName);   
  20.                 nc.addEventListener(NetStatusEvent.NET_STATUS,checkStatus);   
  21.                 var obj:clientInvockObj=new clientInvockObj(chatList,chatContent);   
  22.                 nc.client=obj;   
  23.             }   
  24.                
  25.             private function checkStatus(e:NetStatusEvent):void{   
  26.                 trace(e.info.code);   
  27.                 Debug.log(e.info.code,Debug.BLUE);     
  28.                 isConnectSuccess=(e.info.code=="NetConnection.Connect.Success");   
  29.                 if(isConnectSuccess){   
  30.                     nc.call("getMsg",new Responder(getMsgResult,getMsgFault));   
  31.                     loginBtn.enabled=false;   
  32.                     sendBtn.enabled=true;   
  33.                     Debug.log("client connect success!");   
  34.                        
  35.                 }   
  36.             }   
  37.                
  38.             private function getMsgResult(chatMsgArray:Array):void{   
  39.                 Debug.log("callBack:");   
  40.                 for(var i:uint=0;i<chatMsgArray.length;i++){   
  41.                     chatContent.text+=chatMsgArray[i]+"\n";   
  42.                 }   
  43.             }   
  44.                
  45.             private function getMsgFault():void{   
  46.                    
  47.             }   
  48.                
  49.             public function sendLogin():void{   
  50.                 if(StringUtil.trim(userName.text).length>0){   
  51.                     loginName=userName.text;   
  52.                     initApp();   
  53.                 }   
  54.             }   
  55.                
  56.             public function sendMessage():void{   
  57.                 nc.call("sendMsg",null,loginName,msg.text);   
  58.                 msg.text="";   
  59.             }   
  60.                
  61.                
  62.         ]]>   
  63.     </mx:Script>   
  64.     <mx:HBox width="100%">   
  65.         <mx:VBox width="200" height="100%">   
  66.             <mx:Label text="用户列表:"/>   
  67.             <mx:List id="chatList" width="200" height="400"  labelField="userName" cornerRadius="7"/>   
  68.         </mx:VBox>   
  69.         <mx:VBox  width="100%">   
  70.         <mx:HBox id="loginPanel"  width="100%" height="100%">   
  71.             <mx:TextInput id="userName"/>   
  72.             <mx:Button label="登陆" id="loginBtn" click="sendLogin();"/>   
  73.         </mx:HBox>   
  74.             <mx:TextArea id="chatContent" width="250" height="400"/>   
  75.             <mx:HBox width="100%" height="100%">   
  76.                 <mx:TextInput id="msg"/>   
  77.                 <mx:Button label="发送消息" id="sendBtn" click="sendMessage();" enabled="false"/>   
  78.             </mx:HBox>   
  79.         </mx:VBox>   
  80.     <mx:VBox>   
  81. </mx:VBox>   
  82.     </mx:HBox>   
  83. </mx:Application>  
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="vertical" xmlns:com="com.*" backgroundColor="white">
	<mx:Style source="css.css"></mx:Style>
	<mx:Script>
		<![CDATA[
			import com.client.clientInvockObj;
			import mx.controls.TextInput;
			import com.carlcalderon.arthropod.Debug;
			import mx.utils.StringUtil;
			public var nc:NetConnection;
			
			private static const RTMP_URL:String="rtmp://localhost/chatinglist";
			public var loginName:String;
			private var isConnectSuccess:Boolean;
			
			
			private function initApp():void{
				nc=new NetConnection();
				nc.connect(RTMP_URL,loginName);
				nc.addEventListener(NetStatusEvent.NET_STATUS,checkStatus);
				var obj:clientInvockObj=new clientInvockObj(chatList,chatContent);
				nc.client=obj;
			}
			
			private function checkStatus(e:NetStatusEvent):void{
				trace(e.info.code);
				Debug.log(e.info.code,Debug.BLUE);	
				isConnectSuccess=(e.info.code=="NetConnection.Connect.Success");
				if(isConnectSuccess){
					nc.call("getMsg",new Responder(getMsgResult,getMsgFault));
					loginBtn.enabled=false;
					sendBtn.enabled=true;
					Debug.log("client connect success!");
					
				}
			}
			
			private function getMsgResult(chatMsgArray:Array):void{
				Debug.log("callBack:");
				for(var i:uint=0;i<chatMsgArray.length;i++){
					chatContent.text+=chatMsgArray[i]+"\n";
				}
			}
			
			private function getMsgFault():void{
				
			}
			
			public function sendLogin():void{
				if(StringUtil.trim(userName.text).length>0){
					loginName=userName.text;
					initApp();
				}
			}
			
			public function sendMessage():void{
				nc.call("sendMsg",null,loginName,msg.text);
				msg.text="";
			}
			
			
		]]>
	</mx:Script>
	<mx:HBox width="100%">
		<mx:VBox width="200" height="100%">
			<mx:Label text="用户列表:"/>
			<mx:List id="chatList" width="200" height="400"  labelField="userName" cornerRadius="7"/>
		</mx:VBox>
		<mx:VBox  width="100%">
		<mx:HBox id="loginPanel"  width="100%" height="100%">
			<mx:TextInput id="userName"/>
			<mx:Button label="登陆" id="loginBtn" click="sendLogin();"/>
		</mx:HBox>
			<mx:TextArea id="chatContent" width="250" height="400"/>
			<mx:HBox width="100%" height="100%">
				<mx:TextInput id="msg"/>
				<mx:Button label="发送消息" id="sendBtn" click="sendMessage();" enabled="false"/>
			</mx:HBox>
		</mx:VBox>
	<mx:VBox>
</mx:VBox>
	</mx:HBox>
</mx:Application>

 

 

还有一个用于绑定到客户端NetConnection的client类,供FMS调用:

 

 

Java代码 复制代码
  1. package com.client   
  2. {   
  3.     import mx.controls.List;   
  4.     import mx.controls.TextArea;   
  5.        
  6.     public class clientInvockObj   
  7.     {   
  8.         private var chatList:List;   
  9.         private var chatContent:TextArea;   
  10.         public function clientInvockObj(list:List,chatContent:TextArea)   
  11.         {   
  12.             this.chatList=list;   
  13.             this.chatContent=chatContent;   
  14.         }   
  15.            
  16.         public function getUserList(userList:Array):void{   
  17.                 chatList.dataProvider=userList;   
  18.             }   
  19.            
  20.         public function getMsgInfo(msg:String):void{   
  21.             chatContent.text+=msg+"\n";   
  22.         }   
  23.     }   
  24. }  
package com.client
{
	import mx.controls.List;
	import mx.controls.TextArea;
	
	public class clientInvockObj
	{
		private var chatList:List;
		private var chatContent:TextArea;
		public function clientInvockObj(list:List,chatContent:TextArea)
		{
			this.chatList=list;
			this.chatContent=chatContent;
		}
		
		public function getUserList(userList:Array):void{
				chatList.dataProvider=userList;
			}
		
		public function getMsgInfo(msg:String):void{
			chatContent.text+=msg+"\n";
		}
	}
}

 

 

 

下面是FMS服务端的:

 

 

Java代码 复制代码
  1. application.onAppStart=function(){   
  2.     trace("App started");   
  3.     this.chatMsgArray=new Array();   
  4.     this.userListArray=new Array();   
  5. }   
  6.   
  7. application.onConnect=function(client,userName){   
  8.     trace(" try  connect ")   
  9.     if(checkOnline(userName)){   
  10.         this.rejectConnection(client);   
  11.         return;   
  12.     }   
  13.     this.acceptConnection(client);   
  14.     trace("connected");   
  15.     client.userName=userName;   
  16.     trace(userName);   
  17.     application.userListArray.push(userName);   
  18.     sendUserList();   
  19.     sendMsgToClient("欢迎 "+userName+"进入聊天室.");   
  20.        
  21.     client.getMsg=function(){   
  22.         trace("response client");   
  23.         return application.chatMsgArray;   
  24.     }   
  25.        
  26.     client.sendMsg=function(loginUser,msg){   
  27.         trace("ClientName:"+loginUser);   
  28.         var chatInfo=loginUser+"--说:"+msg+"\n";   
  29.         application.chatMsgArray.push(chatInfo);   
  30.         sendMsgToClient(chatInfo);   
  31.     }   
  32. }   
  33.   
  34. application.onDisconnect=function(client){   
  35.     trace("用户:"+client.userName+"----下线.");   
  36.     removeLeftUser(client.userName);   
  37.     sendUserList();   
  38.     sendMsgToClient("用户:"+client.userName+"----下线.");   
  39. }   
  40.   
  41. function removeLeftUser(userName){   
  42.     for(var i=0;i<application.userListArray.length;i++){   
  43.         if(application.userListArray[i]==userName){   
  44.             application.userListArray.splice(i,1);   
  45.         }   
  46.     }   
  47. }   
  48.   
  49.   
  50.   
  51.   
  52.   
  53.   
  54.   
  55.   
  56.   
  57.   
  58.   
  59. function sendMsgToClient(chatInfo){   
  60.     var leng=application.clients.length;   
  61.     for(var i=0;i<leng;i++){   
  62.         application.clients[i].call("getMsgInfo",null,chatInfo);   
  63.     }   
  64. }   
  65.   
  66. function sendUserList(){   
  67.     var leng=application.clients.length;   
  68.     trace("client num:"+leng);   
  69.     for(var i=0;i<leng;i++){   
  70.         trace("getUserList----"+i);   
  71.         application.clients[i].call("getUserList",null,application.userListArray);   
  72.     }   
  73. }   
  74.   
  75. function checkOnline(userName){   
  76.     var len=application.userListArray.length;   
  77.     for(var i=0;i<len;i++){   
  78.         if(application.userListArray[i]==userName){   
  79.             return true;   
  80.         }   
  81.     }   
  82.     return false;   
  83. }  
application.onAppStart=function(){
	trace("App started");
	this.chatMsgArray=new Array();
	this.userListArray=new Array();
}

application.onConnect=function(client,userName){
	trace(" try  connect ")
	if(checkOnline(userName)){
		this.rejectConnection(client);
		return;
	}
	this.acceptConnection(client);
	trace("connected");
	client.userName=userName;
	trace(userName);
	application.userListArray.push(userName);
	sendUserList();
	sendMsgToClient("欢迎 "+userName+"进入聊天室.");
	
	client.getMsg=function(){
		trace("response client");
		return application.chatMsgArray;
	}
	
	client.sendMsg=function(loginUser,msg){
		trace("ClientName:"+loginUser);
		var chatInfo=loginUser+"--说:"+msg+"\n";
		application.chatMsgArray.push(chatInfo);
		sendMsgToClient(chatInfo);
	}
}

application.onDisconnect=function(client){
	trace("用户:"+client.userName+"----下线.");
	removeLeftUser(client.userName);
	sendUserList();
	sendMsgToClient("用户:"+client.userName+"----下线.");
}

function removeLeftUser(userName){
	for(var i=0;i<application.userListArray.length;i++){
		if(application.userListArray[i]==userName){
			application.userListArray.splice(i,1);
		}
	}
}











function sendMsgToClient(chatInfo){
	var leng=application.clients.length;
	for(var i=0;i<leng;i++){
		application.clients[i].call("getMsgInfo",null,chatInfo);
	}
}

function sendUserList(){
	var leng=application.clients.length;
	trace("client num:"+leng);
	for(var i=0;i<leng;i++){
		trace("getUserList----"+i);
		application.clients[i].call("getUserList",null,application.userListArray);
	}
}

function checkOnline(userName){
	var len=application.userListArray.length;
	for(var i=0;i<len;i++){
		if(application.userListArray[i]==userName){
			return true;
		}
	}
	return false;
}

 

对不住大家,代码都没有写注释,因为跟我前面的那篇几乎一样,所以大家不明白可以参看前面的那篇.

 

 

  • 974e6cf2-fec5-3c2d-8c75-aa5d912e5542-thumb
  • 描述:
  • 大小: 94.2 KB
  • B0548296-ea81-3b0a-81de-dfc125ac3ac8-thumb
  • 描述:
  • 大小: 22.6 KB
分享到：
| Flex连接FMS实现用户列表（使用SharedObje ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    FMS+FLEX-----使用远程共享对象实现多人实时在线聊天

    FMS+FLEX-----使用远程共享对象实现多人实时在线聊天 说明：这是我在网上看到的，收集并整理了一下。 因为我的积分不多了，所以虽然不是原创，但还是要一点资源分的。大家见谅。 压缩包中有说明文档和源码。说明...

    FMS聊天室下载FMS

    【FMS聊天室下载FMS】相关知识点详解 FMS（Flash Media Server）是由Adobe公司开发的一款流媒体服务器软件，主要用于实时音频、视频的发布和交互。它支持HTTP Live Streaming (HLS)、RTMP（Real Time Messaging ...

    fms.rar_flex_flex and fms_fms_fms rtmp_fms flex

    标题"Fms.rar_flex_flex and fms_fms_fms rtmp_fms flex"和描述中的关键词揭示了这个压缩包包含的是与Adobe Flex和Flash Media Server（FMS）相关的项目资源，主要用于创建一个实时通信应用，例如聊天室。Flex是一种...

    JUKI重机DDL-9000C-FMS-WB-PBN中文说明书.pdf

    《JUKI重机DDL-9000C-FMS-WB-PBN中文说明书》是针对JUKI公司的一款高端缝纫设备DDL-9000C-FMS-WB-PBN的操作指南，主要涵盖该设备的技术规格、操作方法、维护保养等方面的信息。以下是该设备的一些关键知识点： 1. *...

    Flex +FMS实现视频聊天

    Flex+FMS写的视频聊天，在本机亲测通过。但唯一不足得是在别的机子上连接不成功。我也不知道为什么。望有才之士能完善。huzhaohui1992@qq.com 如能完善，请给我邮箱一份，在下感激不尽。

    Flex和Fms3打造在线聊天室 源码和文档

    Flex和FMS3是构建实时互动应用程序的强大工具，尤其适合创建在线聊天室这样的实时通信平台。这个源码和文档集合提供了详细的步骤和技术说明，帮助开发者理解如何利用这些技术实现一个功能完备的聊天室。 Flex是一种...

    PyPI 官网下载 | mypy-boto3-fms-1.11.11.0.tar.gz

    PyPI上的资源“mypy-boto3-fms-1.11.11.0.tar.gz”是一个Python库，用于加强Boto3库的类型检查功能，确保代码更加健壮和易于维护。 Boto3是AWS（Amazon Web Services）官方的Python SDK，它允许开发者轻松地与AWS...

    简易聊天室flash多人聊天 FMS实现

    【标题】"简易聊天室flash多人聊天 FMS实现"揭示了这个项目的核心是构建一个基于Flash的多人在线聊天系统，采用FMS（Flash Media Server）作为后台技术来实现实时的通信功能。Flash是一种广泛应用于网页上的多媒体...

    FLEX资源------Flash Media Managment Server中文版下载

    本文将深入探讨FMS的功能、应用以及中文版的特点。 FMS的核心功能在于其强大的媒体处理能力，它能有效地分发、管理和优化多媒体内容。它支持多种格式，如Flash Video (FLV) 和H.264，使得内容能够流畅地在各种设备...

    流媒体服务器---fms3教程

    4. 互动功能：提供数据消息传递，实现用户间的交互，如聊天室、游戏等。 5. 安全性：FMS3提供访问控制、加密等安全措施，保护内容不被非法访问。 四、FMS3应用开发 1. Flex SDK：使用Flex SDK可以创建与FMS3交互的...

    Python库 | mypy-boto3-fms-1.10.42.1.tar.gz

    1. 完善的类型定义：此版本为FMS的所有API调用提供了详细的类型定义，增强了代码的可读性和可维护性。 2. 错误检测：mypy-boto3-fms可以帮助开发者在调用FMS API时，提前发现并修复可能的类型错误。 3. 更新的API...

    数据库课程设计_L-FMS-Website-Static-Pages.zip

    数据库课程设计_L-FMS-Website-Static-Pages

    Python库 | aws-cdk.aws-fms-1.138.0.tar.gz

    总之，aws-cdk.aws-fms-1.138.0是Python开发者在AWS环境中实施云安全策略的得力助手，它通过编程的方式提高了安全策略的部署效率和一致性，让开发者能够更专注于创新，而不是繁琐的安全管理任务。对于那些重视安全并...

    Python库 | mypy-boto3-fms-1.16.9.0.tar.gz

    《Python库mypy-boto3-fms：强化类型检查与AWS FMS集成》 Python作为一门强大且灵活的编程语言，其丰富的库生态系统是其深受开发者喜爱的重要原因。在众多的Python库中，mypy-boto3-fms是一个值得关注的工具，它...

    FMS聊天室+AS3.0

    【标题】"FMS聊天室+AS3.0"是一个基于Adobe Flash Media Server (FMS) 和...通过深入学习和分析这些源代码，开发者不仅可以掌握如何利用FMS和AS3.0创建聊天室，还可以借鉴其设计模式和最佳实践，提高自己的编程技能。

    PyPI 官网下载 | aws-cdk.aws-fms-1.106.0.tar.gz

    标题中的"PyPI 官网下载 | aws-cdk.aws-fms-1.106.0.tar.gz"表明这是一个在Python Package Index (PyPI) 官网上可以找到的软件包，名为`aws-cdk.aws-fms-1.106.0`，并且是以`.tar.gz`格式提供的。`aws-cdk`是Amazon ...

    Python库 | mypy-boto3-fms-1.17.70.post2.tar.gz

    这个库是针对AWS（Amazon Web Services）的Financial Management Services（FMS）的一个类型检查工具，用于增强Boto3库的类型安全性和开发体验。Boto3是Amazon官方提供的Python SDK，它允许开发者轻松地与AWS服务...

    PyPI 官网下载 | mypy-boto3-fms-1.14.8.0.tar.gz

    标题中的“PyPI 官网下载 | mypy-boto3-fms-1.14.8.0.tar.gz”指的是这个资源是从Python的官方包管理器PyPI（Python Package Index）上下载的一个压缩包，名为“mypy-boto3-fms-1.14.8.0.tar.gz”。PyPI是Python...

    FMS制作聊天室例子

    4. **实时通信**：FMS的RTMP协议使得聊天室可以实现实时通信，用户发送的消息能即时被其他在线用户看到，增强了互动性。 5. **数据共享**：除了音频和视频流，FMS还支持数据共享。在聊天室中，用户发送的文字信息...

Magicbox
Global site tag (gtag.js) - Google Analytics