短消息网关通信模块的实现
基于以上设计思路，我们实现的短消息通信模块包括四个父进程： CMPP 通信代理 (cmpp_server) 、 SMPP 通信代理 (smpp_server) 、消息分发处理 server(package_server) 和前转消息处理 server(route_server) 。它们之间通过 6 个消息队列相互通信。具体的软件结构如图 2 所示。
Cmpp_server 主要为 SP 和网关之间建立一条高质量的传输通道。它同时侦听与它相连的多个 socket ，通过队列接口函数 mqm_send( ) 把接收到的 CMPP 格式的消息送入队列 2 中。同时，它也要通过函数 mqm_recv( ) 不停的从队列 1 中获得消息，并把它转发到相应的目的 SP 。 cmpp_server 不需判断收到的消息类型，只负责通信，因此称通信代理。
Smpp_server 与 cmpp_server 基本一致，唯一不同的只有一点： SMPP 协议规定 smpp_server 是客户端，需要主动发起建立连接的请求；而 CMPP 协议规定 cmpp_server 是服务器端，需等待对方连接。
Package_server 是短消息网关的核心，所有的消息都要经过它，包括协议转换，超时重传，计费，路由，都需要在 package_server 中完成。 package_server 同时监听 2 、 4 、 6 三个队列，根据不同的消息头来判断这个消息的下一个目的地。路由表也需要在 package_server 中维护，以便 package_server 能得到路由信息，转发消息。如果路由表中找不到相关的信息， package_server 就要把该消息转发给 route_server ，由 route_server 从汇接网关处获得路由信息后发送该消息。
Route_server 主要处理需要转发到其他网关的消息。当 package_server 发现消息的目的地不是本地网关所连的 SP 或 SMSC ，那么它就会把消息转发给 route_server 处理。 Route_server 接到消息后与汇接网关通信，请求目的地的网关地址，然后与目的网关建立 socket 连接，交付该消息并记录前转话单。
在整个通信模块中，所有的 server 都使用队列接口函数 mqm_init( ) 初始化消息队列并复接在队列上。收发数据使用 mqm_send( ) 和 mqm_recv( ) 函数完成。存储消息采用固定的数据结构，其结构如下：
struct mqm_connection {
unsigned int package_server_seqnum; // 由网关自行产生。若消息从队列 4 中来，该元素将是转化后的 CMPP 协议格式的消息序列号；若消息从队列 2 中来，该元素将是转化后的 SMPP 协议格式的消息序列号。
short mqm_sockfd; // 接收该消息的 socket;
short mqm_seqnum; // 收到的消息序列号；
time_t mqm_timeout; // 收到该消息的时间；
int total_length; // 该消息的长度；
char mqm_buf[MAX_PACKET_SIZE]; // 该消息的内容；
char converted_buf[MAX_PACKET_SIZE]; // 转换协议后的消息内容；
};
现以 MO 请求业务为例，描述通信模块的工作流程。
当 SMSC 以 SMPP 格式的 DELIVER_SM 消息发出订阅某个 SP 的言语传情短消息，经由 smpp_server 收到，从队列 4中转发给 package_server 。 Package_server 收到 MO 请求后回送给 SP 一个 SMPP 格式的 DELIVER_SM_REP 应答消息，并用 mqm_connection 结构体存储这条 MO 消息的各个信息。 之后， package_server 就把该消息转换成 CMPP 协议的 CMPP_Deliver 消息，并通过队列 1送到 cmpp_server 中，转发给目的 SP 。 SP 在接收到这个消息后，会产生一个 CMPP 格式 的 CMPP-_Deliver_Rep 的应答消息返回给网关。当 package_server 收到了应答信号，也需要用 mqm_connection 结构体存储。这时，一条 MO 短消息转发成功， package_server 记录 SMO 话单。
下面给出在 Linux7.2版本的操作系统下，用C语言实现的package_server的主要代码：
main （）
{
mqm_init( ); // 初始化队列；
……
pipe( ); // 建立管道 ;
if (( child_pid = fork( ) ) ==0)
{
// 通过管道通知 2 队列有数 ;
while(1){
get_result_msg_info(REQUEST_2,pipfd2[1]);
}
}
……
// 建立监听描述符集 ;
FD_ZERO ( &monit);
FD_SET ( )_;
……
// 处理队列中来的数据
while(1)
{
select ( ); // 监听 2,4,6 队列 ;
if ( FD_ISSET(queue2,&read_monit )) // 如果 2 队列有数 ;
{
handle_queue2_in( );// 处理 2 队列来的数据 ;
}
……
}//end while;
} //end main ；
