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

            

			            		
		
            
	
            

            


            


            
	
					

            
	
	
	
            
		相關UML：


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

            先看定時器事件： 

             1    //定時器事件
             2    bool PostTimerEvent(WORD wTimerID, WPARAM wBindParam)
             3    {
             4        //效驗參數
             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    }
            嗯哼，代碼質量很高哈，，，
            入口都有斷言在debug階段幫助暴露錯誤，斷言之后還有if語句再次判斷，這樣即使release版本錯誤也不會被漏掉，，，
            關于事件的封裝，在這里其實已經分層了，，，

            這里是第一層：
            

            1struct tagDataHead
            2{
            3    WORD                            wDataSize;                            //數據大小
            4    WORD                            wIdentifier;                        //類型標識
            5    DWORD                            dwInsertTime;                        //插入時間
            6}            ;
            這一層實際上是由CDataStorage負責打包管理，在CQueueServiceEvent執行PostTimerEvent操作的時候會在內部調用CQueueService的add最終調用到CDataStrorage的Add來打包數據,這里的結構也是非常像網絡數據包|- len -|- type -|- data -|。
            在來看Post這一層做的數據打包：
            

            1//定時器事件
            2struct NTY_TimerEvent
            3{
            4    WORD                            wTimerID;                            //定時器 ID
            5    WPARAM                            wBindParam;                            //綁定參數
            6}            ;
            |- len -|- type -|- sub protocl -|。
            其他事件的打包過程都是類似的：
            

             1//數據庫請求事件
             2struct NTY_DataBaseEvent
             3{
             4    WORD                            wIndex;                                //對象索引
             5    WORD                            wRoundID;                            //對象標識
             6    WORD                            wRequestID;                            //請求標識
             7}            ;
             8
             9//網絡應答事件
            10struct NTY_SocketAcceptEvent
            11{
            12    WORD                            wIndex;                                //連接索引
            13    WORD                            wRoundID;                            //連接標識
            14    DWORD                            dwClientIP;                            //連接地址
            15}            ;
            16
            17//網絡讀取事件
            18struct NTY_SocketReadEvent
            19{
            20    WORD                            wIndex;                                //連接索引
            21    WORD                            wRoundID;                            //連接標識
            22    WORD                            wDataSize;                            //數據大小
            23    CMD_Command                        Command;                            //命令信息
            24}            ;
            25
            26//網絡關閉事件
            27struct NTY_SocketCloseEvent
            28{
            29    WORD                            wIndex;                                //連接索引
            30    WORD                            wRoundID;                            //連接標識
            31    DWORD                            dwClientIP;                            //連接地址
            32    DWORD                            dwConnectSecond;                    //連接時間
            33}            ;


            還是一樣，一句話總結CQueueServiceEvent：
            線程安全的接受各種異步事件，并打包封裝好以后插入到關聯的制定IQueueService中.



            
	
            
	
	
            
		posted on 2011-06-02 14:36 Enic 閱讀(1655) 評論(0)  編輯 收藏 引用  所屬分類: 網狐棋牌源碼分析 
	
            

            







            
	    
    




            






            

				

            


    
    







            
	   
	



国产精品久久午夜夜伦鲁鲁|
久久精品麻豆日日躁夜夜躁|
久久久久国产精品嫩草影院|
超级97碰碰碰碰久久久久最新|
久久久久久国产精品美女
|
AAA级久久久精品无码区|
国产成人精品白浆久久69|
久久免费美女视频|
久久强奷乱码老熟女|
国产毛片欧美毛片久久久|
久久久精品午夜免费不卡|
久久亚洲精品无码VA大香大香|
国产产无码乱码精品久久鸭
|
尹人香蕉久久99天天拍|
久久综合给久久狠狠97色|
精品久久人人做人人爽综合|
无码人妻精品一区二区三区久久|
久久99精品综合国产首页|
亚洲国产成人精品女人久久久|
蜜臀av性久久久久蜜臀aⅴ|
亚洲精品无码久久不卡|
国产91久久精品一区二区|
99久久精品免费看国产一区二区三区|
国产精品视频久久|
日韩久久久久久中文人妻|
久久99精品国产麻豆蜜芽|
97精品伊人久久大香线蕉app|
午夜肉伦伦影院久久精品免费看国产一区二区三区
|
久久一本综合|
久久高潮一级毛片免费|
99久久婷婷国产综合亚洲|
久久综合噜噜激激的五月天|
久久久国产99久久国产一|
久久一区二区免费播放|
久久久噜噜噜久久中文字幕色伊伊|
国产欧美一区二区久久|
99久久www免费人成精品|
亚洲精品高清一二区久久|
久久亚洲天堂|
久久久久国产一级毛片高清板|
99久久精品免费观看国产|