• <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ù)程序

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

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

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

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

             

            下面是我寫(xiě)的一個(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 暗夜教父 閱讀(897) 評(píng)論(0)  編輯 收藏 引用 所屬分類: erlang

            <2009年9月>
            303112345
            6789101112
            13141516171819
            20212223242526
            27282930123
            45678910

            常用鏈接

            留言簿(2)

            隨筆分類

            隨筆檔案

            文章分類

            文章檔案

            搜索

            •  

            最新評(píng)論

            閱讀排行榜

            評(píng)論排行榜

            91精品国产91久久综合| 精品久久国产一区二区三区香蕉| 国产亚洲婷婷香蕉久久精品| 色偷偷偷久久伊人大杳蕉| 蜜臀av性久久久久蜜臀aⅴ麻豆| 日韩人妻无码一区二区三区久久| www.久久热.com| 久久久久久A亚洲欧洲AV冫 | 亚洲中文字幕伊人久久无码 | 亚洲色大成网站www久久九| 色综合久久久久久久久五月| 久久久91精品国产一区二区三区| 久久精品国产欧美日韩| 亚洲AV日韩精品久久久久久| 精品久久久久久国产免费了| 国产成人精品三上悠亚久久| 久久青青草原国产精品免费| 久久久午夜精品| 亚洲精品乱码久久久久久蜜桃 | 欧美一区二区久久精品| 国产精品久久久久…| 精品久久久久久久久免费影院| 久久99久久99精品免视看动漫| 午夜福利91久久福利| 狠狠精品久久久无码中文字幕| 国产亚洲精品美女久久久| 久久只有这里有精品4| 久久婷婷五月综合色99啪ak| 国产精品久久久久久久| 久久久免费精品re6| 久久久久久精品成人免费图片| 欧美久久久久久精选9999| www.久久99| 久久噜噜电影你懂的| 狠狠色丁香久久综合婷婷| 性欧美丰满熟妇XXXX性久久久| 伊人久久大香线蕉综合网站| 久久久久97国产精华液好用吗| 久久AⅤ人妻少妇嫩草影院| 久久精品无码一区二区app| 99久久无码一区人妻|