摘要: 9.1 意圖 　 接受器－連接器設(shè)計模式（Acceptor-Connector）使分布式系統(tǒng)中的連接建立及服務(wù)初始化與一旦服務(wù)初始化后所執(zhí)行的處理去耦合。這樣的去耦合通過三種組件來完成：acceptor、connector和service handler（服務(wù)處理器）。連接器主動地建立到遠(yuǎn)地接受器組件的連接，并初始化服務(wù)處理器來處理在連接上交...  閱讀全文      摘要: 接受器/連接器模式設(shè)計用于降低連接建立與連接建立后所執(zhí)行的服務(wù)之間的耦合。例如，在WWW瀏覽器中，所執(zhí)行的服務(wù)或“實際工作”是解析和顯示客戶瀏覽器接收到的HTML頁面。連接建立是次要的，可能通過BSD socket或其他一些等價的IPC機制來完成。使用這些模式允許程序員專注于“實際工作”，而最少限度地去關(guān)心怎樣在服務(wù)器和客戶之間建立連接。而另外一方面，程序員也可以獨立于他所編寫的、或?qū)⒁帉懙姆?wù)...  閱讀全文

• 并發(fā)性：服務(wù)器必須同時執(zhí)行多個客戶請求；
• 效率：服務(wù)器必須最小化響應(yīng)延遲、最大化吞吐量，并避免不必要地使用CPU；
• 編程簡單性：服務(wù)器的設(shè)計應(yīng)該簡化高效的并發(fā)策略的使用；
• 可適配性：應(yīng)該使繼承新的或改進的傳輸協(xié)議（比如HTTP 1.1[3]）所帶來的維護代價最小化。

1. 每個線程同步地阻塞在accept socket調(diào)用中，等待客戶連接請求；
2. 客戶連接到服務(wù)器，連接被接受；
3. 新客戶的HTTP請求被同步地從網(wǎng)絡(luò)連接中讀取；
4. 請求被解析；
5. 所請求的文件被同步地讀取；
6. 文件被同步地發(fā)送給客戶。

1. Web服務(wù)器將Acceptor登記到Initiation Dispatcher，以接受新連接；
2. Web服務(wù)器調(diào)用Initiation Dispatcher的事件循環(huán)；
3. 客戶連接到Web服務(wù)器；
4. Initiation Dispatcher將新連接請求通知Acceptor，后者接受新連接；
5. Acceptor創(chuàng)建HTTP Handler，以服務(wù)新客戶；
6. HTTP Handler將連接登記到Initiation Dispatcher，以讀取客戶請求數(shù)據(jù)（就是說，在連接變得“讀就緒”時）；
7. HTTP Handler服務(wù)來自新客戶的請求。

1. 客戶發(fā)送HTTP GET請求；
2. 當(dāng)客戶請求數(shù)據(jù)到達(dá)服務(wù)器時，Initiation Dispatcher通知HTTP Handler；
3. 請求以非阻塞方式被讀取，于是如果操作會導(dǎo)致調(diào)用線程阻塞，讀操作就返回EWOULDBLOCK（步驟2和3將重復(fù)直到請求被完全讀取）；
4. HTTP Handler解析HTTP請求；
5. 所請求的文件從文件系統(tǒng)中被同步讀取；
6. 為發(fā)送文件數(shù)據(jù)（就是說，當(dāng)連接變得“寫就緒”時），HTTP Handler將連接登記到Initiation Dispatcher；
7. 當(dāng)TCP連接變得寫就緒時，Initiation Dispatcher通知HTTP Handler；
8. HTTP Handler以非阻塞方式將所請求文件發(fā)送給客戶，于是如果操作會導(dǎo)致調(diào)用線程阻塞，寫操作就返回EWOULDBLOCK（步驟7和8將重復(fù)直到數(shù)據(jù)被完全遞送）。

1. Web服務(wù)器指示Acceptor發(fā)起異步接受；
2. 接受器通過OS發(fā)起異步接受，將其自身作為Completion Handler和Completion Dispatcher的引用傳遞；并將用于在異步接受完成時通知Acceptor；
3. Web服務(wù)器調(diào)用Completion Dispatcher的事件循環(huán)；
4. 客戶連接到Web服務(wù)器；
5. 當(dāng)異步接受操作完成時，操作系統(tǒng)通知Completion Dispatcher；
6. Completion Dispatcher通知接受器；
7. Acceptor創(chuàng)建HTTP Handler；
8. HTTP Handler發(fā)起異步操作，以讀取來自客戶的請求數(shù)據(jù)，并將其自身作為Completion Handler和Completion Dispatcher的引用傳遞；并將用于在異步讀取完成時通知HTTP Handler。

1. 客戶發(fā)送HTTP GET請求；
2. 讀取操作完成，操作系統(tǒng)通知Completion Dispatcher；
3. Completion Dispatcher通知HTTP Handler（步驟2和3將重復(fù)直到整個請求被接收）；
4. HTTP Handler解析請求；
5. HTTP Handler同步地讀取所請求的文件；
6. HTTP Handler發(fā)起異步操作，以把文件數(shù)據(jù)寫到客戶連接，并將其自身作為Completion Handler和Completion Dispatcher的引用傳遞；并將用于在異步寫入完成時通知HTTP Handler。
7. 當(dāng)寫操作完成時，操作系統(tǒng)通知Completion Dispatcher；
8. 隨后Completion Dispatcher通知Completion Handler（步驟6-8將重復(fù)直到文件被完全遞送）。

