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

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

 

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

 

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

 

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

 

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

 

 

      如上便完成了整个文字聊天的功能开发，主要应用到的技术点就是通过远程共享对象来同步用户数据。下面为完整的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
             {
                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);
                }
            }
            
             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";
                    }
                }
            }
            
             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 convertArrayCollection(arrNew:ArrayCollection,arrOld:ArrayCollection): void
             {
                 arrNew.removeAll();
              
                 for(var i:int=0;i<arrOld.length ;i++)
                 {
                      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 >

 

 

 

 

 

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

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

 

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