青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

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ù)里會(huì)this.connector從opts里取connector,或者默認(rèn)為connectors/sioconnector.js。(connector的實(shí)現(xiàn)sioconnector和hybridconnector)

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

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

        'connection'事件處理為:

        將connection關(guān)聯(lián)一個(gè)session,監(jiān)聽socket的message事件,接受到message時(shí)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的實(shí)現(xiàn)

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

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

(1)hybrid/switcher.js

    switcher構(gòu)造函數(shù)接受一個(gè)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,這個(gè)add會(huì)向外emit 'connection'(事件參數(shù)為原生socket),并向socket emit 'data'事件;否則非http,則調(diào)用tcpprocessor.add,這個(gè)add會(huì)以剛才的原生socket為參數(shù)創(chuàng)建一個(gè)tcpsocket,同時(shí)向tcpprocessor emit 'connection'(事件參數(shù)為原生tcpsocket)、向這個(gè)原生socket emit 'data'事件。

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

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

(2)hybridsocket.js

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

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

 

(三)server組件

    官方描述如下“模塊使服務(wù)器具備處理客戶端請求的能力。該模塊主要實(shí)現(xiàn)了filter服務(wù),根據(jù)當(dāng)前服務(wù)器類型,加載對應(yīng)handler/目錄下的代碼,并決定一個(gè)請求應(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)系。每個(gè)socket有個(gè)對應(yīng)的Session,驗(yàn)證用戶身份后就將他們綁定。

    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)造時(shí)傳入的那個(gè)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里每個(gè)元素是個(gè)數(shù)組,所以每個(gè)uid可以對應(yīng)多個(gè)session?(這個(gè)以后再具體了解下)

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

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

 

(三)session的使用

    看了下chatofpomelo里,是在connector/handler/entryHandler.js里的enter函數(shù),直接用了session.bind。簡單用法就是在自己項(xiàng)目的驗(yàn)證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 閱讀(1459) 評論(0)  編輯 收藏 引用 所屬分類: 開源nodejs

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

導(dǎo)航

統(tǒng)計(jì)

留言簿(1)

隨筆分類(77)

隨筆檔案(58)

me

基友

同行

業(yè)界前輩

最新隨筆

搜索

積分與排名

最新評論

