FMS3系列(六):使用远程共享对象(SharedObject)实现多人时时在线聊天(Flex | Flash)

      FMS开发中,经常会使用共享对象来同步用户和存储数据。对于实现广播文字信息实现聊天的支持非常强大,还可以跟踪用户的时时动作,在开发Flash多人在线游戏中的应用也非常广阔。

      在使用FMS开发共享对象时需要注意,只有使用Flash Media Interactive Server或Flash Media Development Server这两个版本时才能够创建和使用远程共享对象,来实现多客户端的应用程序之间共享数据。如果是使用的Flash Media Streaming Server版FMS是不能创建远程共享对象的,只能创建本地共享对象,类似于传统Web开发中的Cookie。

      使用共享对象(SharedObject)来开发时时文字聊天其实是很简单的,SharedObject可以跟踪和广播消息,连接到SharedObject中的其中任何一个客户端改变了SharedObject中的数据,SharedObject就会将最新的数据广播到连接到它的所有客户端。从某种角度可以理解为远程的SharedObject是一个同步很多用户的一个网络中心。下图为官方发布的SharedObject广播消息图:

                  

      

      本文是通过实现一个简单的文字聊天来介绍FMS中的远程共享对象的使用,首先在FMS中建立好应用程序名,既在FMS的安装目录下的applications下建立一文件夹,来作为共享对象应用程序使用,如下图所示:

                  

      如上图,SharedObjectApp就是为实现聊天建立的一个FMS应用文件夹,其下的sharedobjects/_definse_为成功创建远程对象后自动生成的目录。如果你所创建的为永久性的远程共享对象,则在该目录下还将会有一个以.fso为扩展名的远程共享对象文件。

      要创建远程共享对象,首先需要连接到FMS应用,然后通过SharedObject.getRemote()方法来完成远程共享对象的创建,通过给远程共享对象添加同步事件监听,远程共享对象里的数据一但发生改变就会自动触发该事件,来实现同步数据。

private function onClick():void
{
    nc 
= new NetConnection();
    nc.connect(
"rtmp://192.168.1.101/SharedObjectApp");
    nc.addEventListener(NetStatusEvent.NET_STATUS,onNetStatusHandler);
}

private function onNetStatusHandler(evt:NetStatusEvent):void
{
    
this.panChat.title+="("+evt.info.code+")";
    
if(evt.info.code=="NetConnection.Connect.Success")
    {
        
//创建一个远程共享对象
        
//参数:远程共享对象的名称 | 连接到的应用程序的URI | 远程共享对象是否为永久远程对象
        so = SharedObject.getRemote("RemotingSO",nc.uri,true); //将生成SO.fso
        
//远程对象(SharedObject)同步事件的监听
        so.addEventListener(SyncEvent.SYNC,onSyncHandler);
        
//远程共享对象连接到服务器
        so.connect(nc);
    }
}

 

      上面代码块实现了连接到FMS应用,成功连接后便创建远程共享对象(RemotingSO),同时还为远程共享对象添加了同步事件监听,通过onSyncHandler方法来处理事件。

      在继续实现聊天功能前,我们需要编写一个通用方法,该方法提供将一个数组里的数据转移到另一个数组,如下代码块:

private function convertArrayCollection(arrNew:ArrayCollection,arrOld:ArrayCollection):void
{
     arrNew.removeAll();
  
     
for(var i:int=0;i<arrOld.length ;i++)
     {
          arrNew.addItemAt(arrOld.getItemAt(i),i);
     }
}

 

      下面我们通过发送消息的流程开始,首先是发送消息,通过自定义Message类来封装消息内容:

 1 package flex.VO
 2 {
 3     public class Message
 4     {
 5         public var NickName:String;  //用户呢称
 6         public var Context:String;    //消息内容
 7         
 8         public function Message()
 9         {
10         }
11     }
12 }

 

      在发送消息的时候,通过此Message类来封装发送消息的数据,然后将其发布到FMS中的远程共享对象,更新远程共享对象中的数据。

