• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            教父的告白
            一切都是紙老虎
            posts - 82,  comments - 7,  trackbacks - 0

            轉(zhuǎn)自http://www.javaeye.com/topic/401041


            學(xué)erlang有一段時(shí)間了,現(xiàn)在在維護(hù)一套webim系統(tǒng)
            并打算擴(kuò)展成 webgame 的服務(wù)程序

            在沒有使用包協(xié)議的時(shí)候,遇到好多粘包問題,實(shí)在惱火

            查閱了相關(guān)資料:

            Flash Socket 的 writeUTF() 會(huì)自動(dòng)增加包頭長(zhǎng)度的協(xié)議,剛好對(duì)應(yīng)了
            Erlang的Socket選項(xiàng) {packet,2}

            這使得兩者的通信非常完美,再也不用擔(dān)心粘包什么的問題了

             

            下面是我寫的一個(gè)Flash Socket 接口:SocketBridge.as

            package {   
                
            import flash.display.Sprite;   
                
            import flash.events.*;   
                
            import flash.net.Socket;   
                
            import flash.utils.*;   
                
            import flash.external.ExternalInterface;   
                
            import flash.system.*;   
                
            public class SocketBridge extends Sprite {   
                    Socket.prototype.timeout    
            =3000;   
                    
            private var socket:Socket;   
                    
            public function SocketBridge()   
                    
            {   
                        socket 
            = new Socket();   
                        socket.addEventListener( Event.CONNECT, onConnect );   
                        socket.addEventListener( ProgressEvent.SOCKET_DATA, onDataRecevice);   
                        socket.addEventListener( Event.CLOSE, onClose);   
                        socket.addEventListener( IOErrorEvent.IO_ERROR, onError);    
                           
                        
            if(ExternalInterface.available)   
                        
            {   
                               
                            ExternalInterface.addCallback(
            "socket_connect",socket_connect);   
                            ExternalInterface.addCallback(
            "socket_send",socket_send);   
                            ExternalInterface.addCallback(
            "load_policy",load_policy);   
                        }
               
                    }
               
                    
            public function onError(e):void  
                    
            {   
                        ExternalInterface.call(
            "sb_onerror",e.text);   
                        socket.close();   
                    }
               
                    
            public function load_policy(host:String,port):void  
                    
            {   
                        Security.loadPolicyFile(
            "xmlsocket://"+host+":"+port);     
                    }
               
                       
                    
            public function socket_connect(host:String,port):void  
                    
            {   
                        
            try{   
                            socket.connect(host,port);   
                        }
            catch(e){   
                            ExternalInterface.call(
            "sb_onerror",e.text);   
                        }
               
                    }
               
                       
                    
            public function socket_send(msg:String)   
                    
            {      
                        socket.writeUTF(msg);   
                        socket.flush();   
                    }
               
                       
                    
            private function onConnect(event:Event):void    
                    
            {   
                        ExternalInterface.call(
            "sb_onconnect",true);   
                    }
               
                       
                    
            private function onClose(event:Event):void    
                    
            {   
                        socket.close();   
                        ExternalInterface.call(
            "sb_onclose",true);   
                    }
               
              
                    
            private function onDataRecevice( eventrogressEvent ):void  
                    
            {   
                        var sdata:String;   
                        
            while(socket.bytesAvailable){   
                            sdata 
            = socket.readUTF();   
                            ExternalInterface.call(
            "sb_ondata",sdata);   
                        }
               
                    }
               
              
                }
               
            }
              
            posted on 2009-09-18 12:40 暗夜教父 閱讀(896) 評(píng)論(0)  編輯 收藏 引用 所屬分類: erlang

            <2025年7月>
            293012345
            6789101112
            13141516171819
            20212223242526
            272829303112
            3456789

            常用鏈接

            留言簿(2)

            隨筆分類

            隨筆檔案

            文章分類

            文章檔案

            搜索

            •  

            最新評(píng)論

            閱讀排行榜

            評(píng)論排行榜

            99久久国产亚洲高清观看2024| 久久伊人中文无码| 久久99精品久久久久久动态图 | 欧美与黑人午夜性猛交久久久| 久久久久亚洲AV综合波多野结衣| 无码人妻少妇久久中文字幕| 色综合久久无码中文字幕| 久久精品无码免费不卡| 久久99国产亚洲高清观看首页| 久久久亚洲裙底偷窥综合| 国产女人aaa级久久久级| 久久精品国产91久久麻豆自制| 久久久无码精品亚洲日韩软件| 亚洲精品无码专区久久久| 狠狠人妻久久久久久综合| 国产精品久久久久久久午夜片| 超级碰碰碰碰97久久久久| 亚洲国产精品一区二区三区久久 | 久久亚洲AV成人出白浆无码国产| 亚洲中文字幕伊人久久无码| 国产69精品久久久久777| 久久精品男人影院| 少妇精品久久久一区二区三区| 国产成人综合久久精品尤物| 无码人妻少妇久久中文字幕蜜桃 | 国产A级毛片久久久精品毛片| 久久91精品国产91久| 免费一级做a爰片久久毛片潮| 国产99久久久久久免费看| 国产精品久久久天天影视| 色狠狠久久AV五月综合| 亚洲欧美日韩中文久久| 一本一本久久A久久综合精品 | 色综合久久久久综合99| 国产精品狼人久久久久影院| 久久久国产乱子伦精品作者| 久久不射电影网| 日本精品久久久久中文字幕| 久久无码人妻精品一区二区三区| 国产精品99久久不卡| 国产精品一区二区久久精品无码|