• 四川郎酒股份有限公司获第十二届人民企业社会责任奖年度环保奖 2019-05-13
  • 银保监会新规剑指大企业多头融资和过度融资 2019-05-12
  • 韩国再提4国联合申办世界杯 中国网友无视:我们自己来 2019-05-11
  • 中国人为什么一定要买房? 2019-05-11
  • 十九大精神进校园:风正扬帆当有为 勇做时代弄潮儿 2019-05-10
  • 粽叶飘香幸福邻里——廊坊市举办“我们的节日·端午”主题活动 2019-05-09
  • 太原设禁鸣路段 设备在测试中 2019-05-09
  • 拜耳医药保健有限公司获第十二届人民企业社会责任奖年度企业奖 2019-05-08
  • “港独”没出路!“梁天琦们”该醒醒了 2019-05-07
  • 陈卫平:中国文化内涵包含三方面 文化复兴表现在其中 2019-05-06
  • 人民日报客户端辟谣:“合成军装照”产品请放心使用 2019-05-05
  • 【十九大·理论新视野】为什么要“建设现代化经济体系”?   2019-05-04
  • 聚焦2017年乌鲁木齐市老城区改造提升工程 2019-05-04
  • 【专家谈】上合组织——构建区域命运共同体的有力实践者 2019-05-03
  • 【华商侃车NO.192】 亲!楼市火爆,别忘了买车位啊! 2019-05-03
    • / 16
    • 下载费用:30 金币  

    重庆时时彩钱取不出来: 一种消息发送系统和方法.pdf

    关 键 词:
    一种 消息 发送 系统 方法
      专利查询网所有资源均是用户自行上传分享,仅供网友学习交流,未经上传用户书面授权,请勿作他用。
    摘要
    申请专利号:

    CN201410072445.0

    申请日:

    2014.02.28

    公开号:

    CN103796182A

    公开日:

    2014.05.14

    当前法律状态:

    授权

    有效性:

    有权

    法律详情: 专利权人的姓名或者名称、地址的变更IPC(主分类):H04W 4/12变更事项:专利权人变更前:杭州东信北邮信息技术有限公司变更后:杭州东信北邮信息技术有限公司变更事项:地址变更前:100191 北京市海淀区知春路9号坤讯大厦7层变更后:310013 浙江省杭州市西湖区文三路398号4层|||授权|||实质审查的生效IPC(主分类):H04W 4/12申请日:20140228|||公开
    IPC分类号: H04W4/12(2009.01)I; G06F17/30; H04L12/24 主分类号: H04W4/12
    申请人: 杭州东信北邮信息技术有限公司
    发明人: 廖建新; 曹予飞; 于强; 司书哲; 王啸凡; 马赛牧; 张鑫烨; 沈雪晴; 金志国
    地址: 100191 北京市海淀区知春路9号坤讯大厦7层
    优先权:
    专利代理机构: 代理人:
    PDF完整版下载: PDF下载
    法律状态
    申请(专利)号:

    CN201410072445.0

    授权公告号:

    |||||||||

    法律状态公告日:

    2017.09.29|||2017.02.15|||2014.06.11|||2014.05.14

    法律状态类型:

    专利权人的姓名或者名称、地址的变更|||授权|||实质审查的生效|||公开

    摘要

    一种消息发送系统和方法,包括:消息开放装置,用于将若干个单发任务请求或每个群发任务请求保存到本地原始任务文件中,同时在数据库中为每个群发任务请求新增一条群发任务记录;下行预处理装置,用于在数据库中为同一接入号和优先级的单发任务请求新增一条单发任务记录,然后将原始任务文件中同一接入号和优先级的单发任务请求、或一个群发任务请求拆分到若干个新生成的子任务文件中,同时在数据库中为对应的单或群发任务记录新增若干个子任务记录,每个子任务记录对应一个子任务文件;下行调度装置,用于从数据库中挑选一个单或群发任务记录,并交消息收发装置发送。本发明属于网络通信技术领域,能为短彩信的单发和群发提供统一调度和下发。

    权利要求书

    权利要求书
    1.  一种消息发送系统,其特征在于,包括有若干个消息开放装置、下行预处理装置、下行调度装置和若干个消息收发装置,其中:
    消息开放装置,用于接收业务系统发送来的单或群发任务请求,并将若干个单发任务请求、或每个群发任务请求保存到本地新生成的一个原始任务文件中,同时在数据库中为每个群发任务请求新增一条群发任务记录;
    下行预处理装置,用于在数据库中为同一接入号和优先级的单发任务请求新增一条单发任务记录,然后将本地原始任务文件中同一接入号和优先级的所有单发任务请求、或一个群发任务请求拆分到若干个新生成的子任务文件中,同时在数据库中为对应的单或群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件;
    下行调度装置,用于根据调度策略,从数据库中挑选出一个单或群发任务记录,并将所述单或群发任务记录下属的子任务记录交由消息收发装置发送;
    消息收发装置,用于向用户发送短彩信。

    2.  根据权利要求1所述的系统,其特征在于,消息开放装置进一步包括有:
    单发任务汇聚单元,用于将业务系统发送来的单发任务请求缓存到自身的内存中,同时,定时或定量将内存中的单发任务请求保存到本地新生成的一个原始任务文件中;
    或者,
    群发任务管理单元,用于从业务系统发来的群发任务请求中提取发送号码、优先级、群发用户号码,然后在数据库中新增一条群发任务记录,同时将群发用户号码保存到本地新生成的一个原始任务文件中,所述群发任务记录保存有群发任务的接入号、优先级、原始任务文件的地址。

    3.  根据权利要求1所述的系统,其特征在于,下行预处理装置进一步包括有:
    单发预处理调度单元,用于定时对本地新生成的、且保存单发任务请求的原始任务文件进行扫描,从扫描到的原始任务文件中读取每条单发任务请求的接入号和优先级,并判断数据库中是否存在有与所述接入号和优先级相一致的单发任务记录,如果否,则在数据库中新增一条单发任务记录,所述单发任务记录的ID采用单发任务请求的接入号和优先级进行标示,然后对扫描到的原始任务文件中的每一接入号和优先级对应的单发任务请求总数进行统计,并将同一接入号和优先级的单发任务请求写入到若干个新生成的子任务文件中,从而使得每个子任务文件中的单发任务请求总数低于一个预先设置的阈值,同时在数据库中为所述接入号和优先级对应的单发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值根据短彩网关/或中心分配的下行链路流控速率来取值;
    或者,
    群发预处理调度单元,用于定时对数据库中的每条群发任务记录逐一扫描,并统计数据库中每条群发任务记录对应的原始任务文件的群发用户号码总数,然后将所述原始任务文件拆分成若干个新生成的子任务文件,从而使得每个子任务文件中的群发用户号码总数低于一个预先设置的阈值,然后在数据库中为所述群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值根据短彩网关/或中心分配的下行链路流控速率来取值。

    4.  根据权利要求1所述的系统,其特征在于,下行调度装置进一步包括有:
    任务调度通道构建单元,用于为每个接入号构建一个任务调度通道,并从数据库中为每个任务调度通道实时读取其接入号对应的所有单和群发任务记录;
    任务调度分配单元,用于根据调度策略,从每个任务调度通道的所有单和群发任务记录中挑选出一个单或群发任务记录作为所述任务调度通道的当前任务;当接收到消息收发装置发送来的携带有接入号的申请消息任务请求时,则将所述接入号对应的任务调度通道的当前任务的一个子任务记录及其对应的子任务文件发送给消息收发装置,
    消息收发装置进一步包括有若干个消息发送通道,其中:
    消息发送通道,用于和接入号相绑定,定时向下行调度装置发起申请消息任务请求,并根据下行调度装置返回的子任务记录及其对应的子任务文件,发送对应的短彩信。

    5.  根据权利要求4所述的系统,其特征在于,采用整形数字描述单发和群发任务记录的优先级级别,数字越大,级别越高,并用偶数标示单发任务记录的优先级级别,用奇数标示群发任务记录的优先级级别。

    6.  一种消息发送方法,其特征在于,当业务系统发起一个单或群发任务请求时,包括有:
    步骤一、消息开放装置接收业务系统发送来的单或群发任务请求,并将若干个单发任务请求、或每个群发任务请求保存到本地新生成的一个原始任务文件中,同时在数据库中为每个群发任务请求新增一条群发任务记录;
    步骤二、下行预处理装置在数据库中为同一接入号和优先级的单发任务请求新增一条单发任务记录,然后将本地原始任务文件中同一接入号和优先级的所有单发任务请求、或一个群发任务请求拆分到若干个新生成的子任务文件中,同时在数据库中为对应的单或群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件;
    步骤三、下行调度装置根据调度策略,从数据库中挑选出一个单或群发任务记录,并将所述单或群发任务记录下属的子任务记录交由消息收发装置来发送对应的短彩信。

    7.  根据权利要求6所述的方法,其特征在于,步骤一进一步包括有:
    步骤11、消息开放装置判断业务系统发来的消息是否是单发任务请求,如果是,则将所 述单发任务请求缓存到自身的内存中,同时,定时或定量将内存中的单发任务请求保存到本地新生成的一个原始任务文件中。

    8.  根据权利要求6所述的方法,其特征在于,步骤一进一步包括有:
    步骤12、消息开放装置判断业务系统发来的消息是否是群发任务请求,如果是,则从群发任务请求中提取发送号码、优先级、群发用户号码,然后在数据库中新增一条群发任务记录,同时将群发用户号码保存到本地新生成的一个原始任务文件中,所述群发任务记录保存有群发任务的接入号、优先级、原始任务文件的地址。

    9.  根据权利要求6所述的方法,其特征在于,步骤二进一步包括有:
    步骤21、下行预处理装置定时对本地新生成的、且保存单发任务请求的原始任务文件进行扫描;
    步骤22、下行预处理装置从扫描到的原始任务文件中读取每条单发任务请求的接入号和优先级,并判断数据库中是否存在有与所述接入号和优先级相一致的单发任务记录,如果有,则继续读取下一条单发任务请求,直至读取完所有扫描到的原始任务文件;如果否,则在数据库中新增一条单发任务记录,所述单发任务记录的ID采用单发任务请求的接入号和优先级进行标示,然后继续读取下一条单发任务请求,直至读取完所有扫描到的原始任务文件;
    步骤23、下行预处理装置对扫描到的原始任务文件中的每一接入号和优先级对应的单发任务请求总数进行统计,并将同一接入号和优先级的单发任务请求写入到若干个新生成的子任务文件中,从而使得每个子任务文件中的单发任务请求总数低于一个预先设置的阈值,然后在数据库中为所述接入号和优先级对应的单发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值根据短彩网关/或中心分配的下行链路流控速率来取值。

    10.  根据权利要求6所述的方法,其特征在于,步骤二进一步包括有:
    步骤24、下行预处理装置定时对数据库中的每条群发任务记录逐一扫描,并统计数据库中每条群发任务记录对应的原始任务文件的群发用户号码总数,然后将所述原始任务文件拆分成若干个新生成的子任务文件,从而使得每个子任务文件中的群发用户号码总数低于一个预先设置的阈值,然后在数据库中为所述群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值根据短彩网关/或中心分配的下行链路流控速率来取值。

    11.  根据权利要求6所述的方法,其特征在于,步骤三进一步包括有:
    步骤31、下行调度装置内部为每个接入号构建一个任务调度通道,并从数据库中为每个任务调度通道实时读取其接入号对应的所有单和群发任务记录;
    步骤32、下行调度装置根据调度策略,从每个任务调度通道的所有单和群发任务记录中挑选出一个单或群发任务记录作为所述任务调度通道的当前任务;
    步骤33、当下行调度装置接收到消息收发装置的一个消息发送通道发送来的申请消息任务请求时,所述申请消息任务请求中携带有接入号,下行调度装置获取所述接入号对应的任务调度通道的当前任务,并将所述当前任务的一个子任务记录及其对应的子任务文件发送给消息收发装置对应的消息发送通道;
    步骤34、消息收发装置的消息发送通道根据子任务记录及其对应的子任务文件发送对应的短彩信。

    12.  根据权利要求11所述的方法,其特征在于,步骤32中,下行调度装置采用整形数字描述单发和群发任务记录的优先级级别,数字越大,级别越高,并用偶数标示单发任务记录的优先级级别,用奇数标示群发任务记录的优先级级别。

    说明书

    说明书一种消息发送系统和方法
    技术领域
    本发明涉及一种消息发送系统和方法,属于网络通信技术领域。
    背景技术
    手机短彩信业务,以高效、即时、准确、低廉及无所不在等优势,已经成为移动业务中重要的组成部分。同时,各种运营商、盈利集团和个人利用短彩信的促销手段层出不穷,大量的短彩信亦需要群发。
    如何为大量短彩信的单发和群发业务提供统一的调度和下发管理?专利ZL200810072048.8(专利名称:基于短信应用网关的短信下发调度系统,申请日:2008‐11‐04,申请人:中国移动通信集团福建有限公司)公开了一种基于短信应用网关的短信下发调度系统,包括各短信业务应用系统和短信网关,所述各短信业务应用系统经一短信应用网关与短信网关相连接,所述短信应用网关包括应用接口???、消息队列、下行短信调度引擎和网关接口???;应用接口??榻邮斩绦?、分配优先级并触发下行短信调度引擎;下行短信调度引擎从消息队列中读取下发短信信息并将其调度至网关接口??榈拇⑺投恿兄?;网关接口??榇佣喔霾煌拇⑺投恿兄刑崛〈⑺投绦畔路⒏绦磐?,并负责流量控制和回复信息结果表的维护。该技术方案统一接收各短信业务应用系统的短信彩信,统一流量控制,并依据全局优先级原则进行合理调度,但并不涉及到大量单发消息和群发消息的统一调度和下发。
    因此,如何为短彩信的单发和群发任务提供统一的调度和下发管理,仍是一个值得深入研究的技术问题。
    发明内容
    有鉴于此,本发明的目的是提供一种消息发送系统和方法,能为短彩信的单发和群发任务提供统一的调度和下发管理。
    为了达到上述目的,本发明提供了一种消息发送系统,包括有若干个消息开放装置、下行预处理装置、下行调度装置和若干个消息收发装置,其中:
    消息开放装置,用于接收业务系统发送来的单或群发任务请求,并将若干个单发任务请求、或每个群发任务请求保存到本地新生成的一个原始任务文件中,同时在数据库中为每个群发任务请求新增一条群发任务记录;
    下行预处理装置,用于在数据库中为同一接入号和优先级的单发任务请求新增一条单发 任务记录,然后将本地原始任务文件中同一接入号和优先级的所有单发任务请求、或一个群发任务请求拆分到若干个新生成的子任务文件中,同时在数据库中为对应的单或群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件;
    下行调度装置,用于根据调度策略,从数据库中挑选出一个单或群发任务记录,并将所述单或群发任务记录下属的子任务记录交由消息收发装置发送;
    消息收发装置,用于向用户发送短彩信。
    为了达到上述目的,本发明还提供了一种消息发送方法,当业务系统发起一个单或群发任务请求时,包括有:
    步骤一、消息开放装置接收业务系统发送来的单或群发任务请求,并将若干个单发任务请求、或每个群发任务请求保存到本地新生成的一个原始任务文件中,同时在数据库中为每个群发任务请求新增一条群发任务记录;
    步骤二、下行预处理装置在数据库中为同一接入号和优先级的单发任务请求新增一条单发任务记录,然后将本地原始任务文件中同一接入号和优先级的所有单发任务请求、或一个群发任务请求拆分到若干个新生成的子任务文件中,同时在数据库中为对应的单或群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件;
    步骤三、下行调度装置根据调度策略,从数据库中挑选出一个单或群发任务记录,并将所述单或群发任务记录下属的子任务记录交由消息收发装置来发送对应的短彩信。
    与现有技术相比,本发明的有益效果是:本发明通过数据库和文件系统两种方式,对各个业务系统发送来的单或群发任务请求进行可靠存储;无论群发还是单发任务请求,本发明始终围绕“任务”概念执行,最终将所有要发送的消息按照接入号、优先级等进行归类,从而整合成粒度合适、可直接执行的任务最小调度单元,确保了每个子任务都能在较短的时间内处理完成;通过各种调度策略控制每个接入号对应的所有单发和群发任务之间的执行顺序,从而保证单发和群发任务的统一调度;当消息量不可控或者消息量爆炸式增长情况下,本发明还可以通过动态变更消息收发装置的数量或者消息收发装置中消息发送通道的数量,在不影响现网正常运行的情况下,灵活方便的实现了系统性能的提升。
    附图说明
    图1是本发明一种消息发送系统的一个实施例的组成结构示意图。
    图2是消息开放装置的组成结构示意图。
    图3是下行预处理装置的组成结构示意图。
    图4是当业务系统发起一个单或群发任务请求时,本发明一种消息发送方法的流程图。
    图5是图4步骤一的具体操作流程图。
    图6是图4步骤二的具体操作流程图。
    图7是图4步骤三的具体操作流程图。
    具体实施方式
    为使本发明的目的、技术方案和优点更加清楚,下面结合附图对本发明作进一步的详细描述。
    如图1所示,本发明一种消息发送系统包括有若干个消息开放装置、下行预处理装置、下行调度装置和若干个消息收发装置,其中:
    消息开放装置,用于接收业务系统发送来的单或群发任务请求,并将若干个单发任务请求、或每个群发任务请求保存到本地新生成的一个原始任务文件中,同时在数据库中为每个群发任务请求新增一条群发任务记录;
    下行预处理装置,用于在数据库中为同一接入号和优先级的单发任务请求新增一条单发任务记录,然后将本地原始任务文件中同一接入号和优先级的所有单发任务请求、或一个群发任务请求拆分到若干个新生成的子任务文件中,同时在数据库中为对应的单或群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述接入号是短彩网关/或中心分配链路时绑定的号码,可以是发送号码、或者发送号码的前缀;
    下行调度装置,用于根据调度策略,从数据库中挑选出一个单或群发任务记录,并将所述单或群发任务记录下属的子任务记录交由消息收发装置发送;
    消息收发装置,用于向用户发送短彩信。
    如图2所示,消息开放装置进一步包括有:
    单发任务汇聚单元,用于将业务系统发送来的单发任务请求缓存到自身的内存中,同时,定时(例如每隔1秒)或定量(例如当单发任务请求的数量达到100条)将内存中的单发任务请求保存到本地新生成的一个原始任务文件中;其中,单发任务汇聚单元定时、或定量的将内存中的所有单发任务请求写到一个原始任务文件中,既可以实现单发和群发的统一调度,还能有效的避免频繁向磁盘上写文件,从而防止对文件系统造成较大的负荷;
    群发任务管理单元,用于从业务系统发来的群发任务请求中提取发送号码、优先级、比重、群发用户号码等信息,然后在数据库中新增一条群发任务记录,同时将群发用户号码等信息保存到本地新生成的一个原始任务文件中,所述群发任务记录保存有群发任务的接入号、优先级、比重、原始任务文件的地址等信息。
    当所述单或群发任务请求是发送彩信时,所述原始任务文件中还保存有对应的彩信附件。
    下行预处理装置通过对原始的单发任务请求和群发任务请求进行处理,可以形成内部统一的消息数据模型,从而供下行调度装置进行集中控制和分配。无论群发还是单发任务请求,下行预处理装置始终围绕“任务”概念执行,最终将所有要发送的消息按照接入号、优先级等进行归类,从而整合成若干个粒度合适、可直接执行的任务最小调度单元。如图3所示,下行预处理装置进一步包括有:
    单发预处理调度单元,用于定时对本地新生成的、且保存单发任务请求的原始任务文件进行扫描,从扫描到的原始任务文件中读取每条单发任务请求的接入号和优先级,并判断数据库中是否存在有与所述接入号和优先级相一致的单发任务记录,如果否,则在数据库中新增一条单发任务记录,所述单发任务记录的ID采用单发任务请求的接入号和优先级进行标示(例如,某一条单发任务记录的ID标示为:1065700_2,其中1065700是接入号,2是优先级),然后对扫描到的原始任务文件中的每一接入号和优先级对应的单发任务请求总数进行统计,并将同一接入号和优先级的单发任务请求写入到若干个新生成的子任务文件中,从而使得每个子任务文件中的单发任务请求总数低于一个预先设置的阈值,同时在数据库中为所述接入号和优先级对应的单发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值可以根据短彩网关/或中心分配的下行链路流控速率来取值,从而确保单发任务记录的每个子任务记录能在较短的时间内处理完成;单发任务记录的ID固定采用“接入号+优先级”进行标示,也就是说,针对同一接入号且同一优先级的单发任务请求,下行预处理装置会将其划入到同一单发任务记录中,由于原始任务文件中不同接入号的单发任务请求混杂在一起,下行预处理装置可以按照一定策略,将原始任务文件归类合并成可以被调度执行的单发任务及子任务:例如,当阈值设置为100时,如果原始任务文件中接入号“1065700”和优先级“2”对应的单发任务请求总数为250条,则生成3个子任务文件来保存这250条单发任务请求,同样,接入号“1065800”和优先级“2”对应的单发任务请求总数为60条,则生成1个子任务文件即可;
    群发预处理调度单元,用于定时对数据库中的每条群发任务记录逐一扫描,并统计数据库中每条群发任务记录对应的原始任务文件的群发用户号码总数,然后将所述原始任务文件拆分成若干个新生成的子任务文件,从而使得每个子任务文件中的群发用户号码总数低于一个预先设置的阈值,然后在数据库中为所述群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值可以根据短彩网关/或中心分配的下行链路流控速率来取值,从而确保群发任务记录的每个子任务记录能在较短的时间内处理完成。
    在单发预处理调度单元和群发预处理调度单元中,当单或群发任务请求是发送彩信时,还需将彩信所关联的彩信附件一并归并到所述单或群发任务请求所属的子任务目录下。
    下行调度装置采用拉模式的任务分配机制,为每一个与链路绑定的接入号构建一个任务调度通道,在同一任务调度通道内部,通过各种调度策略控制其多个任务之间的执行顺序,通道和通道之间互相不影响;同样,也可以根据消息负荷的大小,构建多个消息收发装置,每个消息收发装置内部还可以为每个接入号构建多个消息发送通道。下行调度装置进一步包括有:
    任务调度通道构建单元,用于为每个接入号构建一个任务调度通道,并从数据库中为每个任务调度通道实时读取其接入号对应的所有单和群发任务记录;
    任务调度分配单元,用于根据调度策略(例如优先级或比重),从每个任务调度通道的所有单和群发任务记录中挑选出一个单或群发任务记录作为所述任务调度通道的当前任务;当接收到消息收发装置发送来的携带有接入号的申请消息任务请求时,则将所述接入号对应的任务调度通道的当前任务的一个子任务记录及其对应的子任务文件发送给消息收发装置,
    消息收发装置进一步包括有若干个消息发送通道,其中:
    消息发送通道,用于和接入号相绑定,定时向下行调度装置发起申请消息任务请求,并根据下行调度装置返回的子任务记录及其对应的子任务文件,发送对应的短彩信。
    下行调度装置的任务调度分配单元还可以采用整形数字描述单发和群发任务记录的优先级级别,数字越大,级别越高。为了区分和统一调配群发任务记录和单发任务记录的执行顺序,下行调度装置内部可以用偶数标示单发任务记录的优先级级别,用奇数标示群发任务记录的优先级级别,这样,同一优先级下,单发任务记录的优先级要高于群发任务记录的优先级,既实现了单发和群发的统一调度,又在一定程度上满足了单发消息实时性高的要求。例如对于低优先级的群发任务记录和单发任务记录,其优先级级别分别设为1和2;对于中优先级的群发任务记录和单发任务记录,其优先级级别分别设为3和4;对于高优先级的群发任务记录和单发任务记录,其优先级级别分别设为5和6。
    如图4所示,当业务系统发起一个单或群发任务请求时,本发明一种消息发送方法包括有:
    步骤一、消息开放装置接收业务系统发送来的单或群发任务请求,并将若干个单发任务请求、或每个群发任务请求保存到本地新生成的一个原始任务文件中,同时在数据库中为每个群发任务请求新增一条群发任务记录;
    步骤二、下行预处理装置在数据库中为同一接入号和优先级的单发任务请求新增一条单发任务记录,然后将本地原始任务文件中同一接入号和优先级的所有单发任务请求、或一个群发任务请求拆分到若干个新生成的子任务文件中,同时在数据库中为对应的单或群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述接入号是短 彩网关/或中心分配链路时绑定的号码,可以是发送号码、或者发送号码的前缀;
    步骤三、下行调度装置根据调度策略,从数据库中挑选出一个单或群发任务记录,并将所述单或群发任务记录下属的子任务记录交由消息收发装置来发送对应的短彩信。
    如图5所示,图4步骤一进一步包括有:
    步骤11、消息开放装置判断业务系统发来的消息是否是单发任务请求?如果是,则将所述单发任务请求缓存到自身的内存中,同时,定时(例如每隔1秒)或定量(例如当单发任务请求的数量达到100条)将内存中的单发任务请求保存到本地新生成的一个原始任务文件中,本流程结束;如果否,则继续步骤12;
    消息开放装置定时定量的将内存中所有单发任务请求写到一个原始任务文件中,既可以实现单发和群发的统一调度,还能有效避免频繁向磁盘上写文件,从而防止对文件系统造成较大的负荷;
    步骤12、消息开放装置判断业务系统发来的消息是否是群发任务请求?如果是,则继续步骤13;如果否,则本流程结束;
    步骤13、消息开放装置从群发任务请求中提取发送号码、优先级、比重、群发用户号码等信息,然后在数据库中新增一条群发任务记录,同时将群发用户号码等信息保存到本地新生成的一个原始任务文件中,所述群发任务记录保存有群发任务的接入号、优先级、比重、原始任务文件的地址等信息。
    当所述单或群发任务请求是发送彩信时,所述原始任务文件中还保存有对应的彩信附件。
    图4步骤二中,下行预处理装置通过对原始的单发任务请求和群发任务请求进行处理,可以形成内部统一的消息数据模型,从而供下行调度装置进行集中控制和分配。无论群发还是单发任务请求,下行预处理过程始终围绕“任务”概念执行,最终将所有要发送的消息按照接入号、优先级等进行归类,从而整合成若干个粒度合适、可直接执行的任务最小调度单元。如图6所示,图4步骤二进一步包括有:
    步骤21、下行预处理装置定时对本地新生成的、且保存单发任务请求的原始任务文件进行扫描;
    步骤22、下行预处理装置从扫描到的原始任务文件中读取每条单发任务请求的接入号和优先级,并判断数据库中是否存在有与所述接入号和优先级相一致的单发任务记录,如果有,则继续读取下一条单发任务请求,直至读取完所有扫描到的原始任务文件;如果否,则在数据库中新增一条单发任务记录,所述单发任务记录的ID采用单发任务请求的接入号和优先级进行标示(例如,某一条单发任务记录的ID标示为:1065700_2,其中1065700是接入号,2是优先级),然后继续读取下一条单发任务请求,直至读取完所有扫描到的原始任务文件;
    步骤23、下行预处理装置对扫描到的原始任务文件中的每一接入号和优先级对应的单发任务请求总数进行统计,并将同一接入号和优先级的单发任务请求写入到若干个新生成的子任务文件中,从而使得每个子任务文件中的单发任务请求总数低于一个预先设置的阈值,然后在数据库中为所述接入号和优先级对应的单发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值可以根据短彩网关/或中心分配的下行链路流控速率来取值,从而确保单发任务记录的每个子任务记录能在较短的时间内处理完成;
    单发任务记录的ID固定采用“接入号+优先级”进行标示,也就是说,针对同一接入号且同一优先级的单发任务请求,下行预处理装置会将其划入到同一单发任务记录中,由于原始任务文件中不同接入号的单发任务请求混杂在一起,下行预处理装置可以按照一定策略,将原始任务文件归类合并成可以被调度执行的单发任务及子任务;例如,当阈值设置为100时,如果原始任务文件中接入号“1065700”和优先级“2”对应的单发任务请求总数为250条,则生成3个子任务文件来保存这250条单发任务请求,同样,接入号“1065800”和优先级“2”对应的单发任务请求总数为60条,则生成1个子任务文件即可;
    步骤24、下行预处理装置定时对数据库中的每条群发任务记录逐一扫描,并统计数据库中每条群发任务记录对应的原始任务文件的群发用户号码总数,然后将所述原始任务文件拆分成若干个新生成的子任务文件,从而使得每个子任务文件中的群发用户号码总数低于一个预先设置的阈值,然后在数据库中为所述群发任务记录新增若干个下属的子任务记录,每个子任务记录对应一个子任务文件,所述阈值可以根据短彩网关/或中心分配的下行链路流控速率来取值,从而确保群发任务记录的每个子任务记录能在较短的时间内处理完成。
    当所述单/或群发任务请求是发送彩信时,还需将彩信所关联的彩信附件一并归并到所述单/或群发任务请求所属的单/或群发子任务目录下。
    图4步骤三中,下行调度装置采用拉模式的任务分配机制,为每一个与链路绑定的接入号构建一个任务调度通道,在同一任务调度通道内部,通过各种调度策略控制其多个任务之间的执行顺序,通道和通道之间互相不影响;同样,也可以根据消息负荷的大小,构建多个消息收发装置,每个消息收发装置内部还可以为每个接入号构建多个消息发送通道,如图7所示,图4步骤三进一步包括有:
    步骤31、下行调度装置内部为每个接入号构建一个任务调度通道,并从数据库中为每个任务调度通道实时读取其接入号对应的所有单和群发任务记录;
    步骤32、下行调度装置根据调度策略(例如优先级或比重),从每个任务调度通道的所有单和群发任务记录中挑选出一个单或群发任务记录作为所述任务调度通道的当前任务;
    步骤33、当下行调度装置接收到消息收发装置的一个消息发送通道发送来的申请消息任 务请求时,所述申请消息任务请求中携带有接入号,下行调度装置获取所述接入号对应的任务调度通道的当前任务,并将所述当前任务的一个子任务记录及其对应的子任务文件发送给消息收发装置对应的消息发送通道;
    步骤34、消息收发装置的消息发送通道根据子任务记录及其对应的子任务文件发送对应的短彩信。
    图7步骤32中,下行调度装置还可以采用整形数字描述单发和群发任务记录的优先级级别,数字越大,级别越高。为了区分和统一调配群发任务记录和单发任务记录的执行顺序,下行调度装置内部可以用偶数标示单发任务记录的优先级级别,用奇数标示群发任务记录的优先级级别,这样,同一优先级下,单发任务记录的优先级要高于群发任务记录的优先级,既实现了单发和群发的统一调度,又在一定程度上满足了单发消息实时性高的要求。例如对于低优先级的群发任务记录和单发任务记录,其优先级级别分别设为1和2;对于中优先级的群发任务记录和单发任务记录,其优先级级别分别设为3和4;对于高优先级的群发任务记录和单发任务记录,其优先级级别分别设为5和6。
    以上所述仅为本发明的较佳实施例而已,并不用以限制本发明,凡在本发明的精神和原则之内,所做的任何修改、等同替换、改进等,均应包含在本发明?;さ姆段е?。

    关于本文
    本文标题:一种消息发送系统和方法.pdf
    链接地址://www.4mum.com.cn/p-6185420.html
    关于我们 - 网站声明 - 网站地图 - 资源地图 - 友情链接 - 网站客服 - 联系我们

    [email protected] 2017-2018 www.4mum.com.cn网站版权所有
    经营许可证编号:粤ICP备17046363号-1 
     


    收起
    展开
  • 四川郎酒股份有限公司获第十二届人民企业社会责任奖年度环保奖 2019-05-13
  • 银保监会新规剑指大企业多头融资和过度融资 2019-05-12
  • 韩国再提4国联合申办世界杯 中国网友无视:我们自己来 2019-05-11
  • 中国人为什么一定要买房? 2019-05-11
  • 十九大精神进校园:风正扬帆当有为 勇做时代弄潮儿 2019-05-10
  • 粽叶飘香幸福邻里——廊坊市举办“我们的节日·端午”主题活动 2019-05-09
  • 太原设禁鸣路段 设备在测试中 2019-05-09
  • 拜耳医药保健有限公司获第十二届人民企业社会责任奖年度企业奖 2019-05-08
  • “港独”没出路!“梁天琦们”该醒醒了 2019-05-07
  • 陈卫平:中国文化内涵包含三方面 文化复兴表现在其中 2019-05-06
  • 人民日报客户端辟谣:“合成军装照”产品请放心使用 2019-05-05
  • 【十九大·理论新视野】为什么要“建设现代化经济体系”?   2019-05-04
  • 聚焦2017年乌鲁木齐市老城区改造提升工程 2019-05-04
  • 【专家谈】上合组织——构建区域命运共同体的有力实践者 2019-05-03
  • 【华商侃车NO.192】 亲!楼市火爆,别忘了买车位啊! 2019-05-03
  • 浙江十一选五规律 500wan彩票官网 赚钱的工作技术 彩票客户端 最佳倍投方案稳赚 会赚钱脾气还温和的星座 开元棋牌929棋牌游戏 11选五守号技巧稳赚 赌场最怕什么样的赌法 山东时时11夺金 美添盈赚钱吗 贵州快三开奖遗漏 明日之后快速赚钱 泰山捕鱼 双色球组选的计算方法 彩票中奖秘籍100%中