一、客戶端與服務器的通信
客戶端的通信在pomelo-client里封裝了。
服務器與客戶端的通信在connector里。底層提供websocket、tcp和socket.io三種方式的通信。
(一)connector組件(components/connector.js)
組件構造函數里會this.connector從opts里取connector,或者默認為connectors/sioconnector.js。(connector的實現sioconnector和hybridconnector)
組件的start里會將this.server\this.session\this.connection分別映射到app的對應的組件上。
組件的afterStart里this.connector.start,并監聽this.connector的'connection'事件。
'connection'事件處理為:
將connection關聯一個session,監聽socket的message事件,接受到message時decode message,再將message交給server組件的handle,處理完回調里再將返回信息在connector組件的send里處理。
另外監聽session的'bind'事件,處理函數為,調用connection.addLoginedUser。
組件里的send,encode reponse的message,然后交給schedule組件的schedule。
(二)hybridconnector的實現
connectors/hybridconnector.js以及connectors/hybird。hyrbird實現了原生socket和websocket兩種。
hybridconnector.start里會this.tcpServer=net.createServer,然后把以這個tcpServer為參數創建一個switcher。之后在switcher的'connection'事件里將tcpsocket裝進hybridsocket。
(1)hybrid/switcher.js
switcher構造函數接受一個server參數,并創建this.wsprocessor和this.tcpprocessor。
switcher監聽參數server的'connection'事件,事件處理函數里監聽原生socket的'data'事件,判斷data是否有http頭,如果有,則調用wsprocessor.add,這個add會向外emit 'connection'(事件參數為原生socket),并向socket emit 'data'事件;否則非http,則調用tcpprocessor.add,這個add會以剛才的原生socket為參數創建一個tcpsocket,同時向tcpprocessor emit 'connection'(事件參數為原生tcpsocket)、向這個原生socket emit 'data'事件。
switcher也監聽了this.wsprocessor和this.tcpprocessor的'connection'事件,處理為向switcher自己emit 'connection'。總結,switcher的職責,將socket的字節流data拼成包,以'message'事件向外emit一個個的完成包msg。
剛才提到的tcpsocket.js這里處理原生socket的操作。監聽了原生socket的'data'、'end'、'error'、'close'事件。例如在'data'處理時,當讀入的流長度夠一個包的body后就向tcpsocket emit 'message'。
(2)hybridsocket.js
將socket和websocket封裝為統一接口。構造函數里接受一個id和socket參數。
hybridsocket監聽tcpsocket的'message'事件,將msg decode,之后處理。例如Package.TYPE_DATA類型的msg,就將這個msg再向hybridsocket自己emit一個'message'事件,其他可能是'handshake'或'heartbeat'事件。
(三)server組件
官方描述如下“模塊使服務器具備處理客戶端請求的能力。該模塊主要實現了filter服務,根據當前服務器類型,加載對應handler/目錄下的代碼,并決定一個請求應該是在當前服務器處理還是應該路由給其他服務器處理。”,下面看看代碼流程。
組件的start里初始化filter和handler。
二、服務器之間的通信
三、框架調用
四、session
(一)session組件(components/session.js)
session組件直接用的common/service/sessionService。
(二)sessionService
(1)Session(object)
Session里維護的socket和user信息的之間的對應關系。每個socket有個對應的Session,驗證用戶身份后就將他們綁定。
Session構造函數接受參數socket id\frontendId\socket\service。
Session通過bind\unbind函數將uid綁到this.uid里,并emit 'bind'\'unbind'事件。
Session的set\get函數來給Session設取值,由this.settings維護。
Session的send\sendBatch都是直接通過構造時傳入的那個socket來操作。
(2)MockLocalSession(object)
(3)SessionService(object)
負責對Session的管理。構造函數里將this.sessions和this.uidMap初始為空表。
SessionService的create負責new Session,并放到this.sessions里。
bind\unbind函數負責將傳入的sid\uid對應綁定到this.sessions\this.uidMap里。uidMap里每個元素是個數組,所以每個uid可以對應多個session?(這個以后再具體了解下)
sendMessage\sendMessageByUid根據sid\uid往對應的session或sessions發消息。
其他函數不一一列舉了。
(三)session的使用
看了下chatofpomelo里,是在connector/handler/entryHandler.js里的enter函數,直接用了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將遠程調用處理下,加到opts.services里,然后通過gateway來listen端口和處理message。