该Tutorial程序实现了一个简单的服务器。功能是把客户端发送的字符在屏幕上打印出来。
该Tutorial中最先出现的类是ACE_Reactor。通过阅读该Tutorial的source。发现该类的功能是一个消息泵。通过ACE_Reactor::register_handler()将处理消息的handler注册到ACE_Reactor中去。然后调用ACE_Reactor::handle_events()。ACE_Reactor将把各种消息按类型发往相应的ACE_Event_Handler类(或者其派生类)对消息进行处理。
ACE_Reactor *g_reactor;
main(int, char *[])
{
ACE_NEW_RETURN (g_reactor,
ACE_Reactor,
1);
//该语句创建了一个ACE_Reactor。
.
.
.
for (;;)
g_reactor->handle_events ();
//这里用了一个死循环来让ACE_Reactor不断的处理消息。
}
根据程序的功能,我们需要处理两种消息,一个是当客户端连接进来的时候,另一个是客户端发送信息的时候。这两种消息在ACE中对应的是ACE_Event_Handler::ACCEPT_MASK和ACE_Event_Handler::READ_MASK。所以我们需要两个类来处理两种消息,他们都是从ACE_Event_Handler继承下来的。
Logging_Acceptor对应于处理ACE_Event_Handler::ACCEPT_MASK消息。由于该类要监听端口。该功能由类ACE_SOCK_Acceptor实现。因此Logging_Acceptor内有一个类型为ACE_SOCK_Acceptor的成员变量peer_acceptor_。
Logging_Acceptor::open函数用ACE_SOCK_Acceptor来监听端口ACE_DEFAULT_SERVER_PORT(20002),并且将自己注册到ACE_Reactor中。
virtual ACE_HANDLE Logging_Acceptor::get_handle (void) const函数重载了基类的虚函数。在注册到ACE_Reactor中时,该函数会被调用。取得监听中的Handler。该函数简单的返回peer_acceptor_就可以了。
virtual int Logging_Acceptor::handle_input (ACE_HANDLE fd)函数是事件处理函数。当有用户连入时,该函数将被调用。对应于收到的每个连接该函数生成一个Logging_Handler的实例来处理具体每个连接。这个函数的注释很详细了。
Logging_Handler对应于每个连入的连接。当收到客户端发送的信息时,virtual int Logging_Handler::handle_input (ACE_HANDLE fd)将会被调用,处理收到的信息。该函数用ACE_SOCK_Stream来收取客户端发送的信息。并且将其用宏ACE_DEBUG打印在屏幕上。
Logging_Handler也是在Logging_Handler::open()函数中,将自己注册到ACE_Reactor中的。
Logging_Handler还必须要处理的一个消息是客户端断开了连接。该消息在int handle_close (ACE_HANDLE, ACE_Reactor_Mask _mask)中被处理。将自己从ACE_Reactor中移去。
到这里为止,整个程序就完成了。问题是该程序最后会陷入一个死循环。我们可以用ctrl+z来终止程序。该程序还可能有潜在的内存泄露。