• 應(yīng)用需要執(zhí)行一個或多個不阻塞調(diào)用線程的異步操作；
• 當(dāng)異步操作完成時應(yīng)用必須被通知；
• 應(yīng)用需要獨立于它的I/O模型改變它的并發(fā)策略；
• 通過使依賴于應(yīng)用的邏輯與應(yīng)用無關(guān)的底層構(gòu)造去耦合，應(yīng)用將從中獲益；
• 當(dāng)使用多線程方法或反應(yīng)式分派方法時，應(yīng)用的執(zhí)行將很低效，或是不能滿足性能需求。

• Proactive Initiator是應(yīng)用中任何發(fā)起Asynchronous Operation（異步操作）的實體。它將Completion Handler和Completion Dispatcher登記到Asynchronous Operation Processor（異步操作處理器），此處理器在操作完成時通知前攝發(fā)起器。

• 前攝器模式將應(yīng)用所實現(xiàn)的Completion Handler接口用于Asynchronous Operation完成通知。

• Asynchronous Operation被用于代表應(yīng)用執(zhí)行請求（比如I/O和定時器操作）。當(dāng)應(yīng)用調(diào)用Asynchronous Operation時，操作的執(zhí)行沒有借用應(yīng)用的線程控制。因此，從應(yīng)用的角度來看，操作是被異步地執(zhí)行的。當(dāng)Asynchronous Operation完成時，Asynchronous Operation Processor將應(yīng)用通知委托給Completion Dispatcher。

• Asynchronous Operation是由Asynchronous Operation Processor來運行直至完成的。該組件通常由OS實現(xiàn)。

• Completion Dispatcher負(fù)責(zé)在Asynchronous Operation完成時回調(diào)應(yīng)用的Completion Handler。當(dāng)Asynchronous Operation Processor完成異步發(fā)起的操作時，Completion Dispatcher代表應(yīng)用執(zhí)行應(yīng)用回調(diào)。

1. 前攝發(fā)起器發(fā)起操作：為執(zhí)行異步操作，應(yīng)用在Asynchronous Operation Processor上發(fā)起操作。例如，Web服務(wù)器可能要求OS在網(wǎng)絡(luò)上使用特定的socket連接傳輸文件。要請求這樣的操作，Web服務(wù)器必須指定要使用哪一個文件和網(wǎng)絡(luò)連接。而且，Web服務(wù)器必須指定（1）當(dāng)操作完成時通知哪一個Completion Handler，以及（2）一旦文件被傳輸，哪一個Completion Dispatcher應(yīng)該執(zhí)行回調(diào)。
2. 異步操作處理器執(zhí)行操作：當(dāng)應(yīng)用在Asynchronous Operation Processor上調(diào)用操作時，它相對于其他應(yīng)用操作異步地運行這些操作。現(xiàn)代操作系統(tǒng)（比如Solaris和Windows NT）在內(nèi)核中提供異步的I/O子系統(tǒng)。
3. 異步操作處理器通知完成分派器：當(dāng)操作完成時，Asynchronous Operation Processor取得在操作被發(fā)起時指定的Completion Handler和Completion Dispatcher。隨后Asynchronous Operation Processor將Asynchronous Operation的結(jié)果和Completion Handler傳遞給Completion Dispatcher，以用于回調(diào)。例如，如果文件已被異步傳輸，Asynchronous Operation Processor可以報告完成狀態(tài)（比如成功或失敗），以及寫入網(wǎng)絡(luò)連接的字節(jié)數(shù)。
4. 完成分派器通知應(yīng)用：Completion Dispatcher在Completion Handler上調(diào)用完成掛鉤，將由應(yīng)用指定的任何完成數(shù)據(jù)傳遞給它。例如，如果異步讀取完成，通常一個指向新到達(dá)數(shù)據(jù)的指針將會被傳遞給Completion Handler。

1. 操作調(diào)用：因為操作將在與進行調(diào)用的應(yīng)用線程不同的線程控制中執(zhí)行，必定會發(fā)生某種類型的線程同步。一種方法是為每個操作派生一個線程。更為常用的方法是為Asynchronous Operation Processor而管理一個專用線程池。該方法可能需要應(yīng)用線程在繼續(xù)進行其他應(yīng)用計算之前將操作請求排隊。
2. 操作執(zhí)行：既然操作將在專用線程中執(zhí)行，所以它可以執(zhí)行“阻塞”操作，而不會直接阻礙應(yīng)用的進展。例如，在提供異步I/O讀取機制時，專用線程可以在從socket或文件句柄中讀時阻塞。
3. 操作完成：當(dāng)操作完成時，應(yīng)用必須被通知到。特別是，專用線程必須將應(yīng)用特有的通知委托給Completion Dispatcher。這要求在線程間進行另外的同步。

1. Completion Handler不會被迫輸出特定的接口；以及
2. 在Completion Dispatcher和Completion Handler之間不需要有編譯時依賴。

??? ACE_INET_Addr類，包裝了網(wǎng)絡(luò)地址
??? ACE_SOCK_Connector類，扮演主動連接角色，發(fā)起通訊連接。連接到遠(yuǎn)端的服務(wù)。
??? ACE_SOCK_Acceptor類，扮演被動連接角色，等待連接。等待遠(yuǎn)端客戶的請求。
??? ACE_SOCK_Stream類，扮演數(shù)據(jù)通訊角色，發(fā)送和接收數(shù)據(jù)。完成客戶與服務(wù)之間的通訊。
???
??? 利用ACE庫來開發(fā)網(wǎng)絡(luò)通訊程序是很簡單的，一個基本程序只用到以上提到的幾個類，就
可以完成一個基于客戶端、服務(wù)器端模型的網(wǎng)絡(luò)應(yīng)用的開發(fā)。開發(fā)者無需了解Socket在不同平
臺上的實現(xiàn)，記憶眾多并相互關(guān)聯(lián)的Socket APIs。

