ACE技术论文集-第9章连接和初始化通信服务的对象创建模式

class PEER_ACCEPTOR>

class Acceptor : public Event_Handler

{

public:

// Initialize local_addr transport endpoint factory

// and register with Initiation_Dispatcher Singleton.

virtual int open(const PEER_ACCEPTOR::PEER_ADDR &local_addr);

　

// Factory Method that creates, connects, and

// activates SERVICE_HANDLER’s.

virtual int accept (void);

　

protected:

// Defines the handler’s creation strategy.

virtual SERVICE_HANDLER *make_service_handler (void);

　

// Defines the handler’s connection strategy.

virtual int accept_service_handler(SERVICE_HANDLER *);

　

// Defines the handler’s concurrency strategy.

virtual int activate_service_handler(SERVICE_HANDLER *);

　

// Demultiplexing hooks inherited from Event_Handler,

// which is used by Initiation_Dispatcher for

// callbacks.

virtual HANDLE get_handle (void) const;

virtual int handle_close (void);

　

// Invoked when connection requests arrive.

virtual int handle_event (HANDLE, EVENT_TYPE);

　

private:

// IPC mechanism that establishes

// connections passively.

PEER_ACCEPTOR peer_acceptor_;

};

　

// Useful "short-hand" macros used below.

#define SH SERVICE_HANDLER

#define PA PEER_ACCEPTOR

Acceptor通过特定类型的PEER ACCEPTOR和SERVICE HANDLER被参数化。PEER ACCEPTOR提供的传输机制被Acceptor用于被动地建立连接。SERVICE HANDLER提供的服务对与远地对端交换的数据进行处理。注意SERVICE HANDLER是由应用层提供的具体的服务处理器。

参数化类型使Acceptor的连接建立策略与服务处理器的类型、网络编程接口及传输层连接发起协议去耦合。就如同Connector一样，通过允许整体地替换Acceptor所用的机制，参数化类型的使用有助于提高可移植性。这使得连接建立代码可在含有不同网络编程接口（比如有socket，但没有TLI；反之亦然）的平台间移植。例如，取决于平台能够更为高效地支持socket还是TLI，PEER ACCEPTOR模板参数可以通过SOCK Acceptor或TLI Acceptor来实例化。

下面给出Acceptor的方法的实现。应用通过调用Acceptor的open方法来将其初始化。如下所示：

　

template int

Acceptor::open

(const PEER_ACCEPTOR::PEER_ADDR &local_addr)

{

// Forward initialization to the PEER_ACCEPTOR.

peer_acceptor_.open (local_addr);

　

// Register with Initiation_Dispatcher, which

// ‘‘double-dispatches’’ without get_handle()

// method to extract the HANDLE.

Initiation_Dispatcher::instance

()->register_handler (this, READ_MASK);

}

　

local_addr被传递给open方法。该参数含有网络地址，例如，本地主机的IP地址和TCP端口号，用于侦听连接。Open方法将此地址转发给PEER ACCEPTOR定义的被动连接接受机制。该机制初始化传输端点工厂，由后者将地址广告给有兴趣与此Acceptor连接的客户。

传输端点工厂的行为由用户所实例化的PEER ACCEPTOR的类型来决定。例如，它可以是socket[13]、TLI[14]、STREAM管道[15]、Win32命名管道等的C++包装。

在传输端点工厂被初始化后，open方法将其自身登记到Initiation Dispatcher。Initiation Dispatcher执行“双重分派”，回调Acceptor的get_handle方法，以获取底层传输端点工厂的HANDLE。如下所示：

　

template HANDLE

Acceptor::get_handle (void)

{

return peer_acceptor_.get_handle ();

}

　

Initiation Dispatcher在内部表中存储此HANDLE。Synchronous Event Demultipler（同步事件多路分离器），比如select，随即被用于检测和多路分离到来的来自客户的连接请求。因为Acceptor类继承自Event Handler，当连接从对端到达时，Initiation Dispatcher可以自动回调Acceptor的handle_event方法。该方法是一个适配器（Adapter），它将Initiation Dispatcher的事件处理接口转换为对Acceptor的accept方法的调用。如下所示：

　

template int

Acceptor::handle_event (HANDLE, EVENT_TYPE)

{

// Adapt the Initiation_Dispatcher’s event handling

// API to the Acceptor’s API.

accept ();

}

　

如下所示，accept方法是一个模板方法（Template Method）[10]，它为创建新SERVICE HANDLER、将连接接受进其中并启用服务而实现接受器－连接器模式的被动初始化策略：

　

template int

Acceptor::accept (void)

{

// Create a new SERVICE_HANDLER.

SH *service_handler = make_service_handler ();

　

// Accept connection from client.

accept_service_handler (service_handler);

　

// Activate SERVICE_HANDLER by calling

// its open() hook.

activate_service_handler (service_handler);

}

　

该方法非常简洁，因为它将所有低级细节都分解进具体的SERVICE HANDLER和PEER ACCEPTOR中，后二者通过参数化类型被实例化，并可被Acceptor的子类定制。特别地，因为accept是模板方法，子类可以扩展Acceptor的任意或所有的连接建立和初始化策略。这样的灵活性使得开发者有可能编写这样的Service Handler，其行为与它们被被动地连接和初始化的方式是相分离的。

make_service_handler工厂方法定义Acceptor用于创建SERVICE HANDLER的缺省策略。如下所示：

　

template SH *

Acceptor::make_service_handler (void)

{

return new SH;

}

　

缺省行为使用了“请求策略”（demand strategy），它为每个新连接创建新的SERVICE HANDLER。但是，Acceptor的子类可以重定义这一策略，以使用其他策略创建SERVICE HANDLE，比如创建单独的单体（Singleton）[10]或从共享库中动态链接SERVICE HANDLER。

accept_service_handler方法在下面定义Acceptor所用的SERVICE HANDLER连接接受策略：

　

template int

Acceptor::accept_service_handler(SH *handler)

{

peer_acceptor_->accept (handler->peer ());

}

　

缺省行为委托PEER ACCEPTOR所提供的accept方法。子类可以重定义accept_service_handler方法，以执行更为复杂的行为，比如验证客户的身份，以决定是接受还是拒绝连接。

Activate_service_handler定义Acceptor的SERVICE HANDLER并发策略：

　

template int

Acceptor::activate_service_handler(SH *handler)

{

handler->open ();

}

　

该方法的缺省行为是通过调用SERVICE HANDLER的open挂钩将其启用。这允许SERVICE HANDLER选择它自己的并发策略。例如，如果SERVICE HANDLER继承自Event Handler，它可以登记到Initiation Dispatcher，从而在事件发生在SERVICE HANDLER的PEER STREAM通信端点上时，使Initiation Dispatcher能够分派其handle_event方法。Concrete Acceptor可以重定义此策略，以完成更为复杂的并发启用。例如，子类可以使SERVICE HANDLER成为主动对象（Active Object）[5]，使用多线程或多进程来处理数据。

当Acceptor终止时，无论是由于错误还是由于整个应用的关闭，Initiation Dispatcher都调用Acceptor的handle_close方法，后者可以释放任何动态获取的资源。在此例中，handle_close方法简单地将close请求转发给PEER ACCEPTOR的传输端点工厂。如下所示：

　

template int

Acceptor::handle_close (void)

{

peer_acceptor_.close ();

}