摘 要:在阐述短消息网关结构的基础上,提出了短消息网关通信模块的设计思想,并给出了该通信模块的具体实现。

关键词:短消息; 短消息网关; 通信

1 前言
随着通信技术的发展,无线互联网短消息业务正在为用户提供越来越多的服务。人们不仅可以通过手机点播定制新闻、股票信息、天气预报,还可以下载铃声、图片等。无论需要什么样的信息,我们都可以随时随地地通过手机接入互联网络,享受各种服务。电信运营商要实现这些增值业务,就必须支持网间的互联互通。
目前实现网间互联互通的方式有四种,包括:通过移动关口局互联互通;通过信令转接点互联互通;通过短消息网关互联互通;通过第三方运营商系统互联互通。前两种方式不易设置计费点和引出计费话单,因此不利于网间结算;最后一种方式,虽然能够保证计费点和结算点的统一,但是易受到地域条件的限制。而通过短消息网关实现互联互通,无须对现网运行的设备进行大面积的数据改动和升级改造,能够合理的设置计费点,保证计费的准确性,实现业务鉴权和业务过滤的功能,保证网络的安全,也能够通过对业务流量的监视和控制,防止网络风暴的发生,这种互联方式具有其他三种方式不可比拟的优点。目前,大部分短消息业务的互联互通都是使用短消息网关来实现。
2 短消息网关结构
短消息网关(ISMG)是处于短消息中心(SMSC)和业务提供商(SP)之间的设备,它为这两个实体的数据交换提供安全、快捷的通道。网关与短消息中心之间使用SMPP协议(Short Message Peer to Peer,短消息点对点协议), 与SP之间使用CMPP协议(China Mobile Peer to Peer,中国移动点对点协议),因此短消息网关需要完成协议的转换、计费、路由、安全和网络管理等功能。其结构图如图1所示。
具体说来,图1中SMPP通信代理系统主要实现网关和GSM网中短消息中心(SMSC)的连接,确保准确接收和发送数据,实现高效、可靠的数据传输。为了达到规范要求的不超过0.001%的数据丢包率,SMPP通信代理需要支持流量控制。CMPP通信代理系统主要是实现和SP服务提供商的连接,与SMPP通信代理系统不同的是,由于协议的影响,CMPP通信代理是服务器端,需等待SP的连接,而SMPP通信代理是客户端,需要主动连接SMSC。短消息网关处理系统是网关中最复杂的处理进程,它完成的任务包括:向GNS(汇接网关) 查询路由,维护路由表,进行协议转换和数据分发。防火墙系统主要为网关系统提供安全保障,它包括IP包过滤和身份验证。短信网关计费系统主要形成各种计费话单,为计费提供依据。业务管理系统主要完成对业务进行统计报告,生成报表,为运营者对用户数据的添加、修改、删除以及对网关系统的监控、查询、操作和维护提供接口和界面。

3 短消息网关通信模块的设计与实现
短消息网关通信模块是整个短消息网关的基础。无论是计费、统计,还是超时重传,高质量的通信构架是必不可少的保障。这个通信构架不仅要完成基本的收发消息的功能,而且还要有好的结构以支撑各种业务需求,保证良好的扩展性。
3.1. 短消息网关通信模块的设计
在设计短消息网关通信模块时,我们考虑了以下几点:
第一,由于短消息网关功能繁多,如果把通信和具体业务合在一起开发,容易顾此失彼。可能会因为开始的考虑不周全,造成在增加某项新业务时不得不修改通信底层和原来的业务代码,导致重复开发。所以我们采用通信代理的方式把通信和具体业务分开,在增加新业务时,就只需少量修改通信代理的设置,而且不必再改动原来的业务代码了。
第二,通信代理需要同时侦听多个端口,我们选用多路复用I/O这种方式。虽然多线程能够通过并行计算和共享内存提高代码效率和资源利用率,但在短消息网关中,处理的数据量大,多线程方式的并行处理会造成一些消息的逻辑混乱,资源共享也会增加代码的复杂度。而多路复用使用简单,逻辑清晰明了,不易发生错误,也不会出现因资源共享带来同步和互斥问题。因此使用多路复用I/O是比较合理的。
第三,业务处理模块与通信代理之间可以使用队列进行通信,对队列的管理和参数的设置(例如对同一队列操作的互斥,以及队列个数的设置等)都使用专门的队列内核程序统一调度并封装成函数接口,以方便业务处理模块对队列的使用。另外,通过队列通信,也可以为今后增加的业务提供良好的扩展性。
第四,为了达到99.999%的不丢包率,通信代理需要使用流量控制机制以保证网关内部不丢包。这是因为无论队列设置有多大,如果出现消息只发不收的情况,都会造成队列溢出而丢包。因此,为每个队列中缓存的消息做记录,当某个时刻队列消息的数量达到规定限度,队列就不再收包,以保证到达网关的消息不会丢失。
3.2. 短消息网关通信模块的实现
基于以上设计思路,我们实现的短消息通信模块包括四个父进程: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;
4 结束语
短消息网关是无线互联网短消息业务中最为关键的一个设备,它为手机用户和互联网的信息资源架起了一座桥梁。本文中短消息网关的通信模块设计周全,结构合理,为计费、路由、超时重传等模块提供了良好的扩展性。经实验室测试,在奔2处理器,64兆内存的机器上,收发包速率为每秒5000条,不丢包率达到100%,是一个稳定的系统。
参考文献
[1] 短消息网关设备规范(V1.2).中国移动通信集团公司,2001.
[2] 中国移动通信短消息网关测试规范(V1.2). 中国移动通信公司,2001.
[3] 中国移动通信信息资源站实体与互联网短消息网关接口协议(V1.3).中国移动通信集团公司,2001.
[4] Short Message Peer to Peer Protocol Specification v3.4 .SMPP Developers Forum,1999.
[5] W.Richard Stevens.UNIX网络编程.施振川,周利民,孙宏晖等译.清华大学出版社,1999.

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/10294527/viewspace-125467/,如需转载,请注明出处,否则将追究法律责任。