??? 一下以一個Hello World程序為演示。
???
??? 客戶端程序。發(fā)送一個Hello World到遠(yuǎn)端的服務(wù)器，并接收服務(wù)器返回的信息，將信息
打印在屏幕上。

#include <iostream>
#include <string>

#include <ace/ACE.h>
#include <ace/INET_Addr.h>
#include <ace/SOCK_Connector.h>
#include <ace/SOCK_Stream.h>

int main( int argc, char* argv[] )
{
?ACE::init();//初始化ACE庫，在windows下一定要

?std::string str = "hello world";

?//設(shè)置服務(wù)器地址
?//第一個參數(shù)是端口，第二個是ip地址，也可以是域名。
?//可以先定義一個地址對象，再用ACE_INET_Addr的set函數(shù)來設(shè)定。
?//地址的配置很多，具體的參照文檔
?ACE_INET_Addr peer_addr( 5050, "127.0.0.1" );
?ACE_SOCK_Stream peer_stream;//定義一個通訊隊形

?ACE_SOCK_Connector peer_connector;//定義一個主動連接對象
?peer_connector.connect( peer_stream, peer_addr );//發(fā)起一個連接

?peer_stream.send( str.c_str(), str.length() );//發(fā)送數(shù)據(jù)到服務(wù)器

?str.erase();
?str.resize( sizeof( "hello world" ) );
?peer_stream.recv( (void*)str.c_str(), str.length() );//接收來自服務(wù)器的信息

?std::cout << "from server message : " << str << std::endl;

??? ACE::fini();
?return 0;
}

??? 服務(wù)器端代碼。接收一個遠(yuǎn)端的連接，將接收到的信息打印在屏幕上，并將接收到的信
息返回給客戶端。
#include <iostream>
#include <string>

#include <ace/ACE.h>
#include <ace/SOCK_Acceptor.h>
#include <ace/SOCK_Stream.h>

int main( int argc, char* argv[] )
{
?ACE::init();

?std::string str;
?str.resize( sizeof( "hello world" ) );

?//設(shè)置服務(wù)器地址
?ACE_INET_Addr peer_addr( 5050, "127.0.0.1" );

?ACE_SOCK_Stream peer_stream;
?
?//創(chuàng)建被動連接角色對象
?ACE_SOCK_Acceptor peer_acceptor;
?//開啟被動連接對象，將對象綁定到一個地址上
?peer_acceptor.open( peer_addr );

?//等待連接
?peer_acceptor.accept( peer_stream );

?//數(shù)據(jù)通訊
?peer_stream.recv( (void*)str.c_str(), str.length() );
?std::cout << "from client message : " << str << std::endl;
?peer_stream.send( str.c_str(), str.length() );

?ACE::fini();
?return 0;
}
××××以上代碼需要ACE庫才能運轉(zhuǎn)××××
???
??? 利用ACE編程的基本框架。
??? 客戶端
??? 1 創(chuàng)建地址對象。（ACE_INET_Addr）
??? 2 創(chuàng)建主動連接對象。（ACE_SOCK_Connector）
??? 3 創(chuàng)建數(shù)據(jù)通訊對象。（ACE_SOCK_Stream）
??? 4 設(shè)置服務(wù)器地址。（ACE_INET_Addr::set）
??? 5 將數(shù)據(jù)通訊對象和地址作為參數(shù)傳給主動連接對象，發(fā)起主動連接（ACE_SOCK_Connector::connect）
??? 6 利用通訊對象接收和發(fā)送數(shù)據(jù)。（ACE_SOCK_Stream::recv和ACE_SOCK_Stream::send）
???
??? 服務(wù)器端
??? 1 創(chuàng)建地址對象。（ACE_INET_Addr）
??? 2 創(chuàng)建被動連接對象。（ACE_SOCK_Connector）
??? 3 創(chuàng)建數(shù)據(jù)通訊對象。（ACE_SOCK_Stream）
??? 4 設(shè)置服務(wù)器地址。（ACE_INET_Addr::set）
??? 5 將地址作為參數(shù)傳給被動連接對象，啟動接收（ACE_SOCK_Acceptor::open）
??? 6 將數(shù)據(jù)通訊對象傳給被動連接對象，啟動接收，接受連接（ACE_SOCK_Connector::accept）
??? 7 利用通訊對象接收和發(fā)送數(shù)據(jù)。（ACE_SOCK_Stream::recv和ACE_SOCK_Stream::send）

??? ACE_IPC_SAP類是IPC類族的基類，封裝了句柄，提供了訪問句柄的基本接口，基本結(jié)構(gòu)
如下
class ACE_IPC_SAP
{
public:
? int enable (int value) const;
? int disable (int value) const;

? ACE_HANDLE get_handle (void) const;
? void set_handle (ACE_HANDLE handle);

protected:
? ACE_IPC_SAP (void);
? ~ACE_IPC_SAP (void);

private:
? ACE_HANDLE handle_;
};

