• <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++博客 首頁 新隨筆 聯(lián)系 聚合 管理
              217 Posts :: 61 Stories :: 32 Comments :: 0 Trackbacks
            相關(guān)UML:


            代碼分析:
            首先CQueueServiceEvent這個名字很有誘惑,,,你感覺他是一個事件,其實不是。它實際的功能應(yīng)該是一個帶打包功能的事件隊列,,,或者說是一個像指定的類似EventQueue的東東中投遞事件。從接口上看,這個東東能投遞TimerEvent  DataBaseEvent  SocketAcceptEvent  SocketReadEvent  SocketCloseEvent
            應(yīng)為它本身持有一個CQueueService指針,所以本身并不負責(zé)數(shù)據(jù)管理,只負責(zé)打包并添加到CQueueService實例中去。

            先看定時器事件:
             1    //定時器事件
             2    bool PostTimerEvent(WORD wTimerID, WPARAM wBindParam)
             3    {
             4        //效驗參數(shù)
             5        ASSERT(m_pIQueueService!=NULL);
             6        if (m_pIQueueService==NULL) return false;
             7
             8        //緩沖鎖定
             9        CThreadLockHandle BufferLockHandle(&m_BufferLock);
            10
            11        //投遞消息
            12        NTY_TimerEvent * pTimerEvent=(NTY_TimerEvent *)m_cbBuffer;
            13        pTimerEvent->wTimerID=wTimerID;
            14        pTimerEvent->wBindParam=wBindParam;
            15        m_pIQueueService->AddToQueue(EVENT_TIMER,m_cbBuffer,sizeof(NTY_TimerEvent));
            16
            17        return true;
            18    }
            嗯哼,代碼質(zhì)量很高哈,,,
            入口都有斷言在debug階段幫助暴露錯誤,斷言之后還有if語句再次判斷,這樣即使release版本錯誤也不會被漏掉,,,
            關(guān)于事件的封裝,在這里其實已經(jīng)分層了,,,

            這里是第一層:
            1struct tagDataHead
            2{
            3    WORD                            wDataSize;                            //數(shù)據(jù)大小
            4    WORD                            wIdentifier;                        //類型標識
            5    DWORD                            dwInsertTime;                        //插入時間
            6}
            ;
            這一層實際上是由CDataStorage負責(zé)打包管理,在CQueueServiceEvent執(zhí)行PostTimerEvent操作的時候會在內(nèi)部調(diào)用CQueueService的add最終調(diào)用到CDataStrorage的Add來打包數(shù)據(jù),這里的結(jié)構(gòu)也是非常像網(wǎng)絡(luò)數(shù)據(jù)包|- len -|- type -|- data -|。
            在來看Post這一層做的數(shù)據(jù)打包:
            1//定時器事件
            2struct NTY_TimerEvent
            3{
            4    WORD                            wTimerID;                            //定時器 ID
            5    WPARAM                            wBindParam;                            //綁定參數(shù)
            6}
            ;
            |- len -|- type -|- sub protocl -|。
            其他事件的打包過程都是類似的:
             1//數(shù)據(jù)庫請求事件
             2struct NTY_DataBaseEvent
             3{
             4    WORD                            wIndex;                                //對象索引
             5    WORD                            wRoundID;                            //對象標識
             6    WORD                            wRequestID;                            //請求標識
             7}
            ;
             8
             9//網(wǎng)絡(luò)應(yīng)答事件
            10struct NTY_SocketAcceptEvent
            11{
            12    WORD                            wIndex;                                //連接索引
            13    WORD                            wRoundID;                            //連接標識
            14    DWORD                            dwClientIP;                            //連接地址
            15}
            ;
            16
            17//網(wǎng)絡(luò)讀取事件
            18struct NTY_SocketReadEvent
            19{
            20    WORD                            wIndex;                                //連接索引
            21    WORD                            wRoundID;                            //連接標識
            22    WORD                            wDataSize;                            //數(shù)據(jù)大小
            23    CMD_Command                        Command;                            //命令信息
            24}
            ;
            25
            26//網(wǎng)絡(luò)關(guān)閉事件
            27struct NTY_SocketCloseEvent
            28{
            29    WORD                            wIndex;                                //連接索引
            30    WORD                            wRoundID;                            //連接標識
            31    DWORD                            dwClientIP;                            //連接地址
            32    DWORD                            dwConnectSecond;                    //連接時間
            33}
            ;


            還是一樣,一句話總結(jié)CQueueServiceEvent:
            線程安全的接受各種異步事件,并打包封裝好以后插入到關(guān)聯(lián)的制定IQueueService中.



            posted on 2011-06-02 14:36 Enic 閱讀(1655) 評論(0)  編輯 收藏 引用 所屬分類: 網(wǎng)狐棋牌源碼分析
            亚洲精品无码久久久影院相关影片| 色88久久久久高潮综合影院| 一级女性全黄久久生活片免费| 亚洲成色WWW久久网站| 国产精品青草久久久久婷婷| 国产精品一区二区久久精品无码 | 久久久国产打桩机| 久久青青草原国产精品免费| 日韩亚洲国产综合久久久| 99999久久久久久亚洲| 久久人人青草97香蕉| 99热精品久久只有精品| 人妻少妇久久中文字幕一区二区| 精品久久人人妻人人做精品| 久久久亚洲欧洲日产国码二区 | 综合久久久久久中文字幕亚洲国产国产综合一区首| 久久久国产打桩机| 亚洲精品无码久久久久AV麻豆| 国产成人久久AV免费| 国产成人精品综合久久久| 久久人人超碰精品CAOPOREN| 青青草国产精品久久| 久久精品午夜一区二区福利| 久久精品国产亚洲AV香蕉| 久久亚洲电影| 久久亚洲中文字幕精品一区四| 国产一区二区三区久久| 精品久久无码中文字幕| 亚洲va中文字幕无码久久不卡| 国产成人无码精品久久久性色| 久久青青草原亚洲av无码| 无码8090精品久久一区| 热RE99久久精品国产66热| 久久精品无码一区二区三区免费 | 91精品国产高清久久久久久国产嫩草 | 一本色综合久久| 欧美精品丝袜久久久中文字幕| 精品人妻伦一二三区久久| 国产成人精品久久亚洲高清不卡 | 国内精品九九久久久精品| 久久精品国产久精国产思思|