• <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>

            Sheppard Y

            keep thinking keep coding.

            pomelo0.5.5源碼分析(2)-通信

            2016-07-11 日更新 
            此篇博客已經(jīng)遷移到新博客,并做行文檢查和優(yōu)化排版:
            http://blog.clawz.me/2013/09/05/13-pomelo-read-source-2/

             


            一、客戶端與服務(wù)器的通信

                客戶端的通信在pomelo-client里封裝了。

                服務(wù)器與客戶端的通信在connector里。底層提供websocket、tcp和socket.io三種方式的通信。

            (一)connector組件(components/connector.js)

                組件構(gòu)造函數(shù)里會this.connector從opts里取connector,或者默認(rèn)為connectors/sioconnector.js。(connector的實現(xiàn)sioconnector和hybridconnector)

                組件的start里會將this.server\this.session\this.connection分別映射到app的對應(yīng)的組件上。

                組件的afterStart里this.connector.start,并監(jiān)聽this.connector的'connection'事件。

                    'connection'事件處理為:

                    將connection關(guān)聯(lián)一個session,監(jiān)聽socket的message事件,接受到message時decode message,再將message交給server組件的handle,處理完回調(diào)里再將返回信息在connector組件的send里處理。

                    另外監(jiān)聽session的'bind'事件,處理函數(shù)為,調(diào)用connection.addLoginedUser。

                組件里的send,encode reponse的message,然后交給schedule組件的schedule。

             

            (二)hybridconnector的實現(xiàn)

                connectors/hybridconnector.js以及connectors/hybird。hyrbird實現(xiàn)了原生socket和websocket兩種。

                hybridconnector.start里會this.tcpServer=net.createServer,然后把以這個tcpServer為參數(shù)創(chuàng)建一個switcher。之后在switcher的'connection'事件里將tcpsocket裝進(jìn)hybridsocket。

            (1)hybrid/switcher.js

                switcher構(gòu)造函數(shù)接受一個server參數(shù),并創(chuàng)建this.wsprocessor和this.tcpprocessor。

                switcher監(jiān)聽參數(shù)server的'connection'事件,事件處理函數(shù)里監(jiān)聽原生socket的'data'事件,判斷data是否有http頭,如果有,則調(diào)用wsprocessor.add,這個add會向外emit 'connection'(事件參數(shù)為原生socket),并向socket emit 'data'事件;否則非http,則調(diào)用tcpprocessor.add,這個add會以剛才的原生socket為參數(shù)創(chuàng)建一個tcpsocket,同時向tcpprocessor emit 'connection'(事件參數(shù)為原生tcpsocket)、向這個原生socket emit 'data'事件。

                switcher也監(jiān)聽了this.wsprocessor和this.tcpprocessor的'connection'事件,處理為向switcher自己emit 'connection'。總結(jié),switcher的職責(zé),將socket的字節(jié)流data拼成包,以'message'事件向外emit一個個的完成包msg。

                剛才提到的tcpsocket.js這里處理原生socket的操作。監(jiān)聽了原生socket的'data'、'end'、'error'、'close'事件。例如在'data'處理時,當(dāng)讀入的流長度夠一個包的body后就向tcpsocket emit 'message'。

            (2)hybridsocket.js

                將socket和websocket封裝為統(tǒng)一接口。構(gòu)造函數(shù)里接受一個id和socket參數(shù)。

                hybridsocket監(jiān)聽tcpsocket的'message'事件,將msg decode,之后處理。例如Package.TYPE_DATA類型的msg,就將這個msg再向hybridsocket自己emit一個'message'事件,其他可能是'handshake'或'heartbeat'事件。

             

            (三)server組件

                官方描述如下“模塊使服務(wù)器具備處理客戶端請求的能力。該模塊主要實現(xiàn)了filter服務(wù),根據(jù)當(dāng)前服務(wù)器類型,加載對應(yīng)handler/目錄下的代碼,并決定一個請求應(yīng)該是在當(dāng)前服務(wù)器處理還是應(yīng)該路由給其他服務(wù)器處理。”,下面看看代碼流程。

                組件的start里初始化filter和handler。

             

            二、服務(wù)器之間的通信

             

             

            三、框架調(diào)用

             

            四、session

            (一)session組件(components/session.js)

                session組件直接用的common/service/sessionService。

            (二)sessionService

            (1)Session(object)

                Session里維護(hù)的socket和user信息的之間的對應(yīng)關(guān)系。每個socket有個對應(yīng)的Session,驗證用戶身份后就將他們綁定。

                Session構(gòu)造函數(shù)接受參數(shù)socket id\frontendId\socket\service。

                Session通過bind\unbind函數(shù)將uid綁到this.uid里,并emit 'bind'\'unbind'事件。

                Session的set\get函數(shù)來給Session設(shè)取值,由this.settings維護(hù)。

                Session的send\sendBatch都是直接通過構(gòu)造時傳入的那個socket來操作。

            (2)MockLocalSession(object)

            (3)SessionService(object)

                負(fù)責(zé)對Session的管理。構(gòu)造函數(shù)里將this.sessions和this.uidMap初始為空表。

                SessionService的create負(fù)責(zé)new Session,并放到this.sessions里。

                bind\unbind函數(shù)負(fù)責(zé)將傳入的sid\uid對應(yīng)綁定到this.sessions\this.uidMap里。uidMap里每個元素是個數(shù)組,所以每個uid可以對應(yīng)多個session?(這個以后再具體了解下)

                sendMessage\sendMessageByUid根據(jù)sid\uid往對應(yīng)的session或sessions發(fā)消息。

                其他函數(shù)不一一列舉了。

             

            (三)session的使用

                看了下chatofpomelo里,是在connector/handler/entryHandler.js里的enter函數(shù),直接用了session.bind。簡單用法就是在自己項目的驗證uid后自己綁定。

             

            五、pomelo-rpc

            (一)rpc-client

                client.create\mailstation.create\mailstation.mailboxFactory掛載mailbox\

                client.start(callback)\mailstation.start&callback

                client.addProxies(remote-calls)\proxy.create\

            (二)rpc-server

                lib/rpc-server/server將遠(yuǎn)程調(diào)用處理下,加到opts.services里,然后通過gateway來listen端口和處理message。

            posted on 2013-09-05 23:09 Sheppard Y 閱讀(1440) 評論(0)  編輯 收藏 引用 所屬分類: 開源nodejs

            <2013年9月>
            25262728293031
            1234567
            891011121314
            15161718192021
            22232425262728
            293012345

            導(dǎo)航

            統(tǒng)計

            留言簿(1)

            隨筆分類(77)

            隨筆檔案(58)

            me

            基友

            同行

            業(yè)界前輩

            最新隨筆

            搜索

            積分與排名

            最新評論

            閱讀排行榜

            久久久噜噜噜久久中文福利| 久久精品国产亚洲AV不卡| 国内精品伊人久久久久妇| 狠狠色丁香久久婷婷综合_中| 久久成人小视频| 国产精品一区二区久久精品| 91超碰碰碰碰久久久久久综合| 久久久久九九精品影院| 久久人人爽人人爽人人av东京热| 亚洲中文字幕无码久久精品1 | 国产精品99久久99久久久| 亚洲嫩草影院久久精品| 久久天天躁狠狠躁夜夜不卡| 久久人人爽人人爽人人片AV不| 国产免费久久精品丫丫| 人妻久久久一区二区三区| 精品久久久久国产免费 | 99久久精品国产毛片| 久久精品综合网| 国内精品伊人久久久久网站| 日本强好片久久久久久AAA | 久久婷婷激情综合色综合俺也去 | 国产精品亚洲综合专区片高清久久久| 日韩久久久久中文字幕人妻| 国产一级持黄大片99久久| 亚洲精品无码久久久影院相关影片| 精品久久久久久久久久中文字幕| 激情伊人五月天久久综合| 四虎国产精品成人免费久久| 欧美久久久久久精选9999| 国内精品久久九九国产精品| 久久精品无码专区免费东京热| 久久人妻AV中文字幕| 日本欧美国产精品第一页久久| 99久久精品免费看国产| 91精品国产高清91久久久久久| 久久久久亚洲AV无码专区首JN | 久久99精品国产麻豆蜜芽| 久久精品国产精品青草| www性久久久com| 国产91色综合久久免费|