private function onSend():void
{
    var tempCollection:ArrayCollection 
= new ArrayCollection();
    
if(so.data.msgCollection != null)
    {
        convertArrayCollection(tempCollection,so.data.msgCollection 
as ArrayCollection);
    }
    
    var msg:Message 
= new Message();
    msg.NickName 
= this.txtUser.text;
    msg.Context 
= this.txtMessage.text;
    tempCollection.addItem(msg);
    //更新远程共享对象中的属性值
    so.setProperty(
"msgCollection",tempCollection);
    
    
this.txtMessage.text="";
}

 

      实现了发送消息(将消息添加到远程共享对象并更新远程共享对象的属性值),如果有多个客户端连接到该远程共享对象,这时就回触发远程共享对象的同步事件,通过同步事件处理方法就可以将远程共享对象中的数据同步到客户端。如下代码块:

private function onSyncHandler(evt:SyncEvent):void
{
    
if(so.data.msgCollection!=null)
    {
        var tempCollection:ArrayCollection 
= new ArrayCollection();
        convertArrayCollection(tempCollection,so.data.msgCollection 
as ArrayCollection);
        
        
this.msgText.text="";
        
for(var index:int=0;index<tempCollection.length;index++)
        {
            var message:Object 
= tempCollection.getItemAt(index);
            var displayMessage:String 
= message.NickName+"说:"+message.Context;
            
this.msgText.text += displayMessage + "\n";
        }
    }
}

 

      如上便完成了整个文字聊天的功能开发,主要应用到的技术点就是通过远程共享对象来同步用户数据。下面为完整的Flex端代码:

ContractedBlock.gifExpandedBlockStart.gif完整的Flex端代码
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" fontSize="12">
    
<mx:Script>
        
<![CDATA[
            import mx.controls.Alert;
            import mx.collections.ArrayCollection;
            import flex.VO.Message;
            
            
private var nc:NetConnection;
            
private var so:SharedObject;
            
            
private function onClick():void
ExpandedBlockStart.gifContractedBlock.gif            
{
                nc 
= new NetConnection();
                nc.connect(
"rtmp://192.168.1.101/SharedObjectApp");
                nc.addEventListener(NetStatusEvent.NET_STATUS,onNetStatusHandler);
            }

            
            
private function onNetStatusHandler(evt:NetStatusEvent):void
ExpandedBlockStart.gifContractedBlock.gif            
{
                
this.panChat.title+="("+evt.info.code+")";
                
if(evt.info.code=="NetConnection.Connect.Success")
ExpandedSubBlockStart.gifContractedSubBlock.gif                
{
                    
//创建一个远程共享对象
                    
//参数:远程共享对象的名称 | 连接到的应用程序的URI | 远程共享对象是否为永久远程对象
                    so = SharedObject.getRemote("RemotingSO",nc.uri,true); //将生成SO.fso
                    
//远程对象(SharedObject)同步事件的监听
                    so.addEventListener(SyncEvent.SYNC,onSyncHandler);
                    
//远程共享对象连接到服务器
                    so.connect(nc);
                }

            }

            
            
private function onSyncHandler(evt:SyncEvent):void
ExpandedBlockStart.gifContractedBlock.gif            
{
                
if(so.data.msgCollection!=null)
ExpandedSubBlockStart.gifContractedSubBlock.gif                
{
                    var tempCollection:ArrayCollection 
= new ArrayCollection();
                    convertArrayCollection(tempCollection,so.data.msgCollection 
as ArrayCollection);
                    
                    
this.msgText.text="";
                    
for(var index:int=0;index<tempCollection.length;index++)
ExpandedSubBlockStart.gifContractedSubBlock.gif                    
{
                        var message:Object 
= tempCollection.getItemAt(index);
                        var displayMessage:String 
= message.NickName+"说:"+message.Context;
                        
this.msgText.text += displayMessage + "\n";
                    }

                }

            }

            
            
private function onSend():void
ExpandedBlockStart.gifContractedBlock.gif            
{
                var tempCollection:ArrayCollection 
= new ArrayCollection();
                
if(so.data.msgCollection != null)
ExpandedSubBlockStart.gifContractedSubBlock.gif                
{
                    convertArrayCollection(tempCollection,so.data.msgCollection 
as ArrayCollection);
                }

                
                var msg:Message 
= new Message();
                msg.NickName 
= this.txtUser.text;
                msg.Context 
= this.txtMessage.text;
                tempCollection.addItem(msg);
                
//更新远程共享对象中的属性值
                so.setProperty("msgCollection",tempCollection);
                
                
this.txtMessage.text="";
            }

            
            
private function convertArrayCollection(arrNew:ArrayCollection,arrOld:ArrayCollection):void
ExpandedBlockStart.gifContractedBlock.gif            
{
                 arrNew.removeAll();
              
                 
for(var i:int=0;i<arrOld.length ;i++)
ExpandedSubBlockStart.gifContractedSubBlock.gif                 
{
                      arrNew.addItemAt(arrOld.getItemAt(i),i);
                 }

            }

        ]]
