0

我有一个问题,在客户端(我正在使用 flex)。当用户断开连接并重新连接时,我在共享对象处获得空对象引用。我是否需要重新创建(即重新初始化)共享对象。

任何帮助表示赞赏。

问题是:当两个用户登录并在文本输入中插入一些数据并单击发送时,数据同步没有问题。但是,当其中一个用户断开连接并重新连接时,该用户将不会同步获得任何(更新的)数据。

下面是示例代码

主目录

        var user_array=Array();
        var obj;
        var obj3;
        var obj1;
        application.onAppStart= function()
        {
            trace("OnAppStart");
        }

        application.onConnect = function(client, user_name)
        { 

        application.acceptConnection(client);
        monitorConnection(client);

        var so1=SharedObject.get("hello");
        client.name=user_name;
        trace("OnConnect");
        obj=client;
        user_array.push(user_name);
        so1.setProperty("names",user_array);
        obj1=user_array;
        //  callthiss(obj);


        client.sendSomething = function(name)
        {

            for(var a=0; a<application.clients.length; a++)
            {
                //for(var j=0;j<user_array.length;j++)
                //{
                    if(application.clients[a].name == name)
                    {

                        application.clients[a].call("receiveSomething",null,name);

                    }

                //}
            }
        }

        client.Onclick=function(name)
        {
            var so2=SharedObject.get("so2");
            so2.setProperty("so2",name);
        }
        };


        clientPingResponder = function(client) {

        this.onResult = function(res) {
           // trace("ClientPingResponder.onResult Received: " + res);
            clearInterval(client.cleanupTaskId);
        } 

        this.onStatus = function(info) {
            //trace("ClientPingResponder.onStatus Received: " + info);
        }
        };
        monitorConnection = function(client) {

        client.isAlive = function() {
            trace("client.isAlive has been fired");
            client.cleanupTaskId = setInterval(client.dead, 2 * 1000);
            client.call("pings", new clientPingResponder(client));
        }

        client.dead = function() {
          //  trace("cleanupTaskId: " + client.cleanupTaskId);
           // trace("monitorTaskId: " + client.monitorTaskId);

            clearInterval(client.cleanupTaskId);
            clearInterval(client.monitorTaskId);

            trace("ghost connection has been detected");

            application.disconnect(client);
        }

        client.monitorTaskId = setInterval(client.isAlive, 7*1000);
        trace("detected");
        }


        application.onDisconnect=function(client)
        {

            trace("DisConnect"+client.name);
        //  trace(client.name);
        }

客户端代码(Flex)

    <?xml version="1.0" encoding="utf-8"?>
    <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" >
    <mx:Script>
        <![CDATA[
            internal var nc:NetConnection;
            internal var so1:SharedObject;
            internal var so2:SharedObject;
            internal var str:Responder=new Responder(str1);
            internal function on_login():void
            {

                if(username!=null)
                {
                    nc=new NetConnection();
                    nc.client=this;
                    nc.connect("rtmp://localhost/Sample_2",username.text);
                    nc.addEventListener(NetStatusEvent.NET_STATUS, netstatusHandler);
                }

            }

            internal function netstatusHandler(e:NetStatusEvent):void
            {   
                switch(e.info.code)
                {
                    case "NetConnection.Connect.Success":
                    status_1.text="Connected";
                    trace("so1:: "+so1);
                    if(so1==null)
                    {
                        create_SO();
                    }
                    break;

                    case "NetConnection.Connect.Rejected":
                    status_1.text="Rejected";

                    break;
                    case "NetConnection.Connect.Failed":
                    status_1.text="Failed";
                    break;
                    case "NetConnection.Connect.AppShutdown":
                    status_1.text="AppShutDown";
                    break;
                    case "NetConnection.Connect.NetworkChange":
                    status_1.text="network Change";
                    break;
                    case "NetConnection.Connect.Closed":
                    status_1.text="Disconnected";
                    break;
                }

            }

        public function pings():void
        {
            trace("a ping call from the server has been received");
        }

            internal function create_SO():void
            {
                so1=SharedObject.getRemote("hello",nc.uri,false);
                so1.connect(nc);
                so1.addEventListener(SyncEvent.SYNC, on_hello);

                so2=SharedObject.getRemote("so2",nc.uri,false);
                so2.connect(nc);
                so2.addEventListener(SyncEvent.SYNC, so2Sync);
            }   

            internal var ar:Array=new Array();

            internal function on_hello(e:SyncEvent):void
            {
                    var d:*=e.target.data;
                    for(var s:* in d) 
                    {
                        trace("SYNC::: "+d[s]);
                        ar= d[s] as Array;  
                    }
            }

            internal function str1(strr:String):void
            {
                trace("str: "+strr);
            }
            public function onclient():void
            {
                trace("ss: ");
            }
            public function onclicka():void
            {
                for(var i:int=0;i<ar.length;i++)
                {
                    if(ar[i]!=username.text)
                    {
                        trace("CALL SEND SOME: "+ar[i]);
                        nc.call("sendSomething",null,ar[i]);
                    }
                }

            }

            //public function receiveSomething(str:String):String
            public function receiveSomething(stsr:String):String
            {
                trace("receiveSomething: "+stsr);
                    rec.text="receiveSomething: "+str;
                return stsr; 

            }
            public function ondisconnect():void{
                nc.close();
            }

            public function onreconnect():void
            {
                nc.connect("rtmp://localhost/Sample_2",username.text);
            }

            public function ButtonClick(event:MouseEvent):void
            {
                nc.call("Onclick",null,sendtxt.text);
            }

            public function so2Sync(event:SyncEvent):void
            {
                var output=event.target.data;
                var a:Array= new Array();
                for(var n in output)
                {
                    var obj=output[n];
                    a.push(obj);
                    dg.dataProvider=a;

                }

            }


        ]]>
    </mx:Script>

        <mx:TextInput x="10" y="10" id="username"/>
        <mx:Button x="188" y="10" label="Login" id="login" click="on_login()"/>
        <mx:Button id="Dis" label="Disconnect" click="ondisconnect()" y="40"/>
        <mx:Button id="re" label="reconnect" click="onreconnect()" y="70"/>

        <mx:Text x="379" y="12" text="Text" id="status_1"/>
        <mx:Text x="289" y="12" text="Status"/>
        <mx:TextInput x="438" y="180" id="sendtxt"/>
        <mx:Button x="632" y="180"  label="Send" click="ButtonClick(event)"/>
        <mx:List x="434" y="222" id="dg"></mx:List> 

    </mx:Application>
4

0 回答 0