ACE反應(yīng)器(Reactor)模式的深入分析
反應(yīng)器(Reactor):用于事件多路分離和分派的體系結(jié)構(gòu)模式
通常的,對(duì)一個(gè)文件描述符指定的文件或設(shè)備, 有兩種工作方式: 阻塞與非阻塞。所謂阻塞方式的意思是指, 當(dāng)試圖對(duì)該文件描述符進(jìn)行讀寫時(shí), 如果當(dāng)時(shí)沒有東西可讀,或者暫時(shí)不可寫, 程序就進(jìn)入等待狀態(tài), 直到有東西可讀或者可寫為止。而對(duì)于非阻塞狀態(tài), 如果沒有東西可讀, 或者不可寫, 讀寫函數(shù)馬上返回, 而不會(huì)等待。
在前面的章節(jié)中提到的Tcp通信的例子中,就是采用的阻塞式的工作方式:當(dāng)接收tcp數(shù)據(jù)時(shí),如果遠(yuǎn)端沒有數(shù)據(jù)可以讀,則會(huì)一直阻塞到讀到需要的數(shù)據(jù)為止。這種方式的傳輸和傳統(tǒng)的被動(dòng)方法的調(diào)用類似,非常直觀,并且簡單有效,但是同樣也存在一個(gè)效率問題,如果你是開發(fā)一個(gè)面對(duì)著數(shù)千個(gè)連接的服務(wù)器程序,對(duì)每一個(gè)客戶端都采用阻塞的方式通信,如果存在某個(gè)非常耗時(shí)的讀寫操作時(shí),其它的客戶端通信將無法響應(yīng),效率非常低下。
一種常用做法是:每建立一個(gè)Socket連接時(shí),同時(shí)創(chuàng)建一個(gè)新線程對(duì)該Socket進(jìn)行單獨(dú)通信(采用阻塞的方式通信)。這種方式具有很高的響應(yīng)速度,并且控制起來也很簡單,在連接數(shù)較少的時(shí)候非常有效,但是如果對(duì)每一個(gè)連接都產(chǎn)生一個(gè)線程的無疑是對(duì)系統(tǒng)資源的一種浪費(fèi),如果連接數(shù)較多將會(huì)出現(xiàn)資源不足的情況。
另一種較高效的做法是:服務(wù)器端保存一個(gè)Socket連接列表,然后對(duì)這個(gè)列表進(jìn)行輪詢,如果發(fā)現(xiàn)某個(gè)Socket端口上有數(shù)據(jù)可讀時(shí)(讀就緒),則調(diào)用該socket連接的相應(yīng)讀操作;如果發(fā)現(xiàn)某個(gè)Socket端口上有數(shù)據(jù)可寫時(shí)(寫就緒),則調(diào)用該socket連接的相應(yīng)寫操作;如果某個(gè)端口的Socket連接已經(jīng)中斷,則調(diào)用相應(yīng)的析構(gòu)方法關(guān)閉該端口。這樣能充分利用服務(wù)器資源,效率得到了很大提高。
在Socket編程中就可以通過select等相關(guān)API實(shí)現(xiàn)這一方式。但直接用這些API控制起來比較麻煩,并且也難以控制和移植,在ACE中可以通過Reactor模式簡化這一開發(fā)過程。
反應(yīng)器本質(zhì)上提供一組更高級(jí)的編程抽象,簡化了事件驅(qū)動(dòng)的分布式應(yīng)用的設(shè)計(jì)和實(shí)現(xiàn)。除此而外,反應(yīng)器還將若干不同種類的事件的多路分離集成到易于使用的API中。特別地,反應(yīng)器對(duì)基于定時(shí)器的事件、信號(hào)事件、基于I/O端口監(jiān)控的事件和用戶定義的通知進(jìn)行統(tǒng)一地處理。
ACE中的反應(yīng)器與若干內(nèi)部和外部組件協(xié)同工作。其基本概念是反應(yīng)器框架檢測事件的發(fā)生(通過在OS事件多路分離接口上進(jìn)行偵聽),并發(fā)出對(duì)預(yù)登記事件處理器(event handler)對(duì)象中的方法的"回調(diào)"(callback)。該方法由應(yīng)用開發(fā)者實(shí)現(xiàn),其中含有應(yīng)用處理此事件的特定代碼。
使用ACE的反應(yīng)器,只需如下幾步:
創(chuàng)建事件處理器,以處理他所感興趣的某事件。
在反應(yīng)器上登記,通知說他有興趣處理某事件,同時(shí)傳遞他想要用以處理此事件的事件處理器的指針給反應(yīng)器。
隨后反應(yīng)器框架將自動(dòng)地:
在內(nèi)部維護(hù)一些表,將不同的事件類型與事件處理器對(duì)象關(guān)聯(lián)起來。
在用戶已登記的某個(gè)事件發(fā)生時(shí),反應(yīng)器發(fā)出對(duì)處理器中相應(yīng)方法的回調(diào)。
反應(yīng)器模式在ACE中被實(shí)現(xiàn)為ACE_Reactor類,它提供反應(yīng)器框架的功能接口。
如上面所提到的,反應(yīng)器將事件處理器對(duì)象作為服務(wù)提供者使用。反應(yīng)器內(nèi)部記錄某個(gè)事件處理器的特定事件的相關(guān)回調(diào)方法。當(dāng)這些事件發(fā)生時(shí),反應(yīng)器會(huì)創(chuàng)建這種事件和相應(yīng)的事件處理器的關(guān)聯(lián)。
事件處理器
事件處理器就是需要通過輪詢發(fā)生事件改變的對(duì)象列表中的對(duì)象,如在上面的例子中就是連接的客戶端,每個(gè)客戶端都可以看成一個(gè)事件處理器。
回調(diào)事件
就是反應(yīng)器支持的事件,如Socket讀就緒,寫就緒。拿上面的例子來說,如果某個(gè)客戶端(事件處理器)在反應(yīng)器中注冊(cè)了讀就緒事件,當(dāng)客戶端給服務(wù)器發(fā)送一條消息的時(shí)候,就會(huì)觸發(fā)這個(gè)客戶端的數(shù)據(jù)可讀的回調(diào)函數(shù)。
在反應(yīng)器框架中,所有應(yīng)用特有的事件處理器都必須由ACE_Event_Handler的抽象接口類派生。可以通過重載相應(yīng)的"handle_"方法實(shí)現(xiàn)相關(guān)的回調(diào)方法。
使用ACE_Reactor基本上有三個(gè)步驟:
創(chuàng)建ACE_Event_Handler的子類,并在其中實(shí)現(xiàn)適當(dāng)?shù)?handle_"方法,以處理你想要此事件處理器為之服務(wù)的事件類型。
通過調(diào)用反應(yīng)器對(duì)象的register_handler(),將你的事件處理器登記到反應(yīng)器。
在事件發(fā)生時(shí),反應(yīng)器將自動(dòng)回調(diào)相應(yīng)的事件處理器對(duì)象的適當(dāng)?shù)膆andle_"方法。
上一篇:解析C++ 浮點(diǎn)數(shù)的格式化輸出
欄 目:C語言
下一篇:C++函數(shù)參數(shù)取默認(rèn)值的深入詳解
本文標(biāo)題:ACE反應(yīng)器(Reactor)模式的深入分析
本文地址:http://mengdiqiu.com.cn/a1/Cyuyan/4368.html
您可能感興趣的文章
- 01-10Reactor反應(yīng)器的實(shí)現(xiàn)方法詳解
- 01-10C# interface與delegate效能比較的深入解析
- 01-10利用ace的ACE_Task等類實(shí)現(xiàn)線程池的方法詳解
- 01-10C++ using namespace std 用法深入解析
- 01-10全面解析C++中的new,operator new與placement new
- 01-10C++ namespace相關(guān)語法實(shí)例分析
- 01-10C++ COM編程之QueryInterface函數(shù)(一)
- 01-10C++ COM編程之QueryInterface函數(shù)(二)
- 01-10C++中replace()函數(shù)使用方法匯總
- 01-10淺談C++中replace()方法


