ACE程序员教程-第2章 进程间通信服务访问点包装

　　socket、TLI、STREAM管道和FIFO为访问局部和全局IPC机制提供广泛的接口。但是，有许多问题与这些不统一的接口有关联。比如类型安全的缺乏和多维度的复杂性会导致成问题的和易错的编程。

　　ACE的IPC SAP类属提供了统一的层次类属，对那些麻烦而易错的接口进行封装。在保持高性能的同时，IPC SAP被设计用于改善通信软件的正确性、易学性、可移植性和可复用性。

图2-1 IPC SAP类属

　　根据底层使用的不同IPC接口，IPC SAP类被划分为四种主要的类属，图2-1描述了这一划分。ACE_IPC_SAP类提供的一些函数是所有IPC接口公有的。有四个不同的类由此类派生而出，每个类各自代表ACE包含的一种IPC SAP包装类属。这些类封装适用于特定IPC接口的功能。例如，ACE_SOCK类包含的功能适用于BSD socket编程接口，而ACE_TLI包装TLI编程接口。

　　在这四个类的每一个类下面都有一整层次的包装类，它们完整地包装底层接口，并提供高度可复用、模块化、安全和易用的包装类。

　　该类属中的类都位于ACE_SOCK之下；它提供使用BSD socket编程接口的Internet域和UNIX域协议族的接口。这个类属中的类被进一步划分为：

• Dgram类和Stream类：Dgram类基于UDP数据报协议，提供不可*的无连接消息传递功能。另一方面，Stream类基于TCP协议，提供面向连接的消息传递。
• Acceptor、Connector类和Stream类：Acceptor和Connector类分别用于被动和主动地建立连接。Acceptor类封装BSD accept()调用，而Connector封装BSD connect()调用。Stream类用于在连接建立之后提供双向的数据流，并包含有发送和接收方法。

　　表2-1详细描述了该类属中的类以及它们的职责：

表2-1 ACE_SOCK中的类及其职责

　　在下面的部分，我们将要演示怎样将IPC_SAP包装类直接用于处理进程间通信。记住这些只是ACE的冰山一角。在教程的后续章节中将会介绍其他类和组件。

　　ACE中的流包装提供面向连接的通信。流数据传输包装类包括ACE_SOCK_Stream和ACE_LSOCK_Stream，它们分别包装TCP/IP和UNIX域socket协议数据传输功能。连接建立类包括针对TCP/IP的ACE_SOCK_Connector和ACE_SOCK_Acceptor，以及针对UNIX域socket的ACE_LSOCK_Connector和ACE_LSOCK_Acceptor。

　　Acceptor类用于被动地接受连接（使用BSD accept()调用），而Connector类用于主动地建立连接（使用BSD connect()调用）。

　　下面的例子演示接收器和连接器是怎样用于建立连接的。该连接随后将用于使用流数据传输类来传输数据。

例2-1

classServer

Server(int port): server_addr_(port),peer_acceptor_(server_addr_)

{

data_buf_= new char[SIZE_BUF];

}

//Handle the connection once it has been established. Here the

//connection is handled by reading SIZE_DATA amount of data from the

//remote and then closing the connection stream down.

inthandle_connection()

{

// Read data from client

for(int i=0;i

{

int byte_count=0;

if( (byte_count=new_stream_.recv_n (data_buf_, SIZE_DATA, 0))==-1)

ACE_ERROR ((LM_ERROR, "%p\n", "Error in recv"));

else

{

data_buf_[byte_count]=0;

ACE_DEBUG((LM_DEBUG,"Server received %s \n",data_buf_));

}

}

// Close new endpoint

if (new_stream_.close () == -1)

ACE_ERROR ((LM_ERROR, "%p\n", "close"));

return 0;

}

//Use the acceptor component peer_acceptor_ to accept the connection

//into the underlying stream new_stream_. After the connection has been

//established call the handle_connection() method.

intaccept_connections()

{

if (peer_acceptor_.get_local_addr (server_addr_) == -1)

ACE_ERROR_RETURN ((LM_ERROR,"%p\n","Error in get_local_addr"),1);

　

ACE_DEBUG ((LM_DEBUG,"Starting server at port %d\n",

server_addr_.get_port_number ()));

　

// Performs the iterative server activities.

while(1)

{

ACE_Time_Value timeout (ACE_DEFAULT_TIMEOUT);

if (peer_acceptor_.accept (new_stream_, &client_addr_, &timeout)== -1)

{

ACE_ERROR ((LM_ERROR, "%p\n", "accept"));

continue;

}

else

{

ACE_DEBUG((LM_DEBUG,

"Connection established with remote %s:%d\n",

client_addr_.get_host_name(),client_addr_.get_port_number()));

//Handle the connection

handle_connection();

}

}

}

private:

char *data_buf_;

ACE_INET_Addr server_addr_;

ACE_INET_Addr client_addr_;

ACE_SOCK_Acceptor peer_acceptor_;

ACE_SOCK_Stream new_stream_;

};

intmain(int argc, char *argv[])

{

if(argc<2)

{

ACE_ERROR((LM_ERROR,"Usage %s", argv[0]));

ACE_OS::exit(1);

}

Server server(ACE_OS::atoi(argv[1]));

server.accept_connections();

}

上面的例子创建了一个被动服务器，侦听到来的客户连接。在连接建立后，服务器接收来自客户的数据，然后关闭连接。Server类表示该服务器。

TAG: IPC SAP 进程 通信服务 访问 包装 SOCKET Stream