一种短信网关中并行业务处理的系统和方法

    公开(公告)号:CN101616366A

    公开(公告)日:2009-12-30

    申请号:CN200810068123.3

    申请日:2008-06-24

    Inventor: 殷庆 王荣

    Abstract: 本发明公开了一种短信网关中并行业务处理的系统及方法,其系统包括一消息入口用于从通信模块接收业务消息,并向业务通道发送待处理的短消息;所述业务通道设置为并行的多个,每一所述业务通道为一条短消息所需要经过的所有处理逻辑,包括业务逻辑判断单元、状态维护单元、业务处理单元;所述状态维护单元用于对短消息的状态进行维护和更新,所述的业务处理单元用于完成基本的业务处理功能,具有业务处理功能的单一性和原子性的特点。本发明系统和方法由于采用了并行处理的多个业务通道,显著提高了短消息网关的业务处理能力,克服了业务处理的性能瓶颈,提高了多CPU机器的硬件使用率,有效降低了系统成本,保护和延长了系统的投资。

    一种基于并行队列的短消息重试系统及方法

    公开(公告)号:CN101616365A

    公开(公告)日:2009-12-30

    申请号:CN200810068121.4

    申请日:2008-06-24

    Inventor: 殷庆

    Abstract: 本发明公开了一种基于并行队列的短消息重试系统及方法,其系统包括一重试处理模块;一业务处理模块;一通信模块;所述重试处理模块包括:一消息分发控制单元,用于接收需要重试的消息,根据分发策略将重试消息分发到多个重试通道中;多个重试通道,每一重试通道形成一完整处理重试消息的处理逻辑机;一共享重试配置数据单元,用于配置并行重试处理的基础参数;一集中反馈式动态流量控制单元,用于控制当前目的网元的重试流量;一消息出口单元,将重试消息发送到通信模块,再发送到目的网元。本发明系统及方法由于采用了根据当前系统的流量触发流控,显著提高了短消息网关的重试处理能力,有效降低了系统成本,实现了高效的短消息重试功能。

    一种短信网关处理等待回执消息的方法

    公开(公告)号:CN101420667B

    公开(公告)日:2012-07-04

    申请号:CN200710124180.4

    申请日:2007-10-24

    Abstract: 本发明公开了一种短信网关处理等待回执消息的方法,其设置在一短信网关上,并包括步骤如下:所述短信网关启动时,申请具有一预定大小的内部存储器,并初始化其外部存储器;所述短信网关接收到上级网元的短信请求,并转发到下级网元成功后,将该等待回执的消息存入所述内部存储器中;清理所述内部存储器中的部分等待回执的消息保存到所述外部存储器中;所述短信网关从下级网元收到回执后,在所述内部存储器和外部存储中查询对应的消息。本发明方法由于采用了采用分级存储的方式,实现对等待回执消息的存储和查询,实现了既具有全内存缓存的高速度,又具有全外部存储器缓存的大容量,兼具性能和存储的大容量特点。

    一种短消息系统中对网元进行重试的方法

    公开(公告)号:CN100461882C

    公开(公告)日:2009-02-11

    申请号:CN200510080390.9

    申请日:2005-07-04

    Abstract: 本发明的一种短消息系统中对网元进行重试的方法,在本网元给下级网元转发消息失败后形成重试消息,进入重试流程,所述重试消息存放在重试内存,所述重试内存已满时放入到数据库中,以对重试消息进行存储。本发明方法由于系统采用了两级缓存,解决了重试内存存储的局限性;通过设置发送队列,实现了多个目的网元对重试内存的存储共享;通过发送流量控制,实现了对短消息的有效重试和平滑重试;采用以上方法实现的重试流程,能够完整地解决当前短消息重试中的问题,能够最大限度地提高重试成功率。

    一种多模块短消息系统的负荷分担方法

    公开(公告)号:CN1937787A

    公开(公告)日:2007-03-28

    申请号:CN200510104840.3

    申请日:2005-09-21

    Abstract: 本发明公开了一种多模块短消息系统的负荷分担方法,其包括多个节点用于对短消息的处理,并包括:按各个节点的实际配置来分配各个节点处理能力的比例值;从短消息内容中选取出特征值;将各个节点的比例值相加得到基数值;将该短消息的特征值按所述基数值进行取模运算得到模数;根据所得模数结合各个节点的比例值,得到该短消息应该由哪个节点处理。本发明方法很好的处理了在多模块的短消息系统中消息分发的问题,而且使消息分发无论是节点状态正常或者出现异常时都能够很好的按比例分配消息,方法简单、实用。

    一种基于TCP并发多链路的通信系统及其方法

    公开(公告)号:CN101159747B

    公开(公告)日:2010-09-01

    申请号:CN200710177220.1

    申请日:2007-11-12

    Inventor: 殷庆 程均 尹朝东

    Abstract: 本发明公开了一种基于TCP并发多链路的通信系统及其方法,其中该系统包括:收发线程组、动态分配链接池、链路状态机、消息接口;收发线程组用于完成链路的数据接收和发送,并根据数据接收和发送的状态改变链路状态机的当前工作状态;动态分配链接池用于管理通信系统与外部网元之间建立的链接;当发送或接收链路数据时,收发线程组通过调用动态分配链接池的服务创建相应的链路,并通过链路状态机登记相应的事件通知的回调服务;链路状态机根据外部网元链路请求的发起、接收情况捕获相应的链路事件,并通过收发线程组的回调服务完成链路数据的发送或接收。本发明提高了系统的并发链接数,提高系统在高并发链接、大数据传输时的处理效率和实时性。

    一种短消息网关多协议转换装置及其方法

    公开(公告)号:CN101150584A

    公开(公告)日:2008-03-26

    申请号:CN200710176645.0

    申请日:2007-10-31

    Abstract: 本发明公开了一种短消息网关多协议转换装置及其方法,其中该装置包括:通信收发模块、协议适配模块、业务处理模块、管理配置模块;通信收发模块通过通信链路完成外部网元的外部协议数据包的接收和发送;通信收发模块调用协议适配模块将外部协议数据包转换成内部统一短消息格式数据包,并发送至业务处理模块;业务处理模块对内部统一短消息格式数据包进行处理得到目的网元的配置信息,根据该配置信息通过调用协议适配模块将内部统一短消息格式数据包转换为目的协议数据包,并通过通信收发模块发送至目的网元;管理配置模块提供上述模块所需的配置信息。本发明具有良好的可扩展性和可维护性,大大降低了短消息网关软件开发难度,减少了开发周期。

    一种基于并行队列的短消息重试系统及方法

    公开(公告)号:CN101616365B

    公开(公告)日:2012-12-05

    申请号:CN200810068121.4

    申请日:2008-06-24

    Inventor: 殷庆

    Abstract: 本发明公开了一种基于并行队列的短消息重试系统及方法,其系统包括一重试处理模块;一业务处理模块;一通信模块;所述重试处理模块包括:一消息分发控制单元,用于接收需要重试的消息,根据分发策略将重试消息分发到多个重试通道中;多个重试通道,每一重试通道形成一完整处理重试消息的处理逻辑机;一共享重试配置数据单元,用于配置并行重试处理的基础参数;一集中反馈式动态流量控制单元,用于控制当前目的网元的重试流量;一消息出口单元,将重试消息发送到通信模块,再发送到目的网元。本发明系统及方法由于采用了根据当前系统的流量触发流控,显著提高了短消息网关的重试处理能力,有效降低了系统成本,实现了高效的短消息重试功能。

    一种短信网关处理等待回执消息的方法

    公开(公告)号:CN101420667A

    公开(公告)日:2009-04-29

    申请号:CN200710124180.4

    申请日:2007-10-24

    Abstract: 本发明公开了一种短信网关处理等待回执消息的方法,其设置在一短信网关上,并包括步骤如下:所述短信网关启动时,申请具有一预定大小的内部存储器,并初始化其外部存储器;所述短信网关接收到上级网元的短信请求,并转发到下级网元成功后,将该等待回执的消息存入所述内部存储器中;清理所述内部存储器中的部分等待回执的消息保存到所述外部存储器中;所述短信网关从下级网元收到回执后,在所述内部存储器和外部存储中查询对应的消息。本发明方法由于采用了采用分级存储的方式,实现对等待回执消息的存储和查询,实现了既具有全内存缓存的高速度,又具有全外部存储器缓存的大容量,兼具性能和存储的大容量特点。

    一种基于TCP并发多链路的通信系统及其方法

    公开(公告)号:CN101159747A

    公开(公告)日:2008-04-09

    申请号:CN200710177220.1

    申请日:2007-11-12

    Inventor: 殷庆 程均 尹朝东

    Abstract: 本发明公开了一种基于TCP并发多链路的通信系统及其方法,其中该系统包括:收发线程组、动态分配链接池、链路状态机、消息接口;收发线程组用于完成链路的数据接收和发送,并根据数据接收和发送的状态改变链路状态机的当前工作状态;动态分配链接池用于管理通信系统与外部网元之间建立的链接;当发送或接收链路数据时,收发线程组通过调用动态分配链接池的服务创建相应的链路,并通过链路状态机登记相应的事件通知的回调服务;链路状态机根据外部网元链路请求的发起、接收情况捕获相应的链路事件,并通过收发线程组的回调服务完成链路数据的发送或接收。本发明提高了系统的并发链接数,提高系统在高并发链接、大数据传输时的处理效率和实时性。

Patent Agency Ranking