閱讀排行
本欄相關(guān)
- 04-02c語言函數(shù)調(diào)用后清空內(nèi)存 c語言調(diào)用
- 04-02func函數(shù)+在C語言 func函數(shù)在c語言中
- 04-02c語言的正則匹配函數(shù) c語言正則表達(dá)
- 04-02c語言用函數(shù)寫分段 用c語言表示分段
- 04-02c語言中對(duì)數(shù)函數(shù)的表達(dá)式 c語言中對(duì)
- 04-02c語言編寫函數(shù)冒泡排序 c語言冒泡排
- 04-02c語言沒有round函數(shù) round c語言
- 04-02c語言分段函數(shù)怎么求 用c語言求分段
- 04-02C語言中怎么打出三角函數(shù) c語言中怎
- 04-02c語言調(diào)用函數(shù)求fibo C語言調(diào)用函數(shù)求
隨機(jī)閱讀
- 01-11Mac OSX 打開原生自帶讀寫NTFS功能(圖文
- 01-10delphi制作wav文件的方法
- 01-11ajax實(shí)現(xiàn)頁面的局部加載
- 01-10C#中split用法實(shí)例總結(jié)
- 08-05織夢(mèng)dedecms什么時(shí)候用欄目交叉功能?
- 08-05DEDE織夢(mèng)data目錄下的sessions文件夾有什
- 01-10使用C語言求解撲克牌的順子及n個(gè)骰子
- 08-05dedecms(織夢(mèng))副欄目數(shù)量限制代碼修改
- 01-10SublimeText編譯C開發(fā)環(huán)境設(shè)置
- 04-02jquery與jsp,用jquery