??? ACE_SOCK類是使用Socket的基類，所有使用Socket通訊的類都從這個類派生。本類的功
能包括
??? 1 創(chuàng)建和銷毀Socket句柄
??? 2 獲取本地和遠(yuǎn)端的網(wǎng)絡(luò)地址
??? 3 設(shè)置和讀取Socket選項。
基本結(jié)構(gòu)如下
class ACE_SOCK : public ACE_IPC_SAP
{
public:
? //設(shè)置Socket的屬性，包裝了setsockopt系統(tǒng)函數(shù)
? int set_option (int level,
????????????????? int option,
????????????????? void *optval,
????????????????? int optlen) const;
? //獲取Socket的屬性，包裝了getsockopt系統(tǒng)函數(shù)
? int get_option (int level,
????????????????? int option,
????????????????? void *optval,
????????????????? int *optlen) const;
? //獲得本地地址
? int get_local_addr (ACE_Addr &) const;
? //獲取遠(yuǎn)端地址
? int get_remote_addr (ACE_Addr &) const;
? //關(guān)閉Socket
? int close (void);
? //打開一個Socket，沒有Qos
? int open (int type,
??????????? int protocol_family,
??????????? int protocol,
??????????? int reuse_addr);
? //打開一個Socket，有Qos
? int open (int type,
??????????? int protocol_family,
??????????? int protocol,
??????????? ACE_Protocol_Info *protocolinfo,
??????????? ACE_SOCK_GROUP g,
??????????? u_long flags,
??????????? int reuse_addr);

protected:
? ACE_SOCK (int type,
??????????? int protocol_family,
??????????? int protocol = 0,
??????????? int reuse_addr = 0);
? ACE_SOCK (int type,
??????????? int protocol_family,
??????????? int protocol,
??????????? ACE_Protocol_Info *protocolinfo,
??????????? ACE_SOCK_GROUP g,
??????????? u_long flags,
??????????? int reuse_addr);
? ACE_SOCK (void);
? ~ACE_SOCK (void);
};

??? ACE_SOCK_IO類，包裝了Socket數(shù)據(jù)通訊的基本方法。本類提供的功能
??? 1 支持?jǐn)?shù)據(jù)的發(fā)送和接收
??? 2 支持分散讀操作
??? 3 支持集中寫操作
??? 4 支持阻塞，非阻塞，定時 I/O操作
基本結(jié)構(gòu)如下
class ACE_SOCK_IO : public ACE_SOCK
{
public:
? ACE_SOCK_IO (void);
? ~ACE_SOCK_IO (void);

? //接收數(shù)據(jù)
? ssize_t recv (void *buf,
??????????????? size_t n,
??????????????? const ACE_Time_Value *timeout = 0) const;
? //分散讀操作
? ssize_t recv (iovec iov[],
??????????????? size_t n,
??????????????? const ACE_Time_Value *timeout = 0) const;
? //發(fā)送數(shù)據(jù)?????????????
? ssize_t send (const void *buf,
??????????????? size_t n,
??????????????? const ACE_Time_Value *timeout = 0) const;
? //集中寫操作
? ssize_t send (const iovec iov[],
??????????????? size_t n,
??????????????? const ACE_Time_Value *timeout = 0) const;
};

??? ACE_SOCK_Stream類，繼承ACE_SOCK_IO類。在ACE_SOCK_IO類提供的功能上，添加了發(fā)送
和接收剛好n個字節(jié)的能力。基本結(jié)構(gòu)如下
class ACE_Export ACE_SOCK_Stream : public ACE_SOCK_IO
{
public:
? ACE_SOCK_Stream (void);
? ACE_SOCK_Stream (ACE_HANDLE h);
? ~ACE_SOCK_Stream (void);
?
? //剛好讀取n個字節(jié)的數(shù)據(jù)
? ssize_t recv_n (void *buf,
????????????????? size_t len,
????????????????? const ACE_Time_Value *timeout = 0,
????????????????? size_t *bytes_transferred = 0) const;
? //分散讀剛好n個字節(jié)操作
? ssize_t recvv_n (iovec iov[],
?????????????????? int iovcnt,
?????????????????? const ACE_Time_Value *timeout = 0,
?????????????????? size_t *bytes_transferred = 0) const;
? //剛好發(fā)送n個字節(jié)的數(shù)據(jù)
? ssize_t send_n (const void *buf,
????????????????? size_t len,
????????????????? const ACE_Time_Value *timeout = 0,
????????????????? size_t *bytes_transferred = 0) const;
? //集中寫剛好n個字節(jié)操作
? ssize_t sendv_n (const iovec iov[],
?????????????????? int iovcnt,
?????????????????? const ACE_Time_Value *timeout = 0,
?????????????????? size_t *bytes_transferred = 0) const;

? int close_reader (void);
? int close_writer (void);

? int close (void);

? typedef ACE_INET_Addr PEER_ADDR;
};

??? ACE_SOCK_Acceptor類是一個工廠類，用來被動產(chǎn)生一個新的通訊端點。提供如下能力
??? 1 接收對等端的連接
??? 2 連接可以通過阻塞、非阻塞或定時方式接受。
基本結(jié)構(gòu)如下
class ACE_Export ACE_SOCK_Acceptor : public ACE_SOCK
{
public:

? ACE_SOCK_Acceptor (void);
? ACE_SOCK_Acceptor (const ACE_Addr &local_sap,
???????????????????? int reuse_addr = 0,
???????????????????? int protocol_family = PF_UNSPEC,
???????????????????? int backlog = ACE_DEFAULT_BACKLOG,
???????????????????? int protocol = 0);
? ~ACE_SOCK_Acceptor (void);

? //打開一個監(jiān)聽
? int open (const ACE_Addr &local_sap,
??????????? int reuse_addr = 0,
??????????? int protocol_family = PF_UNSPEC,
??????????? int backlog = ACE_DEFAULT_BACKLOG,
??????????? int protocol = 0);

? int close (void);
? //接受一個對等端的連接，產(chǎn)生一個通訊
? int accept (ACE_SOCK_Stream &new_stream,
????????????? ACE_Addr *remote_addr = 0,
????????????? ACE_Time_Value *timeout = 0,
????????????? int restart = 1,
????????????? int reset_new_handle = 0) const;
};

