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

            Error

            C++博客 首頁 新隨筆 聯系 聚合 管理
              217 Posts :: 61 Stories :: 32 Comments :: 0 Trackbacks
            網關服務器入網流程:
            s1.連接網關管理器
            s2.上報自身信息給網關管理器
            s3.從網關管理器獲取自己的管理信息
            *s4.按照管理信息預分配好需要的資源
            s5.網關服務器打開客戶端監聽端口
            s6.網關服務器開始轉發“管理器”和客戶端的數據
            *網關服務器完全不理解來自客戶端的數據(對客戶端而言是透明的)
            *網關服務器和“管理器”之間存在協議棧,有五個高級命令:轉發,廣播轉發,T下線1,T下線2,關閉網關
            *網關服務器會定時給“管理器”發送心跳請求ping
            *網關服務器會維護客戶端狀態機:Freed、Starting、InUse、Stoping
            GateWayServer抽象網關邏輯以及和管理器的連接,處理管理器命令,并且轉發客戶端和管理器的消息
            GWClient抽象網關到客戶端連接,負責處理網關和客戶端的邏輯
            網關啟動后,GateWayServer會打開監聽端口,當新的連接上來以后,會創建一個新的GWClient對象,并且將新的socket連接郊游GWClient管理。GWClient管理客戶端和網關服務器之間的通訊數據:接受到客戶端的數據會交由GameWayServer對象轉發到指定的管理器,GameWayServer也會將管理器發送給客戶端的數據交由GWClient發送到客戶端。
            即在網關服務器內部:GWClient做為客戶端的代理,GateWayServer做為管理器(邏輯服務器)的代理。
            // 禁用nagles算法
            int nodelay = 1;
            if(ACE_OS::setsockopt(new_handle,IPPROTO_TCP, TCP_NODELAY,(char*)&nodelay,sizeof(nodelay))==-1)
            {
            ACE_ERROR( ( LM_ERROR, ACE_TEXT("Set socket TCP_NODELAY failed!!\n")) );
            }
            缺陷:
            1.缺少對客戶端的安全檢測,也許是放到后面的邏輯服務器上去做了。不能排除惡意連接,或者誤操作的連接,所有的連接都被accept上來,然后做數據交換。
            2.數據的分發上,好像一個網關服務器只能對應一個管理器(邏輯服務器)
            3.網關只能標識到連接(SettionID是用戶邏輯無關的),無法識別到具體邏輯客戶端
            嘗試做低級抽象:
            IGateWayClientAccpetor
              OnClientAccept
            IGateWay2ClientSession
              SessionID
              OnConnect
              OnRead
              OnWrite
            IGateWay2ManagerSession
              SessionID
              OnConnect
              OnRead
              OnWrite
              
            IGateWayDataRouter
              OnAccessRouting(IGateWay2ClientSession)
              OnAccessRouting(IGateWay2ManagerSession)
              OnGateWay2ClientSessionRead(來自客戶端的數據,當前代碼下,會轉發給唯一的管理器處理)
              OnGateWay2ManagerSession(來自管理器的數據,如果是需要轉發給客戶端的數據,會包含有客戶端SessionId)

            協議概覽:
            網關管理服務器 協議:
            enum EGWMgrMsgType
            {
            GWMMT_Msg, // Route server msg to clients.
            GWMMT_MsgAll, // Route server msg to all clients.
            GWMMT_Droped, // *A client has been droped by manager( actively or disconnect ack ).
            GWMMT_DropedDiscard, // *A client has been droped by manager( actively or disconnect ack ).
            GWMMT_Shutdown, // Shutdown gateway server.
            GWMMT_Max,
            };
            GWMMT_Msg: 轉發消息到指定客戶端
            GWMMT_MsgAll: 轉發廣播消息到全部客戶端
            GWMMT_Droped: 網關管理器T掉指定客戶端
            GWMMT_DropedDiscard: 網關管理器T掉指定客戶端
            GWMMT_Shutdown: 關閉網關服務器
            ---------------------------------------------------------------------------------------
            網關服務器 協議:
            enum EGWSVMsgType
            {
            GWSMT_CLJoin, // New client join.
            GWSMT_CLDisconnected, // Client disconnected.
            GWSMT_Msg, // Route client message to server.
            GWSMT_Ping, // gateway ping message to server.
            GWSMT_Max,
            };
            GWSMT_CLJoin: 新連接客戶端
            GWSMT_CLDisconnected: 客戶端連接斷開
            GWSMT_Msg: 將客戶端的消息轉發到服務器
            GWSMT_Ping: 網關服務器到邏輯服務器的ping
            -----------------------------------------------------------------------------------
            網關服務器消息頭:
            struct GWMsgHdr
            {
            GWMsgHdr( u_int type, u_int len ):type_( type ), data_len_(len){}
            u_int type_; // Msg type.
            u_int data_len_; //
            };
            ------------------------------------------------------------------------------------
            網關上報給網關管理器的自身信息
            struct GWLocalInfo  // 監聽客戶端連接的endpoint
            {
            u_int addr_; // Gateway listen address.
            u_short port_;
            };
            ------------------------------------------------------------------------------------
            網關從網關管理器接受的信息
            struct GWInfo
            {
            u_int id_; // Gateway server id.
            u_int cl_num_; // Client num.
            };

            設計特點:
            1.啟動參數通過內存共享,本地,可以被其他程序訪問到,也許直接被共享到集群了,沒有深入去看
            posted on 2015-03-15 22:24 Enic 閱讀(293) 評論(0)  編輯 收藏 引用 所屬分類: 從零開始寫棋牌游戲平臺
            国产日韩久久久精品影院首页| 一本久久综合亚洲鲁鲁五月天亚洲欧美一区二区 | 99久久综合国产精品二区| www亚洲欲色成人久久精品| 久久精品中文字幕大胸| 久久精品亚洲中文字幕无码麻豆 | 久久香蕉国产线看观看乱码| 久久久不卡国产精品一区二区| 久久久久青草线蕉综合超碰| 久久久国产精品亚洲一区| 久久免费香蕉视频| 狠狠色噜噜狠狠狠狠狠色综合久久| 伊人久久精品线影院| 亚洲国产另类久久久精品黑人| 热re99久久精品国产99热| 性色欲网站人妻丰满中文久久不卡| 91久久九九无码成人网站| 精品国产乱码久久久久久1区2区 | 久久综合久久美利坚合众国 | 亚洲AV无码久久精品蜜桃| 伊人久久综合热线大杳蕉下载| 伊人久久精品无码二区麻豆| 久久av高潮av无码av喷吹| 四虎国产精品免费久久5151| 久久精品国产网红主播| 中文字幕久久久久人妻| 欧美精品乱码99久久蜜桃| 精品久久人人妻人人做精品| 国产亚洲婷婷香蕉久久精品| 久久夜色精品国产亚洲| 99久久成人国产精品免费| 久久精品国产清高在天天线| 亚洲精品乱码久久久久久蜜桃不卡 | 国产一区二区精品久久岳| 久久亚洲高清观看| 99久久精品免费看国产| 99久久精品九九亚洲精品| 久久久久人妻一区精品| 无码任你躁久久久久久老妇App| 一本色道久久综合狠狠躁篇| 色妞色综合久久夜夜|