转载于:http://blog.itpub.net/10294527/viewspace-125467/

短消息网关通信模块的设计与实现(转)相关推荐

  1. 短消息网关系统接口协议

    1概述 1.1协议说明 本协议是SMG和SP之间.SMG和GNS之间.以及SMG和SMG之间的接口协议,简称SGIP. 通过应用SGIP协议,SP可以接入到SMG,实现SP应用的一点接入.全网服务:S ...

  2. 企业短信应用平台的设计

    手机短信作为一种非常重要的沟通方式,正在被越来越多的企业重视.本文介绍的企业短信应用平台简单易行,可以为企业提供方便灵活的.基于短信的双向交流渠道. 多年来,及时准确地采集前端销售数据.快速地将各种消 ...

  3. 5G 短消息解决方案

    短信作为传统无线网络的基础业务,随着移动网络的飞速发展,我们会发现,在日常生活中我们使用短信进行沟通的情况越来越少了. 但是在我们使用各种业务的时候,仍然离不开短信,例如: 注册新的APP.密码找回, ...

  4. SS7网络中的短消息服务(SMS): 使用模块化设备优化利润

    ■ 概 述 电信设备制造商(TEM)和服务提供商在寻找可以从新服务中产生销售额的方法. 应用程序使用短消息服务(SMS)是一个理想的方法来增加收入而不需要做很大的设备架构投资. 七号信令 (SS7) ...

  5. 基于短消息的远程家电红外遥控系统

    基于短消息的远程家电红外遥控系统 通过远程广域网控制家电设备是信息家电的主要发展方向之一.由于价格低廉.覆盖面广.使用方便等原因,短消息平台已经成为远程家电控制的重要方法. 本文研究和开发了一种基于短 ...

  6. 多媒体短消息业务及其实现(转)

    当今的社会流行着一种新的时尚,被称之为"拇指文化",尽管历来拇指被认为是五个手指中最笨拙的手指,但是由于移动信息的出现改变了它的历史地位.我们到处能见忙碌着发送短信的人们.短信在经 ...

  7. Android发送短消息程序的总结

    1.1      准备的基础知识 1.1.1          PendingIntent类 pendingIntent字面意义:等待的,未决定的Intent. 要得到一个pendingIntent对 ...

  8. 消息队列背后的设计思想

    作者:jaydenwen,腾讯 PCG 后台开发工程师 消息队列也通常称为消息中间件,提到消息队列,大部分互联网人或多或少都听过该名词.对于后端工程师而言,更是日常开发中必备的一项技能.随着大数据时代 ...

  9. WCDMA的短消息业务协议分析

    2019独角兽企业重金招聘Python工程师标准>>> 基于WCDMA的短消息业务协议分析 2009年06月22日 09:08 来源:本站整理 作者:佚名 我要评论(0) 摘 要:  ...

最新文章

  1. 《windows核心编程系列》二谈谈ANSI和Unicode字符集
  2. 阿联酋阿布扎比人工智能大学招收全奖博士,年薪20.9W
  3. 12月18日云栖精选夜读 | Java 中创建对象的 5 种方式!...
  4. Python入门100题 | 第068题
  5. 学习okhttp wiki--Connections.
  6. (1) 使用supervisor提高nodejs调试效率
  7. mysql技术内幕sampdb_MySql技术内幕之MySQL入门(1)
  8. 校门外的树(洛谷-P1047)
  9. 【Oracle】ORA-30042: Cannot offline the undo tablespace
  10. GitHub上最火的74个Android开源项目(三)
  11. P2962 [USACO09NOV]灯Lights 对抗搜索
  12. arm-4-裸板开发
  13. pr 无法启动因为计算机丢失,pramtlib.dll_“PR打不开,因为计算机丢失TimeWarpFilter.dll”是怎么回事?怎么办啊?_prccamtlib.dll...
  14. 首款搭载国产龙芯 CPU 的域名服务器发布
  15. 如何使用视频格式转换器将flv转换成MP4
  16. JAVA Math函数向上取整和向下取整
  17. 信贷反欺诈体系介绍及其策略规则应用
  18. 烷烃同分异构体数目的计算
  19. isca2017_papers笔记: Stream-Dataflow Acceleration
  20. R包--ChAMP--甲基化芯片处理(450K、850K)

热门文章

  1. python注销一段代码_好用到哭!你需要立刻学会的20个Python代码段
  2. 王者荣耀s12服务器维护,王者荣耀S12新增排位保护卡,输了也不用担心掉段了!...
  3. Microsoft LDAP 配置页中输入有效的用户名及密码,microsoft ldap 配置页中输入有效的用户名
  4. 网站安全检测:推荐 8 款免费的 Web 安全测试工具
  5. Git 回滚代码到指定版本
  6. java对象数组赋值
  7. 练习:两数相加(链表逆序存储求和数字)
  8. Idea代码提示没有String问题
  9. H5基于canvas实现电子签名并生成PDF文档
  10. mysql中三目运算_mysql三目运算使用示例