ACE小技巧:在ACE_Acceptor框架中,自定義服務處理器的創(chuàng)建
Stone Jiang
ACE_Acceptor框架使對新連接的偵聽變得容易,也使創(chuàng)建和激活新連接的ACE_Svc_Handler的派生類變得容易。之前我們已經(jīng)了解了ACE_Svc_Handle::open()掛勾函數(shù)和服務處理器
初始化時它所扮演的角色。本文我們回退幾步,來了解服務處理器是如何實例化的以及我們?nèi)绾巫远x它的行為。
再看看ACE_Acceptor類,它是一個模板類,第一個模板參數(shù)ACE_Accetpor是代表與服務建立連接的處理器。當新的連接建立時,ACE_Acceptor調(diào)用make_svc_handler()掛勾函數(shù)來
實際創(chuàng)建的新建服務處理器對象。ACE_Acceptor::make_svc_handler()的實現(xiàn)如下:
template?
<
class
?SVC_HANDLE,ACE_PEER_ACCEPTOR_1
>
int
ACE_Acceptor
<
SVC_HANDLE,?ACE_PEER_ACCEPTOR_2
>
::make_svc_handler(SVC_HANDLE
*&
?sh)
{
??ACE_TRACE?(
"
ACE_Acceptor<SVC_HANDLER,?ACE_PEER_ACCEPTOR_2>::make_svc_handler
"
);??
if
?(sh?
==
?
0
)
????ACE_NEW_RETURN?(sh,
????????????????????SVC_HANDLER,
????????????????????
-
1
);??
//
?Set?the?reactor?of?the?newly?created?<SVC_HANDLER>?to?the?same
??
//
?reactor?that?this?<ACE_Acceptor>?is?using.
??sh
->
reactor?(
this
->
reactor?());
??
return
?
0
;
}
?
默認的實現(xiàn)包括了兩步基本操作:
1.? 獲得一個新的SVC_HANLDER對象, 這里是使用的new運算符分配的。
2.? 設置新的服務處理器的reactor指針為ACE_Accetpor使用的reactor的。
然而,如果應用程序需要通過其它方式獲得SVC_HANDLER對象,而不是通過默認的構(gòu)造函數(shù)那種動態(tài)分配,這又該怎么辦呢?舉例來說,我們可能需要:
?. 從一個預分配的池中獲得SVC_HANDLER對象;
?. 為新創(chuàng)建的SVC_HANDLER傳入一些額外的信息
?. 使用單體的SVC_HANDLER
上面這些情形,我們都可以自定義make_svc_handler()掛勾函數(shù)來實現(xiàn)必要的行為。例如,假定我們新的處理器需要擁有一個處理所有對所有接收到的消息進行集中處理的中心處理
器。這個中心處理器我們用類Processor表示。我們需要每個服務處理器都擁有一個指向中心處理器的指針,而不是使Processor成為一個全局訪問的指針(使用全局變量的種種弊端
本文不作詳述)。我們的解決辦法是: 從ACE_Accetor派生一個新類,這個新類擁有Processor的指針作成員,并且,在創(chuàng)建新和服務處理器(Service)的時候,把這個 Processor的
指針作參數(shù)傳進去。
新的acceptor類可以這樣定義:
class
?My_Acceptor?:?
public
?ACE_Acceptor
<
Service,?ACE_SOCK_ACCEPTOR
>
...
{
public
:

??My_Acceptor?(Processor?
*
processor)?:?processor_?(processor)?
...
{?}
;
??
??
int
?make_svc_handler?(Service?
*&
sh)

????
...
{
??????
if
?(sh?
==
?
0
)
????????ACE_NEW_RETURN?(sh,
????????????????????????Service?(
this
->
processor_),
????????????????????????
-
1
);??????
//
?Set?the?reactor?of?the?newly?created?<SVC_HANDLER>?to?the?same
??????
//
??reactor?that?this?<ACE_Acceptor>?is?using.
??????sh
->
reactor?(
this
->
reactor?());
??????
return
?
0
;
????}
private
:
??Processor?
*
processor_;
}
?
就這樣,現(xiàn)在,當My_Acceptor接受新連接的時候,make_svc_handler()掛勾函數(shù)分配一個新的處理器(Service),并把Processor*作為參數(shù)傳進去。需要注意的事,盡管這里使用
的是這一個構(gòu)造函數(shù)Service(Processor*)。我們?nèi)孕枨鬄镾ervice類定義默認的構(gòu)造函數(shù),以滿足模板類ACE_Acceptor的需要。
?