`

使用远程共享对象实现多人实时在线聊天 转

    博客分类:
  • FMS
阅读更多

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广播消息图:

111

 

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

111

 

如上图,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端代码:

 

以下为引用的内容:
<?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>

 

 

 

程序运行截图如下:

 

 

图1----FMS状态图

 

 

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

 

 

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

 

 

 

 

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

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

本文示例源代码下载:http://files.cnblogs.com/beniao/Flash/FlexChat.rar

 

分享到:
评论

相关推荐

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

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

    基于JAVA RMI的聊天室

    - **服务器端(Server)**: 这个项目中的服务器端是RMI的核心,它负责接收客户端的连接请求,创建并注册远程对象,管理所有在线用户,并处理客户端发送的聊天消息。服务器端通常会有一个主类启动RMI服务,一个远程...

    FMS案例开发[整理].pdf

    此外,案例开发还包括了如何创建可交互的FMS连接、基于FMS的流媒体播放程序、在线视频录制与回放以及如何利用远程共享对象实现多人实时在线聊天的详细步骤。这些系列文章深入浅出地讲解了从零开始构建这样一个系统的...

    在线白板设计与实现

    在这个系统中,用户可以通过聊天室进行文字交流,同时利用共享画板进行实时的图形绘制和协作,这在远程教育、团队协作、创意讨论等场景中具有广泛的应用价值。 首先,我们来看看这个系统的技术栈。"Java"是主要的...

    JSP视频聊天程序最简单代码实现功能

    - **多人聊天**:通过添加更多的RTCPeerConnection实例,可以扩展到多人视频聊天。 - **屏幕共享**:集成屏幕共享功能,增强协作体验。 - **媒体录制**:允许用户记录聊天过程,供后续回放。 在实际开发中,...

    WebRTC-master.zip_adventureonc_friendlyxn8_webrtc_视频聊天_转发:iOS w

    - WebRTC由Google发起,其目标是让网页浏览器具备实时音视频通信能力,实现P2P(点对点)的数据共享。 - 核心组件包括:getUserMedia(获取本地媒体流)、RTCPeerConnection(建立和维护两个浏览器间的连接)和...

    用于网络会议系统,聊天系统的视频语音控件

    在网络视频会议系统中,它可以支持多人同时参与,实现屏幕共享、白板协作等功能,满足远程协作的需求。 标签“网络视频”、“聊天室”、“视频会议”进一步细化了控件的应用领域。网络视频涉及到视频编码、解码技术...

    red5入门教程

    而简单的聊天程序则展示了Red5在实时通信中的应用,通过发送和接收文本消息,实现多人在线聊天。 附录部分将介绍用于Red5开发的各种工具的使用,帮助初学者更高效地进行开发工作。 总的来说,这个Red5入门教程旨在...

    聊天模仿的QQ基本的对话功能

    模仿的QQ也实现了这一功能,用户可以方便地截取屏幕,选择是否添加标注、箭头等元素,然后一键发送给聊天对象,这对于远程协作和问题解决尤其有用。 3. **语音与视频通话**:虽然描述中未明确提及,但作为完整的...

    Flex3.0学习手册

    ### Flex3.0 学习手册关键知识点综述 ...6. **远程共享对象**: 利用SharedObject实现多人在线聊天。 通过上述内容的学习,读者能够全面掌握Flex3.0的基础知识和技术要点,并能够运用这些技能来开发实际的应用程序。

    flex java red5完全学习手册

    - **共享对象**:通过共享对象实现数据持久化和多用户间的实时数据交换。 - **远程调用**:支持客户端和服务器端之间的远程过程调用。 - **RSTP协议**:使用RSTP协议进行流媒体传输。 Red5的出现填补了开源市场上的...

    archive_PaintChat日本Java画图聊天程序.zip.zip

    从标题来看,我们可以推测这个程序允许用户进行实时的画图交流,类似于白板共享功能,可能是为了促进远程协作或在线教育。 【描述】"archive_PaintChat日本Java画图聊天程序.zip.zip" 没有提供具体的细节,但我们...

    基于Java的远程视频会议系统(系统+论文).zip

    4. **多用户同步**:为了实现多人在线会议,系统需要处理多用户间的同步问题,包括音视频流的同步、共享屏幕内容的同步,以及聊天消息的同步等。 5. **安全机制**:考虑到数据敏感性和隐私保护,系统应包含加密技术...

    Remoting双向通信v1.0

    这个"Remoting双向通信v1.0"可能是一个实现双向通信的软件包或框架,旨在简化远程对象调用的过程,使应用程序能够实时地在两端进行数据交互。 在.NET Remoting中,双向通信(Two-Way Communication)意味着客户端...

    RMIRoom_rmi_

    在多人聊天室的实现中,通常会有一个“房间”概念,即一个聊天的共享空间,用户可以加入或离开这个房间。RMI在此处的作用是将用户的输入消息发送到服务器,并由服务器广播给房间内的所有用户。此外,服务器可能还会...

    windows red5入门教程

    Red5是一款基于Java开发的开源流媒体服务器,与Adobe的FMS(Flash Media Server)类似,提供音频和视频的实时流传输、录制、共享对象、远程调用以及现场直播等功能。它使用RTP/RTSP协议进行流媒体传输,因其开源、...

    基于 Red5 的流媒体服务器的搭建和应用

    Red5能够支持多人在线游戏的实时通信需求,实现玩家间的语音聊天、视频分享等功能。 #### 五、总结 Red5作为一款强大的开源流媒体服务器,不仅能够支持多种流媒体格式的转换和播放,还具备丰富的功能,如录制、...

    Flex与.NET互操作(十二):FluorineFx.Net的及时通信应用(Remote Shared Objects)(三)

    在 Flex 的服务器端,使用 FluorineFx 实现远程共享对象的方式与 Flash Media Server (FMS) 不同。FluorineFx 提供了 `ISharedObjectService` 接口,其中的 `CreateSharedObject()` 方法用于创建远程共享对象。`...

    Flash Media Server 入门教程.doc

    - **Flash聊天室**: 实现多人在线聊天功能,包括文字、语音和视频聊天。 - **在线视频会议**: 提供高质量的音视频通信能力,支持多人参与的在线会议。 - **网络游戏**: 可用于实时传输游戏数据,实现多人在线对战。 ...

    java源码包---java 源码 大量 实例

    2个目标文件,FTP的目标是:(1)提高文件的共享性(计算机程序和/或数据),(2)鼓励间接地(通过程序)使用远程计算机,(3)保护用户因主机之间的文件存储系统导致的变化,(4)为了可靠和高效地传输,虽然用户...

Global site tag (gtag.js) - Google Analytics