閱讀排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            乱码第一页成人| 一区二区三区四区五区在线| 久久成人一区| 亚洲视频一区二区免费在线观看| 亚洲经典三级| 中日韩男男gay无套| 在线视频精品一| 亚洲欧美一区二区精品久久久| 午夜国产精品影院在线观看| 久久久久国产一区二区三区四区| 欧美一级夜夜爽| 蜜臀av国产精品久久久久| 亚洲精品久久在线| 国产精品99久久不卡二区| 久久精品视频在线| 欧美三级视频在线播放| 韩日精品视频| 亚洲自拍电影| 欧美激情精品久久久久久黑人| 99精品热6080yy久久| 久久久99爱| 国产精品伦理| 亚洲国产精品va| 亚洲免费视频网站| 亚洲第一页中文字幕| 亚洲欧美视频在线观看| 欧美高清不卡在线| 黄色国产精品一区二区三区| 亚洲欧美成人一区二区在线电影| 免费欧美高清视频| 欧美一区二区高清在线观看| 欧美日韩亚洲一区三区| 亚洲精品1区| 久久躁狠狠躁夜夜爽| 亚洲一区中文| 国产精品啊啊啊| 日韩一区二区精品视频| 麻豆精品在线播放| 久久国产福利国产秒拍| 国产精品久久久一区二区| 99re成人精品视频| 久久大逼视频| 久久久99久久精品女同性| 亚洲大黄网站| 久久久精品午夜少妇| 欧美亚州韩日在线看免费版国语版| 国产自产在线视频一区| 亚洲欧美在线免费观看| 日韩网站在线观看| 欧美国内亚洲| 亚洲精品婷婷| 亚洲精选久久| 欧美视频导航| 亚洲一区二区欧美日韩| 亚洲另类黄色| 欧美视频导航| 午夜精品一区二区三区电影天堂| 亚洲精品欧美日韩| 欧美日韩国产精品自在自线| 亚洲另类自拍| 日韩视频免费观看高清在线视频 | 影音先锋亚洲视频| 久久婷婷人人澡人人喊人人爽| 欧美一区二区三区免费观看视频| 国产麻豆精品视频| 久久国产精品久久久| 欧美一区二区视频在线| 精久久久久久| 亚洲国产裸拍裸体视频在线观看乱了中文| 久久这里有精品视频| 91久久精品国产91性色tv| 亚洲国产日韩欧美在线动漫| 欧美片第一页| 午夜久久黄色| 久久午夜精品一区二区| 亚洲精品日韩在线| 国产精品99久久久久久久久| 国产精品中文在线| 久久综合免费视频影院| 欧美好吊妞视频| 亚洲一区视频| 久久人人97超碰人人澡爱香蕉| 亚洲人成艺术| 亚洲香蕉视频| 亚洲国产高清视频| 国产精品99久久不卡二区| 国产农村妇女毛片精品久久麻豆| 久久精品一区二区国产| 欧美成ee人免费视频| 亚洲综合精品自拍| 久久久五月婷婷| 亚洲综合欧美| 免费观看国产成人| 欧美亚洲免费| 欧美精品粉嫩高潮一区二区| 欧美一区二区三区四区在线 | 欧美xxx成人| 一区二区三区欧美在线| 欧美一区二区三区男人的天堂| 亚洲第一天堂av| 亚洲综合日韩在线| 日韩一级网站| 久久婷婷丁香| 久久精品欧美| 国产精品欧美激情| 最新成人av网站| 伊人狠狠色丁香综合尤物| 一区二区三区国产精华| 亚洲激情婷婷| 久久久7777| 久久国产精品色婷婷| 欧美特黄一级大片| 亚洲精品视频在线播放| 亚洲国产精品第一区二区| 欧美一级久久久久久久大片| 制服丝袜激情欧洲亚洲| 欧美成人国产一区二区| 免费的成人av| 好吊成人免视频| 性久久久久久久久久久久| 亚洲一区二区三区色| 欧美精品在线视频观看| 亚洲国产欧美久久| 亚洲欧洲免费视频| 免费观看久久久4p| 欧美激情第一页xxx| 黄网动漫久久久| 久久国产免费| 麻豆成人av| 亚洲国产精品黑人久久久| 久久久久久午夜| 老色鬼精品视频在线观看播放| 国产在线拍偷自揄拍精品| 香蕉久久国产| 老司机午夜精品视频在线观看| 国产一区二区三区四区在线观看| 亚洲欧美日韩国产成人| 久久激情综合网| 韩日欧美一区二区三区| 久久人体大胆视频| 欧美激情亚洲自拍| 在线视频精品一区| 国产精品日产欧美久久久久| 午夜激情综合网| 久久深夜福利免费观看| 国内一区二区在线视频观看| 久久久天天操| 亚洲国产欧美精品| 亚洲视频一区二区在线观看 | 亚洲男人av电影| 国产精品美腿一区在线看| 亚洲一区二区在线| 久久久久国产精品一区二区| 在线观看欧美激情| 欧美激情视频一区二区三区不卡| 亚洲精品久久久久久久久久久久| 在线视频你懂得一区| 国产欧美精品一区二区色综合| 久久精品99国产精品日本| 欧美激情黄色片| 亚洲精品一区中文| 亚洲午夜av在线| 久久精品国产免费观看| 一区二区在线观看视频| 欧美88av| 亚洲专区欧美专区| 欧美激情一区| 欧美在线播放一区| 91久久国产综合久久| 国产精品日韩一区| 欧美成人午夜剧场免费观看| 亚洲一区二区三区在线看| 欧美高清在线| 欧美中在线观看| 夜夜爽www精品| 国产一区二区三区无遮挡| 欧美精品一区二区蜜臀亚洲| 亚洲欧美日韩中文视频| 亚洲福利国产| 久久久噜噜噜久久人人看| 亚洲视频在线观看免费| 在线观看欧美日韩| 国产精品尤物福利片在线观看| 欧美二区在线| 久久国产欧美精品| 亚洲一区在线观看免费观看电影高清| 免费美女久久99| 久久久精品tv| 午夜久久tv| 午夜欧美大片免费观看| 9l国产精品久久久久麻豆| 在线电影院国产精品| 国产美女精品视频| 欧美天堂亚洲电影院在线播放| 久久色在线播放| 久久国产加勒比精品无码| 亚洲欧美成人一区二区在线电影| 最新国产の精品合集bt伙计| 免费成人黄色片| 久久久夜夜夜|