短消息網關通信模塊的實現
基于以上設計思路，我們實現的短消息通信模塊包括四個父進程： 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 ；