>
    
</mx:Script>
    
<mx:Panel x="22" y="22" width="482" height="260" layout="absolute"  id="panChat"
        title
="文字聊天">
        
<mx:TextArea x="0" y="0" width="100%" height="100%" backgroundColor="#FCDADA" id="msgText"/>
        
<mx:ControlBar>
            
<mx:TextInput width="53" id="txtUser"/>
            
<mx:Label text="说:"/>
            
<mx:TextInput width="195" id="txtMessage"/>
            
<mx:Button label="Send" click="onSend()"/>
            
<mx:Button label="Connection" fontWeight="normal" click="onClick()"/>
        
</mx:ControlBar>
    
</mx:Panel>
    
</mx:Application>

 

      程序运行截图如下:

            

                                                  图1----FMS状态图

            

                                                图2----聊天客户端(张三)

                  

                                          图3----聊天客户端(李四)

            

 

      如上图,在FMS应用目录下创建了一后缀为.fso的文件,这就是永久性的远程共享对象文件名。在使用远程共享的时候,根据实际需求来确定是否使用永久性的远程共享对象,一般做聊天应用我个人建议使用临时远程共享对象(不生成.fso文件),要存储聊天记录可以通过其他方式来保存。

      详细大家可以查看官方提供的文档,在FMS的安装目录下就有,我的是D:\Adobe\Flash Media Server 3\documentation\flashmediaserver_AS3LR\index.html

 

      本文就介绍于此,如文中有什么问题,请大家拍砖指正。本文示例源代码下载

 

版权说明

  本文属原创文章,欢迎转载,其版权归作者和博客园共有。  

  作      者:Beniao

 文章出处:http://beniao.cnblogs.com/  或  http://www.cnblogs.com/

        

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/268581.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

表驱动法——直接访问表示例1

表驱动法——直接访问表示例1 《代码大全》看到“表驱动法”一章&#xff0c;以下是表驱动法的第一个方法——直接访问表 import java.util.Scanner; import java.util.Calendar;class DaysPerMonth {public static void main(String[] args) {System.out.println("输入年…

linux原理 培训,Linux容器技术原理和使用

1.1 隔离和共享在一个多员共用的开发环境或者一台服务器运行多个逻辑隔离的服务器进程。谁的运行环境也不希望影响到另一个谁。也就是一个物理机器需要虚拟化出多个环境或者容器。通过提供一种创建和进入容器的方式&#xff0c;操作系统让应用程序就像在独立的机器上运行一样&a…

模态框里使IMG的Src能动态显示

<IMG οnclick"var actionMath.random();this.srcvcode.aspx?actionaction.toString();" />点击图片&#xff0c;只要vcode.aspx能动态输出不同的内容&#xff0c;则IMG控件里的图片也会变动&#xff0c;在模态框里也有效

github和gitlab仓库一起使用

github是网络公有代码仓库&#xff0c;一般用于私人代码托管&#xff0c;而gitlab一般是企业搭建的内部代码仓库。工作期间&#xff0c;我们都会同时用到这两个仓库。可公司邮箱与个人邮箱是不同的&#xff0c;由此产生的 SSH key 也是不同的&#xff0c;这就造成了冲突 。如何…

