短消息網(wǎng)關(guān)通信模塊的實現(xiàn)

   基于以上設(shè)計思路，我們實現(xiàn)的短消息通信模塊包括四個父進程： CMPP 通信代理 (cmpp_server) 、 SMPP 通信代理 (smpp_server) 、消息分發(fā)處理 server(package_server) 和前轉(zhuǎn)消息處理 server(route_server) 。它們之間通過 6 個消息隊列相互通信。具體的軟件結(jié)構(gòu)如圖 2 所示。

   Cmpp_server 主要為 SP 和網(wǎng)關(guān)之間建立一條高質(zhì)量的傳輸通道。它同時偵聽與它相連的多個 socket ，通過隊列接口函數(shù) mqm_send( ) 把接收到的 CMPP 格式的消息送入隊列 2 中。同時，它也要通過函數(shù) mqm_recv( ) 不停的從隊列 1 中獲得消息，并把它轉(zhuǎn)發(fā)到相應(yīng)的目的 SP 。 cmpp_server 不需判斷收到的消息類型，只負責通信，因此稱通信代理。

   Smpp_server 與 cmpp_server 基本一致，唯一不同的只有一點： SMPP 協(xié)議規(guī)定 smpp_server 是客戶端，需要主動發(fā)起建立連接的請求；而 CMPP 協(xié)議規(guī)定 cmpp_server 是服務(wù)器端，需等待對方連接。

   Package_server 是短消息網(wǎng)關(guān)的核心，所有的消息都要經(jīng)過它，包括協(xié)議轉(zhuǎn)換，超時重傳，計費，路由，都需要在 package_server 中完成。 package_server 同時監(jiān)聽 2 、 4 、 6 三個隊列，根據(jù)不同的消息頭來判斷這個消息的下一個目的地。路由表也需要在 package_server 中維護，以便 package_server 能得到路由信息，轉(zhuǎn)發(fā)消息。如果路由表中找不到相關(guān)的信息， package_server 就要把該消息轉(zhuǎn)發(fā)給 route_server ，由 route_server 從匯接網(wǎng)關(guān)處獲得路由信息后發(fā)送該消息。

   Route_server 主要處理需要轉(zhuǎn)發(fā)到其他網(wǎng)關(guān)的消息。當 package_server 發(fā)現(xiàn)消息的目的地不是本地網(wǎng)關(guān)所連的 SP 或 SMSC ，那么它就會把消息轉(zhuǎn)發(fā)給 route_server 處理。 Route_server 接到消息后與匯接網(wǎng)關(guān)通信，請求目的地的網(wǎng)關(guān)地址，然后與目的網(wǎng)關(guān)建立 socket 連接，交付該消息并記錄前轉(zhuǎn)話單。

   在整個通信模塊中，所有的 server 都使用隊列接口函數(shù) mqm_init( ) 初始化消息隊列并復接在隊列上。收發(fā)數(shù)據(jù)使用 mqm_send( ) 和 mqm_recv( ) 函數(shù)完成。存儲消息采用固定的數(shù)據(jù)結(jié)構(gòu)，其結(jié)構(gòu)如下：

   struct mqm_connection {

   unsigned int package_server_seqnum; // 由網(wǎng)關(guān)自行產(chǎn)生。若消息從隊列 4 中來，該元素將是轉(zhuǎn)化后的 CMPP 協(xié)議格式的消息序列號；若消息從隊列 2 中來，該元素將是轉(zhuǎn)化后的 SMPP 協(xié)議格式的消息序列號。

   short mqm_sockfd; // 接收該消息的 socket;

   short mqm_seqnum; // 收到的消息序列號；

   time_t mqm_timeout; // 收到該消息的時間；

   int total_length; // 該消息的長度；

   char mqm_buf[MAX_PACKET_SIZE]; // 該消息的內(nèi)容；

   char converted_buf[MAX_PACKET_SIZE]; // 轉(zhuǎn)換協(xié)議后的消息內(nèi)容；

   };

   現(xiàn)以 MO 請求業(yè)務(wù)為例，描述通信模塊的工作流程。

   當 SMSC 以 SMPP 格式的 DELIVER_SM 消息發(fā)出訂閱某個 SP 的言語傳情短消息，經(jīng)由 smpp_server 收到，從隊列 4中轉(zhuǎn)發(fā)給 package_server 。 Package_server 收到 MO 請求后回送給 SP 一個 SMPP 格式的 DELIVER_SM_REP 應(yīng)答消息，并用 mqm_connection 結(jié)構(gòu)體存儲這條 MO 消息的各個信息。 之后， package_server 就把該消息轉(zhuǎn)換成 CMPP 協(xié)議的 CMPP_Deliver 消息，并通過隊列 1送到 cmpp_server 中，轉(zhuǎn)發(fā)給目的 SP 。 SP 在接收到這個消息后，會產(chǎn)生一個 CMPP 格式 的 CMPP-_Deliver_Rep 的應(yīng)答消息返回給網(wǎng)關(guān)。當 package_server 收到了應(yīng)答信號，也需要用 mqm_connection 結(jié)構(gòu)體存儲。這時，一條 MO 短消息轉(zhuǎn)發(fā)成功， package_server 記錄 SMO 話單。

   下面給出在 Linux7.2版本的操作系統(tǒng)下，用C語言實現(xiàn)的package_server的主要代碼：

   main （）

   {

   mqm_init( ); // 初始化隊列；

   ……

   pipe( ); // 建立管道 ;

   if (( child_pid = fork( ) ) ==0)

   {

   // 通過管道通知 2 隊列有數(shù) ;

   while(1){

   get_result_msg_info(REQUEST_2,pipfd2[1]);

   }

   }

   ……

   // 建立監(jiān)聽描述符集 ;

   FD_ZERO ( &monit);

   FD_SET ( )_;

   ……

   // 處理隊列中來的數(shù)據(jù)

   while(1)

   {

   select ( ); // 監(jiān)聽 2,4,6 隊列 ;

   if ( FD_ISSET(queue2,&read_monit )) // 如果 2 隊列有數(shù) ;

   {

   handle_queue2_in( );// 處理 2 隊列來的數(shù)據(jù) ;

   }

   ……

   }//end while;

   } //end main ；