囯产精品久久久久久久久蜜桃,久久频这里精品99香蕉久,日本欧美久久久久免费播放网

用Zmq實現網關與游戲服全互連

用Zmq實現網關與游戲服全互連

（金慶的專欄）

Zeromq無需bind, connect次序，可以在對方bind之前就connect, 可實現服務器以任意順序啟動。
Zmq有自動重連功能，可實現服務器故障重啟不影響整個系統。

萬神服務器內部連接采用了Zmq, 并可能在未來將客戶端服務器之間的連接也改用為Zmq。

萬神的網關（Gtw，Gateway）與游戲服（Gs, Game Server）之間是M*N的全互連關系。
即M個網關，N個游戲服，每個Gtw連接所有Gs, 每個Gs連接所有Gtw.
采用Zmq的Router-Router模式，Gtw和Gs分別只需一個zmq::socket_t, 就可以實現M*N互連。

Router-Router互連的決竅是至少其中一方須設置ZMQ_IDENTITY.
因為Gs是穩定的服務器，數量固定，所以設為bind方，并設置 ZMQ_IDENTITY.
Gtw是可任意添加的服務器，所以設為connect方，使用自動ZMQ_IDENTITY.
ZMQ_IDENTITY就是socket的名字。
Gtw向Gs發送消息時，須先指定對方的名字，然后才能發送到指定的Gs.
接收時，也會附帶獲取對方的名字。
Gtw是自動ZMQ_IDENTITY，每次連接Gs, Gs就會自動為其設定一個隨機的名字。
Gtw重啟后，希望其名字與前次運行的名字不相同，所以設為自動ZMQ_IDENTITY.

Gs端只需一次bind:
    zmq::socket_t sktGs(context, ZMQ_ROUTER);
    sktGs.setsockopt(ZMQ_IDENTITY, ...);
    sktGs.bind("tcp://*:12345");

Gtw端須連接多個Gs, Gs的IP和端口是配置的：
    zmq::socket_t sktGtw(context, ZMQ_ROUTER);
    BOOST_FOREACH(int nGsId, setGsIds);
    {
        sktGtw.connect(Fmt("tcp://%s:%u",
            config.GetGsHost(nGsId),
            config.GetGsPort(nGsId)));
    }

Gtw重啟后，應該假設此時Gs可能尚未存在，須不斷向Gs發Init消息。
Gs應答InitAck之后就可以確認與Gs之間的連接建立成功。
Gs的名字是從配置文件讀取的。

Gs重啟后，將等待Gtw的消息，如果是Init, 則應答InitAck.
如果是其他消息，則發送Reset, 讓Gtw重置。
Gtw接到Reset后，將發送Init, 并等待InitAck.

如此，Gs與Gtw將不存在啟動順序關系，并且服務器可任意重啟而不影響其他服務器。

posted on 2013-11-26 17:25 金慶閱讀(3178) 評論(0) 編輯收藏引用所屬分類: 2. 網游開發

只有注冊用戶登錄后才能發表評論。
【推薦】100%開源！大型工業跨平臺軟件C++源碼提供，建模，組態！

相關文章: How are dtLinks created in NavMesh UE4 Blueprint Multiple Event BeginPlay 第9代游戲主機 Canvas Scaler 的3種模式幀同步是否允許客戶端指定命令幀號 rpc應答太快造成請求超時測試 tolua 例子 TestErrorStack lua變量缺少local造成unity死鎖 C# tolua 之間互傳 byte[] Unity使用異步grpc

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