linux端口被攻击,Linux 常见攻击端口封杀表

Linux常见攻击端口封杀表# Vi /etc/sysconfig/iptables# INPUT-A INPUT -p tcp --dport 135 -j REJECT-A INPUT -p udp --dport 135 -j REJECT-A INPUT -p tcp --dport 136 -j REJECT-A INPUT -p udp --dport 136 -j REJECT-A INPUT -p tcp --dport 137 -j REJECT-A INPUT -p u…

Exchange 2007服务器启动后,Information Store和System Attendant服务不能自动启动

Exchange 2007服务器启动后&#xff0c;Information Store和System Attendant服务不能自动启动 SA和Information服务不会自动启动&#xff0c;手动启动正常1) 在Exchange服务器上添加下面的注册表键值来延迟SA的启动时间HKLM\System\CurrentControlSet\Services\MSExchangeSA\P…

报表简介

帆软报表、华企报表、润乾报表系统、杰表 、数巨报表 1.帆软报表&#xff08;FineReport&#xff09;软件下载地址&#xff1a;http://www.finereport.com/products/trial软件介绍FineReport报表软件是帆软软件&#xff08;中国&#xff09;公司自主研发的一款纯Java编写的企业…

巨型帧linux检测,linux – KVM来宾和主机之间的巨型帧?

我正在尝试为KVM来宾和主机系统之间的存储通信实现9000字节MTU.主机有一个桥接器(br1),其MTU为9000字节&#xff1a;host# ip link show br18: br1: mtu 9000 qdisc noqueue state UPlink/ether fe:54:00:50:f3:55 brd ff:ff:ff:ff:ff:ffinet 172.16.64.1/24 brd 172.16.64.255…

访问服务器端数据

有时你要连接的服务并非是SOAP风格的。其他常用的框架可以结合使用HTTP Get和Post方法来返回数据。使用<mx:HTTPService>标签可以让你访问这种类型的WEB服务。使用HTTP Post和Get方法操作的WEB服务可以理解为REST服务。在很多情况下&#xff0c;使用HTTP Post方法。使用H…

《大话设计模式》--模板模式

题目&#xff1a;相同的两份试卷&#xff0c;甲乙两个人做&#xff0c;答案不同 public class TestPager {public void question() {System.out.println("题目&#xff1a;答案是A、B、C、D中哪一个&#xff1f;");System.out.println("答案&#xff1a;" …

linux 股票指南针,IOS开发入门之ios指南针

本文将带你了解IOS开发入门之ios指南针&#xff0c;希望本文对大家学IOS有所帮助参考http://blog.sina.com.cn/s/blog_4a37054201013nhr.html可运行的代码如下1.拖拽ImageView ,关联变量到.h中2.代码如下//// ViewController.h// SouthDemo//// Created by xiao7 on 14/10/2…

一条命令解决系统N多故障

这是我刚在论坛上看到的&#xff0c;所以我把它收藏在我的博客中&#xff0c;因为以前笔记本总遇到这样的问题&#xff0c;不知道能管用吗&#xff0c;待测试。 1&#xff1a; 使用Windows操作系统的人有时会遇到这样的错误信息&#xff1a;「“0X????????”指令引用的…

【Java】二维码生成,QRcode

QRcode jar包下载地址&#xff1a;http://swetake.com/qrcode/java/qr_java.html 解析的工具可以参考 zxing 代码如下 package erweima;import java.awt.Color;import java.awt.Graphics2D;import java.awt.image.BufferedImage;import java.io.File;import java.io.IOExceptio…

linux db2 ssl,IBM DB2 Content Manager V83与手工配置SSL

此文章主要向大家描述的是IBM DB2 Content Manager V83系统中&#xff0c;手工配置SSL的实际操作步骤&#xff0c;在IBM DB2 Content Manager V83系统中&#xff0c;一般的情况下都需要使用SSL协议。 在安装IBM DB2 Content Manager V83系统时。安装程序可以完成对IBM HTTP Ser…