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

核心提示： 实现了发送消息（将消息添加到远程共享对象并更新远程共享对象的属性值），如果有多个客户端连接到该远程共享对象，FMS3系列(六)：使用远程共享对象实现多人实时在线聊天(4)，这时就回触发远程共享对象的同步事件，通过同步事件处理方法就可以将远程共享对象中的数据同步到客户端，如下代码块：以下为引

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

以下为引用的内容：

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端代码：

以下为引用的内容：

<?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>