• <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国内精品自在现线| 狼狼综合久久久久综合网| 久久久久久久久久久久中文字幕 | 漂亮人妻被中出中文字幕久久 | 久久久久成人精品无码中文字幕 | 精品国产91久久久久久久a| 婷婷久久综合| 亚洲AV无码久久精品蜜桃| 好属妞这里只有精品久久| 欧美一区二区三区久久综合| 性欧美大战久久久久久久久| 午夜精品久久久久久中宇| 久久亚洲精品中文字幕| 国产精品久久午夜夜伦鲁鲁| 99re久久精品国产首页2020| 婷婷久久综合九色综合九七| 伊人久久大香线蕉AV一区二区 | 国产成人精品久久一区二区三区av | 欧洲人妻丰满av无码久久不卡| 午夜精品久久久久久99热| 国产麻豆精品久久一二三| 99久久精品国产综合一区| 久久久久久亚洲Av无码精品专口| 国产国产成人精品久久| 狠狠色伊人久久精品综合网| 久久久久久久91精品免费观看| 久久99精品久久久久婷婷| 国产福利电影一区二区三区久久久久成人精品综合 | 国产精品99久久久久久董美香| 久久久WWW成人| 久久美女人爽女人爽| 麻豆一区二区99久久久久| 青青青伊人色综合久久| 色综合久久中文字幕综合网| 久久香蕉超碰97国产精品| 亚洲综合精品香蕉久久网97| 久久天天躁狠狠躁夜夜躁2014| 久久亚洲天堂| 国产精品久久99|