??? ACE_SOCK_Connector類是一個工廠類，用來主動建立一個新的通訊端。提供的功能如下
??? 1 發(fā)起一個到對等接受者的連接，并在連接后產(chǎn)生一個通訊對象
??? 2 連接可以通過阻塞、非阻塞或定時方式發(fā)起
基本結(jié)構(gòu)如下
class ACE_SOCK_Connector
{
public:
? ACE_SOCK_Connector (void);
? ACE_SOCK_Connector (ACE_SOCK_Stream &new_stream,
????????????????????? const ACE_Addr &remote_sap,
????????????????????? const ACE_Time_Value *timeout = 0,
????????????????????? const ACE_Addr &local_sap = ACE_Addr::sap_any,
????????????????????? int reuse_addr = 0,
????????????????????? int flags = 0,
????????????????????? int perms = 0,
????????????????????? int protocol = 0);

? //發(fā)起一個連接
? int connect (ACE_SOCK_Stream &new_stream,
?????????????? const ACE_Addr &remote_sap,
?????????????? const ACE_Time_Value *timeout = 0,
?????????????? const ACE_Addr &local_sap = ACE_Addr::sap_any,
?????????????? int reuse_addr = 0,
?????????????? int flags = 0,
?????????????? int perms = 0,
?????????????? int protocol = 0);

? ~ACE_SOCK_Connector (void);

? int complete (ACE_SOCK_Stream &new_stream,
??????????????? ACE_Addr *remote_sap = 0,
??????????????? const ACE_Time_Value *timeout = 0);
};

??? 以上的類結(jié)構(gòu)是簡化的，以突出重點功能。要完全了解每個類，看源代碼。

??? 多路分配的入口函數(shù)handle_events，在框架的實現(xiàn)接口類中定義
??? 多路分配的主體實現(xiàn)函數(shù)event_handling,在ACE_WFMO_Reactor中定義，偽
實現(xiàn)代碼如下
int ACE_WFMO_Reactor::event_handling (ACE_Time_Value *max_wait_time,
????????????????????????????????????? int alertable)
{
? int result = 0;
?
? do
? {
????? //等待在句柄集上發(fā)生的事件
????? //wait_for_multiple_events的具體實現(xiàn)是使用
????? //WaitForMultipleObjectsEx函數(shù)
????? DWORD wait_status = this->wait_for_multiple_events (timeout,
????????????????????????????????????????????????????????? alertable);
????? //分發(fā)事件
????? result = this->safe_dispatch (wait_status);
? }while (result == 0);

? return result;
}

??? 分發(fā)的主體函數(shù)是dispatch_handles,在ACE_WFMO_Reactor中定義，偽實現(xiàn)
代碼如下
int ACE_WFMO_Reactor::dispatch_handles (DWORD wait_status)
{
? DWORD dispatch_slot = 0;

? //活動的句柄總數(shù)
? DWORD max_handlep1 = this->handler_rep_.max_handlep1 ();

? //查找要分發(fā)的句柄的索引
? for (int number_of_handlers_dispatched = 1;;++number_of_handlers_dispatched)
? {
????? //計算有事件發(fā)生，要分發(fā)的句柄索引
????? dispatch_slot += wait_status - WAIT_OBJECT_0;
????? //分發(fā)給相應(yīng)的事件處理對象
????? if (this->dispatch_handler (dispatch_slot, max_handlep1) == -1)
??????? return -1;

????? ++dispatch_slot;

????? if (dispatch_slot >= max_handlep1)
??????? return number_of_handlers_dispatched;//分發(fā)了幾個事件

????? //檢查剩下的句柄中有沒有有事件發(fā)生的
????? wait_status = this->poll_remaining_handles (dispatch_slot);
????? switch (wait_status)
????? {
??????? case WAIT_FAILED: // Failure.
????????? ACE_OS::set_errno_to_last_error ();
????????? /* FALLTHRU */
??????? case WAIT_TIMEOUT:
????????? // There are no more handles ready, we can return.
????????? return number_of_handlers_dispatched;//分發(fā)了幾個事件
????? }
? }
}

??? 找到具體事件處理對象主體函數(shù)complex_dispatch_hander,在ACE_WFMO_Reactor
中定義，為代碼如下
int ACE_WFMO_Reactor::complex_dispatch_handler (DWORD slot,
??????????????????????????????????????????????? ACE_HANDLE event_handle)
{
? //找到當(dāng)前的分發(fā)的信息
? ACE_WFMO_Reactor_Handler_Repository::Current_Info &current_info =
??? this->handler_rep_.current_info ()[slot];

? WSANETWORKEVENTS events;
? ACE_Reactor_Mask problems = ACE_Event_Handler::NULL_MASK;
? if (::WSAEnumNetworkEvents ((SOCKET) current_info.io_handle_,
????????????????????????????? event_handle,
????????????????????????????? &events) == SOCKET_ERROR)
??? problems = ACE_Event_Handler::ALL_EVENTS_MASK;
? else
? {
????? //發(fā)生的事件于要檢測的事件是否相同，相同就分發(fā)
????? events.lNetworkEvents &= current_info.network_events_;
????? while (events.lNetworkEvents != 0)
????? {
????????? ACE_Event_Handler *event_handler = current_info.event_handler_;

????????? //調(diào)用事件處理對象，進行事件處理
????????? problems |= this->upcall (current_info.event_handler_,
??????????????????????????????????? current_info.io_handle_,
??????????????????????????????????? events);

????????? if (this->handler_rep_.scheduled_for_deletion (slot))
??????????? break;
????? }
? }

? return 0;
}

