• <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++博客
首頁(yè)
新隨筆
聯(lián)系
聚合

管理

			
			
				

            
	
            
		
            
			
			
			
				 
				217 
				Posts ::
				61 Stories
				::
				32 Comments
				::
				0 Trackbacks
			
		
            
	
            

            

			            		
		
            
	
            

            


            


            
	
					

            
	
	
	
            
		相關(guān)UML：


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

            先看定時(shí)器事件： 

             1    //定時(shí)器事件
             2    bool PostTimerEvent(WORD wTimerID, WPARAM wBindParam)
             3    {
             4        //效驗(yàn)參數(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階段幫助暴露錯(cuò)誤，斷言之后還有if語(yǔ)句再次判斷，這樣即使release版本錯(cuò)誤也不會(huì)被漏掉，，，
            關(guān)于事件的封裝，在這里其實(shí)已經(jīng)分層了，，，

            這里是第一層：
            

            1struct tagDataHead
            2{
            3    WORD                            wDataSize;                            //數(shù)據(jù)大小
            4    WORD                            wIdentifier;                        //類型標(biāo)識(shí)
            5    DWORD                            dwInsertTime;                        //插入時(shí)間
            6}            ;
            這一層實(shí)際上是由CDataStorage負(fù)責(zé)打包管理，在CQueueServiceEvent執(zhí)行PostTimerEvent操作的時(shí)候會(huì)在內(nèi)部調(diào)用CQueueService的add最終調(diào)用到CDataStrorage的Add來(lái)打包數(shù)據(jù),這里的結(jié)構(gòu)也是非常像網(wǎng)絡(luò)數(shù)據(jù)包|- len -|- type -|- data -|。
            在來(lái)看Post這一層做的數(shù)據(jù)打包：
            

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

             1//數(shù)據(jù)庫(kù)請(qǐng)求事件
             2struct NTY_DataBaseEvent
             3{
             4    WORD                            wIndex;                                //對(duì)象索引
             5    WORD                            wRoundID;                            //對(duì)象標(biāo)識(shí)
             6    WORD                            wRequestID;                            //請(qǐng)求標(biāo)識(shí)
             7}            ;
             8
             9//網(wǎng)絡(luò)應(yīng)答事件
            10struct NTY_SocketAcceptEvent
            11{
            12    WORD                            wIndex;                                //連接索引
            13    WORD                            wRoundID;                            //連接標(biāo)識(shí)
            14    DWORD                            dwClientIP;                            //連接地址
            15}            ;
            16
            17//網(wǎng)絡(luò)讀取事件
            18struct NTY_SocketReadEvent
            19{
            20    WORD                            wIndex;                                //連接索引
            21    WORD                            wRoundID;                            //連接標(biāo)識(shí)
            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;                            //連接標(biāo)識(shí)
            31    DWORD                            dwClientIP;                            //連接地址
            32    DWORD                            dwConnectSecond;                    //連接時(shí)間
            33}            ;


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



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

            







            
	    
    




            






            

				

            


    
    







            
	   
	



亚洲中文久久精品无码|
91精品国产9l久久久久|
欧美一级久久久久久久大片|
久久久久99精品成人片三人毛片
|
欧美黑人激情性久久|
97久久超碰国产精品2021|
久久精品中文字幕久久|
久久99精品久久久久久齐齐|
99久久夜色精品国产网站|
麻豆精品久久精品色综合|
久久综合伊人77777|
国产精品久久久久jk制服|
久久精品无码免费不卡|
人妻无码αv中文字幕久久
|
国产精品99久久久精品无码|
久久久久久人妻无码|
一本一本久久a久久精品综合麻豆|
MM131亚洲国产美女久久|
人人狠狠综合久久亚洲|
久久青草国产精品一区|
久久亚洲私人国产精品vA|
国产精品热久久无码av|
久久久久久无码Av成人影院|
亚洲综合久久夜AV |
狠狠人妻久久久久久综合蜜桃
|
国产精品天天影视久久综合网|
一本大道久久香蕉成人网|
国产精品gz久久久|
久久―日本道色综合久久|
99久久国产综合精品麻豆|
国产精品无码久久综合|
国内精品九九久久久精品|
久久午夜伦鲁片免费无码|
少妇人妻88久久中文字幕|
少妇人妻综合久久中文字幕|
欧美久久久久久|
成人综合久久精品色婷婷|
久久99热这里只有精品66|
伊色综合久久之综合久久|
偷窥少妇久久久久久久久|
99久久精品免费看国产一区二区三区|