1
int ACE_WFMO_Reactor::handle_events (ACE_Time_Value &how_long)
{
? return this->event_handling (&how_long, FALSE);
}

2
// Waits for and dispatches all events.? Returns -1 on error, 0 if
// max_wait_time expired, or the number of events that were dispatched.
int ACE_WFMO_Reactor::event_handling (ACE_Time_Value *max_wait_time,
????????????????????????????????????? int alertable)
{
? ACE_TRACE ("ACE_WFMO_Reactor::event_handling");

? // Make sure we are not closed
? if (!this->open_for_business_ || this->deactivated_)
????? return -1;

? // Stash the current time -- the destructor of this object will
? // automatically compute how much time elapsed since this method was
? // called.
? ACE_Countdown_Time countdown (max_wait_time);

? int result;
?
? do
? {
????? // Check to see if it is ok to enter ::WaitForMultipleObjects
????? // This will acquire <this->lock_> on success On failure, the
????? // lock will not be acquired
?????
????? result = this->ok_to_wait (max_wait_time, alertable);
????? if (result != 1)
??????? return result;

????? // Increment the number of active threads
????? ++this->active_threads_;

????? // Release the <lock_>
????? this->lock_.release ();

????? // Update the countdown to reflect time waiting to play with the
????? // mut and event.
?????
????? countdown.update ();

????? // Calculate timeout
????? int timeout = this->calculate_timeout (max_wait_time);

????? // Wait for event to happen
????? DWORD wait_status = this->wait_for_multiple_events (timeout,
????????????????????????????????????????????????????????? alertable);

????? // Upcall
????? result = this->safe_dispatch (wait_status);
????? if (0 == result)
????? {
????????? // wait_for_multiple_events timed out without dispatching
????????? // anything.? Because of rounding and conversion errors and
????????? // such, it could be that the wait loop timed out, but
????????? // the timer queue said it wasn't quite ready to expire a
????????? // timer. In this case, max_wait_time won't have quite been
????????? // reduced to 0, and we need to go around again. If max_wait_time
????????? // is all the way to 0, just return, as the entire time the
????????? // caller wanted to wait has been used up.
????????? countdown.update ();???? // Reflect time waiting for events
?????????
????????? if (0 == max_wait_time || max_wait_time->usec () == 0)
??????????? break;
????? }
? }while (result == 0);

? return result;
}

3
int ACE_WFMO_Reactor::safe_dispatch (DWORD wait_status)
{
? int result = -1;
? ACE_SEH_TRY
? {
????? result = this->dispatch (wait_status);
? }
? ACE_SEH_FINALLY
? {
????? this->update_state ();
? }

? return result;
}

4
int ACE_WFMO_Reactor::dispatch (DWORD wait_status)
{
? int handlers_dispatched = 0;

? // Expire timers
? handlers_dispatched += this->expire_timers ();

? switch (wait_status)
? {
? case WAIT_FAILED: // Failure.
????? ACE_OS::set_errno_to_last_error ();
????? return -1;

? case WAIT_TIMEOUT: // Timeout.
????? errno = ETIME;
????? return handlers_dispatched;

? default:? // Dispatch.
????? // We'll let dispatch worry about abandoned mutes.
????? handlers_dispatched += this->dispatch_handles (wait_status);
????? return handlers_dispatched;
? }
}

5
// Dispatches any active handles from <handles_[slot]> to
// <handles_[max_handlep1_]>, polling through our handle set looking
// for active handles.

int ACE_WFMO_Reactor::dispatch_handles (DWORD wait_status)
{
? // dispatch_slot is the absolute slot.? Only += is used to
? // increment it.
? DWORD dispatch_slot = 0;

? // Cache this value, this is the absolute value.
? DWORD max_handlep1 = this->handler_rep_.max_handlep1 ();

? // nCount starts off at <max_handlep1>, this is a transient count of
? // handles last waited on.
? DWORD nCount = max_handlep1;

? for (int number_of_handlers_dispatched = 1;;++number_of_handlers_dispatched)
? {
????? const bool ok = (wait_status >= WAIT_OBJECT_0 && wait_status <= (WAIT_OBJECT_0 + nCount));

????? if (ok)
??????? dispatch_slot += wait_status - WAIT_OBJECT_0;
????? else
??????? // Otherwise, a handle was abandoned.
??????? dispatch_slot += wait_status - WAIT_ABANDONED_0;

????? // Dispatch handler
????? if (this->dispatch_handler (dispatch_slot, max_handlep1) == -1)
??????? return -1;

????? // Increment slot
????? ++dispatch_slot;

????? // We're done.
????? if (dispatch_slot >= max_handlep1)
??????? return number_of_handlers_dispatched;

????? // Readjust nCount
????? nCount = max_handlep1 - dispatch_slot;

????? // Check the remaining handles
????? wait_status = this->poll_remaining_handles (dispatch_slot);
????? switch (wait_status)
????? {
??????? case WAIT_FAILED: // Failure.
????????? ACE_OS::set_errno_to_last_error ();
????????? /* FALLTHRU */
??????? case WAIT_TIMEOUT:
????????? // There are no more handles ready, we can return.
????????? return number_of_handlers_dispatched;
????? }
? }
}

6
int ACE_WFMO_Reactor::dispatch_handler (DWORD slot,
??????????????????????????????????????? DWORD max_handlep1)
{
? // Check if there are window messages that need to be dispatched
? if (slot == max_handlep1)
??? return this->dispatch_window_messages ();

? // Dispatch the handler if it has not been scheduled for deletion.
? // Note that this is a very week test if there are multiple threads
? // dispatching this slot as no locks are held here. Generally, you
? // do not want to do something like deleting the this pointer in
? // handle_close() if you have registered multiple times and there is
? // more than one thread in WFMO_Reactor->handle_events().
? else if (!this->handler_rep_.scheduled_for_deletion (slot))
? {
????? ACE_HANDLE event_handle = *(this->handler_rep_.handles () + slot);

????? if (this->handler_rep_.current_info ()[slot].io_entry_)
??????? return this->complex_dispatch_handler (slot,
?????????????????????????????????????????????? event_handle);
????? else
??????? return this->simple_dispatch_handler (slot,
????????????????????????????????????????????? event_handle);
? }
? else
??? // The handle was scheduled for deletion, so we will skip it.
??? return 0;
}

7
int ACE_WFMO_Reactor::complex_dispatch_handler (DWORD slot,
??????????????????????????????????????????????? ACE_HANDLE event_handle)
{
? // This dispatch is used for I/O entires.

? ACE_WFMO_Reactor_Handler_Repository::Current_Info &current_info =
??? this->handler_rep_.current_info ()[slot];

? WSANETWORKEVENTS events;
? ACE_Reactor_Mask problems = ACE_Event_Handler::NULL_MASK;
? if (::WSAEnumNetworkEvents ((SOCKET) current_info.io_handle_,
????????????????????????????? event_handle,
????????????????????????????? &events) == SOCKET_ERROR)
??? problems = ACE_Event_Handler::ALL_EVENTS_MASK;
? else
? {
????? // Prepare for upcalls. Clear the bits from <events> representing
????? // events the handler is not interested in. If there are any left,
????? // do the upcall(s). upcall will replace events.lNetworkEvents
????? // with bits representing any functions that requested a repeat
????? // callback before checking handles again. In this case, continue
????? // to call back unless the handler is unregistered as a result of
????? // one of the upcalls. The way this is written, the upcalls will
????? // keep being done even if one or more upcalls reported problems.
????? // In practice this may turn out not so good, but let's see. If any
????? // problems, please notify Steve Huston <shuston@riverace.com>
????? // before or after you change this code.
????? events.lNetworkEvents &= current_info.network_events_;
????? while (events.lNetworkEvents != 0)
????? {
????????? ACE_Event_Handler *event_handler = current_info.event_handler_;

????????? int reference_counting_required =
??????????? event_handler->reference_counting_policy ().value () ==
??????????? ACE_Event_Handler::Reference_Counting_Policy::ENABLED;

????????? // Call add_reference() if needed.
????????? if (reference_counting_required)
????????? {
????????????? event_handler->add_reference ();
????????? }

????????? // Upcall
????????? problems |= this->upcall (current_info.event_handler_,
??????????????????????????????????? current_info.io_handle_,
??????????????????????????????????? events);

????????? // Call remove_reference() if needed.
????????? if (reference_counting_required)
????????? {
????????????? event_handler->remove_reference ();
????????? }

????????? if (this->handler_rep_.scheduled_for_deletion (slot))
??????????? break;
????? }
? }

? if (problems != ACE_Event_Handler::NULL_MASK
????? && !this->handler_rep_.scheduled_for_deletion (slot)? )
??? this->handler_rep_.unbind (event_handle, problems);

? return 0;
}

8
ACE_Reactor_Mask ACE_WFMO_Reactor::upcall (ACE_Event_Handler *event_handler,
?????????????????????????????????????????? ACE_HANDLE io_handle,
?????????????????????????????????????????? WSANETWORKEVENTS &events)
{
? // This method figures out what exactly has happened to the socket
? // and then calls appropriate methods.
? ACE_Reactor_Mask problems = ACE_Event_Handler::NULL_MASK;

? // Go through the events and do the indicated upcalls. If the handler
? // doesn't want to be called back, clear the bit for that event.
? // At the end, set the bits back to <events> to request a repeat call.

? long actual_events = events.lNetworkEvents;
? int action;

? if (ACE_BIT_ENABLED (actual_events, FD_WRITE))
? {
????? action = event_handler->handle_output (io_handle);
????? if (action <= 0)
????? {
????????? ACE_CLR_BITS (actual_events, FD_WRITE);
????????? if (action == -1)
??????????? ACE_SET_BITS (problems, ACE_Event_Handler::WRITE_MASK);
????? }
? }

? if (ACE_BIT_ENABLED (actual_events, FD_CONNECT))
? {
????? if (events.iErrorCode[FD_CONNECT_BIT] == 0)
????? {
????????? // Successful connect
????????? action = event_handler->handle_output (io_handle);
????????? if (action <= 0)
????????? {
????????????? ACE_CLR_BITS (actual_events, FD_CONNECT);
????????????? if (action == -1)
??????????????? ACE_SET_BITS (problems, ACE_Event_Handler::CONNECT_MASK);
????????? }
????? }
????? // Unsuccessful connect
????? else
????? {
????????? action = event_handler->handle_input (io_handle);
????????? if (action <= 0)
????????? {
????????????? ACE_CLR_BITS (actual_events, FD_CONNECT);
????????????? if (action == -1)
??????????????? ACE_SET_BITS (problems, ACE_Event_Handler::CONNECT_MASK);
????????? }
????? }
? }

? if (ACE_BIT_ENABLED (actual_events, FD_OOB))
? {
????? action = event_handler->handle_exception (io_handle);
????? if (action <= 0)
????? {
????????? ACE_CLR_BITS (actual_events, FD_OOB);
????????? if (action == -1)
??????????? ACE_SET_BITS (problems, ACE_Event_Handler::EXCEPT_MASK);
????? }
? }

? if (ACE_BIT_ENABLED (actual_events, FD_READ))
? {
????? action = event_handler->handle_input (io_handle);
????? if (action <= 0)
????? {
????????? ACE_CLR_BITS (actual_events, FD_READ);
????????? if (action == -1)
??????????? ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK);
????? }
? }

? if (ACE_BIT_ENABLED (actual_events, FD_CLOSE)
????? && ACE_BIT_DISABLED (problems, ACE_Event_Handler::READ_MASK))
? {
????? action = event_handler->handle_input (io_handle);
????? if (action <= 0)
????? {
????????? ACE_CLR_BITS (actual_events, FD_CLOSE);
????????? if (action == -1)
??????????? ACE_SET_BITS (problems, ACE_Event_Handler::READ_MASK);
????? }
? }

? if (ACE_BIT_ENABLED (actual_events, FD_ACCEPT))
? {
????? action = event_handler->handle_input (io_handle);
????? if (action <= 0)
????? {
????????? ACE_CLR_BITS (actual_events, FD_ACCEPT);
????????? if (action == -1)
??????????? ACE_SET_BITS (problems, ACE_Event_Handler::ACCEPT_MASK);
????? }
? }

? if (ACE_BIT_ENABLED (actual_events, FD_QOS))
? {
????? action = event_handler->handle_qos (io_handle);
????? if (action <= 0)
????? {
????????? ACE_CLR_BITS (actual_events, FD_QOS);
????????? if (action == -1)
??????????? ACE_SET_BITS (problems, ACE_Event_Handler::QOS_MASK);
????? }
? }

? if (ACE_BIT_ENABLED (actual_events, FD_GROUP_QOS))
? {
????? action = event_handler->handle_group_qos (io_handle);
????? if (action <= 0)
????? {
????????? ACE_CLR_BITS (actual_events, FD_GROUP_QOS);
????????? if (action == -1)
??????????? ACE_SET_BITS (problems, ACE_Event_Handler::GROUP_QOS_MASK);
????? }
? }

? events.lNetworkEvents = actual_events;
? return problems;
}

??????? ACE這個開源項目的代碼的量是很大的。對于系統(tǒng)編程、網(wǎng)絡(luò)編程是非常的有用，但是對其介紹的書和資料是非常的少。要想了解和很好的使用，就必須要自己去看源代碼了。（好在還有三本書，庫中的事例還是比較的多）
??????? ACE庫中的代碼大體可以分為三大部分
??????? 1? OS Adaptation（操作系統(tǒng)適配）部分。這部分主要是屏蔽各操作系統(tǒng)的API的不同，將系統(tǒng)調(diào)用接口統(tǒng)一到C＋＋函數(shù)的接口，以實現(xiàn)平臺的可移植。
??????? 2? C++ Wrapper Facade（C++外包）部分。這部分主要是將相互關(guān)聯(lián)的操作和數(shù)據(jù)結(jié)構(gòu)封裝到C++類中，提供統(tǒng)一的接口。提供強類型的檢測，降低不必要的認(rèn)為錯誤。利用C++多態(tài)、繼承等能力，形成一個架構(gòu)，使本地的、遠(yuǎn)端的操作統(tǒng)一在一個相同接口和使用策略下。
??????? 3? Framework（框架）部分。為一組相關(guān)的應(yīng)用提供可復(fù)用的架構(gòu)。開發(fā)者在確定了應(yīng)用后，選擇可用的架構(gòu)開發(fā)應(yīng)用程序，不用考慮平臺和底層機制。快速的開發(fā)。
??????? 第一部分面對大量的底層的細(xì)節(jié)，而且目標(biāo)是平臺的移植，如果對平臺的移植感興趣的兄弟姐妹可以看看。一般情況下沒什么看的必要。
??????? 第二部分和第三部分對我們的應(yīng)用和學(xué)習(xí)如何利用C++來設(shè)計程序非常的有價值，要多看。細(xì)心揣摩，特別是配上設(shè)計的問題（宏觀的和微觀的）。 ??????? chown??? 設(shè)置文件或目錄的所有權(quán)用戶。
??????? chown 用戶名.組名 文件或目錄名。
?????? 例 1 chown user.group directory? 2 chown user.group file

??????? chmod??? 改變文件或目錄的用戶權(quán)限。
??????? 一個文件或目錄的用戶權(quán)限由三個部分組成 所有者權(quán)限 所有者所在的組的權(quán)限 其他用戶的權(quán)限。每個權(quán)限又由三種權(quán)力組成，讀權(quán)力 寫權(quán)力 執(zhí)行權(quán)力
??????? 例 1 chmod 711 file 所有者有讀、寫、執(zhí)行權(quán)力
???????????????????????????????????????? 所有者所在組用戶有執(zhí)行權(quán)力
???????????????????????????????????????? 其他用戶有執(zhí)行權(quán)力 ??????? 想學(xué)的時候就開始學(xué)習(xí)。聽過設(shè)計模式，心動了，那就開始學(xué)吧。是的，開始時不能明白那里面寫些什么，不要緊，先把它們背下來。里面的實例代碼用手寫一邊，不要只是看一邊。就看那本叫設(shè)計模式的書，這不是說那些以它為根本的注解的書不好，只是個人認(rèn)為注解帶有注解人的理解和思考，看了反而添加了更多的不理解的概念。將寫過的代碼拿出來，用模式的眼光去重新審視，有了想法就去編碼實現(xiàn)，并不但的改進。