高并发下的消息调度系统及方法与流程

1.本发明属于通讯传输技术领域，具体涉及一种高并发下的消息调度系统及方法。


背景技术：

2.对于金融平台，每天的交易数据、通知信息等较多，尤其是在交易日。并且由于各种突发情况，消息突然暴增的情况时有发生，然而由于原平台上设计的信息发送通道有限，导致很多重要的数据积压、延时发送，容易引发业务流失，从而给企业造成损失。
3.为了解决上述问题，现有技术中，多数技术人员提出扩展发送通道数量的方式来解决，但是要想完全克服上述问题，解决重要消息不能及时送达的问题，大多需要增加几倍的发送通道数量，才能克服上述问题。而由于上述方案成本高，使用率低，多数通道长时间处于空闲状态，造成企业投入的资源大大浪费，而且提高了企业的经营成本。
4.故针对上述问题，有必要基于现有技术进行改造。


技术实现要素：

5.本发明意在提供一种高并发下的消息调度系统及方法，以解决突发情况发生时，重要数据信息积压、延时发送的问题。
6.为了达到上述目的，本发明的方案为：
7.一种高并发下的消息调度系统，包括调度处理器、待发送信息存储器和待发送队列存储区；所述调度处理器的队列检测端与待发送队列存储区连接；所述待发送信息存储器的分类和发送控制端与所述调度处理器连接；所述待发送信息存储器包括m个待发送存储区，m个待发送存储区包括n个特紧急类消息存储区和m-n个普通类消息存储区；m和n均为正整数，且m大于n；所述待发送信息存储器的m个待发送存储区分别和所述待发送队列存储区连接；所述待发送队列存储区的输出端与消息输出通道连接。
8.通过上述设计，基于调度处理器，将待发送信息存储器接收的消息根据属性分成特紧急类消息存储区和普通类消息存储区，当突发情况发生后，管理人员设置普通类消息存储区与待发送队列存储区的通讯状态或者接收速度，来提高特紧急类消息存储区的特紧急类消息的发送速度，从而解决突发情况发生时，重要数据信息积压、延时发送的问题。
9.进一步的技术方案，所述待发送队列存储区包括特紧急类待发送分区和普通类待发送分区；
10.所述特紧急类待发送分区与所述特紧急类消息存储区连接；
11.所述普通类待发送分区与所述普通类消息存储区连接。
12.通过将待发送队列存储区进行分区，来接收不同属性的消息，从而便于企业对发送出的消息比例、数量进行掌握。并且分类发送，还可以利于企业对本企业业务更精准的了解。
13.再进一步的技术方案，所述调度处理器设置有占比调节模块，用于调节所述待发送队列存储区中特紧急类待发送分区和普通类待发送分区占用比例。
14.通过设置待发送队列存储区比例，可以根据需求随时调节，当突发情况发生时，可以根据需要将紧急类消息的队列比例调整为90％，甚至100％。以克服重要消息被堆压，防止业务流失，避免给企业造成损失。
15.一种高并发下的消息调度方法，包括上述高并发下的消息调度系统，消息调度的具体步骤为：
16.预处理：设定待发送队列存储区空闲度分割值，两两相邻的空闲度分割值形成一个空闲度区间；并设定在每一个空闲度区间内，在一个发送周期内m类消息分别的占比；
17.s1：待发送信息存储器实时接收的待发送消息，并根据待发送消息属性进行m类分类，并将分类后的消息对应存放到对应的m个待发送存储区；
18.s2：调度处理器获取待发送队列存储区的当前空闲度；
19.s3：调度处理器根据空闲度，控制待发送队列存储区的m个待发送存储区向待发送队列存储区传输消息，该传输消息量与预处理设定的占比相匹配；
20.s4：调度处理器实时获取紧急事项信号，若无，返回步骤s2；若有，进入步骤s5；
21.s5:调度处理器根据紧急事项信号进行信息调取并发送，直至获取到紧急事项信号结束信号。
22.通过上述方法，调度处理器通过获取待发送队列存储区的空闲度来对待发送信息存储器的消息进行分类分量发送，也就是当空闲度高时，在保证紧急类消息发送的前提下还可以发送普通类信号，当空闲度相对较低时候，可以适当减少普通类的消息发送速度，来保证紧急类消息的发送。通过调整空闲度来对消息发送进行合理控制，实现不影响企业业务和运营的前提下，保证消息有序发送，无需增加过多的通道，有效降低了企业是经营成本。
23.再进一步的技术方案，所述紧急事项信号至少包括紧急情况下每个发送周期内m类消息分别的占比。
24.其中，紧急事项信号包括紧急情况下每个发送周期内m类消息分别的占比，可根据紧急类消息的需求，对m类消息进行按占比发送，实现通道按照设计需求进行发送，避免造成重要消息遗漏或者延误。
25.再进一步的技术方案，紧急事项信号还包括紧急事项信号占用起止时间段、紧急事项信号占用的发送通道、紧急事项信号启动属性中的一种或者多种组合设计。
26.再进一步的技术方案，设定每一个空闲度区间m类消息的占比时，根据m个待发送存储区内待发送消息优先级进行设定。
27.优先级可以根据企业属性或者需求进行设计分类，并且优先级可以根据企业需求进行改变，适应性广。
28.本方案的工作原理及有益效果在于：相对于现有技术，无需对现有通道进行改进，直接沿用原有设计思路，增加消息的属性，实现分类分级，通过获取待发送队列存储区的空闲度，结合消息优先级，做出消息发送计划。当发生紧急情况时，可快速解决消息堆叠，造成企业运营瘫痪的问题，有效避免企业业务流失，运行成本低，适应性广。
附图说明
29.图1为本发明实施例一中高并发下的消息调度系统框图；
30.图2为本发明实施例一中高并发下的消息调度方法的流程图。
具体实施方式
31.下面通过具体实施方式进一步详细说明：
32.本实施例，高并发下的消息调度系统包括调度处理器1、待发送信息存储器2和待发送队列存储区3；基本如图1和图2所示：所述调度处理器1的队列检测端与待发送队列存储区3连接；所述待发送信息存储器2的分类和发送控制端与所述调度处理器1连接，所述待发送队列存储区3的输出端与消息输出通道连接。
33.在本实施例中，以金融企业为例，在金融企业中，涉及到的消息具体包括：交易类消息、验证码类消息、通知提醒类消息、营销类消息；
34.具体的：交易类消息常见的有贷放款审批消息、在线支付消息、转账消息等；
35.验证码类消息常见的有短信验证码、有效验证码、图片验证码等；
36.通知提醒类消息常见的有催收消息、系统更新消息、用户登录消息等；
37.营销类消息常见的有广告消息。
38.在本实施例中，所述待发送信息存储器2包括四个待发送存储区，四个待发送存储区包括一个特紧急类消息存储区21和三个普通类消息存储区22；
39.在本实施例中，交易类消息为特紧急类消息；三个普通类消息分别为验证码类消息、通知提醒类消息、营销类消息。
40.在本实施例中，所述待发送信息存储器2的四个待发送存储区分别和所述待发送队列存储区3连接。
41.在本实施例中，所述待发送队列存储区3包括特紧急类待发送分区和普通类待发送分区；普通类待发送分区内又设三个小分区，分别放验证码类消息、通知提醒类消息、营销类消息。
42.在本实施例中，所述特紧急类待发送分区与所述特紧急类消息存储区21连接；
43.在本实施例中，所述普通类待发送分区与所述普通类消息存储区22连接。
44.所述调度处理器1设置有占比调节模块，用于调节所述待发送队列存储区3中特紧急类待发送分区和普通类待发送分区占用比例。
45.一种高并发下的消息调度方法，结合附图1和2可以看出，包括上述高并发下的消息调度系统，消息调度的具体步骤为：
46.预处理：设定待发送队列存储区3空闲度分割值，两两相邻的空闲度分割值形成一个空闲度区间；并设定在每一个空闲度区间内，在一个发送周期内m类消息分别的占比；
47.在本实施例中，设计空闲度分割值分别是30％，50％，80％；
48.在本实施例中，当空闲度在0-30％时，待发送队列存储区内全部为特紧急类消息；
49.在本实施例中，当空闲度在30％-50％时，待发送队列存储区内包括特紧急类消息和验证码类消息，占比为4:1；
50.在本实施例中，当空闲度在50％-80％时，待发送队列存储区内包括特紧急类消息、验证码类消息以及通知提醒类消息，占比为3:1:1；
51.在本实施例中，当空闲度在80％-100％时，待发送队列存储区内包括特紧急类消息、验证码类消息、通知提醒类消息以及营销类消息，占比为2:1:1:1；
52.s1：待发送信息存储器2实时接收的待发送消息，并根据待发送消息属性进行四类分类，并将分类后的消息对应存放到对应的四个待发送存储区；
53.s2：调度处理器1获取待发送队列存储区3的当前空闲度；
54.s3：调度处理器1根据空闲度，控制待发送队列存储区3的四个待发送存储区向待发送队列存储区3传输消息，该传输消息量与预处理设定的占比相匹配；
55.s4：调度处理器1实时获取紧急事项信号，若无，返回步骤s2；若有，进入步骤 s5；
56.s5:调度处理器1根据紧急事项信号进行信息调取并发送，直至获取到紧急事项信号结束信号。
57.所述紧急事项信号包括紧急情况下每个发送周期内四类消息分别的占比和紧急事项信号起止时间。
58.紧急事项信号的启动可以是由管理员启动，可以根据特紧急类消息堆压量来进行启动，在本实施例中，当特紧急类消息存储区内存储量超过90％则启动紧急事项信号。
59.在本实施例中，启动紧急事项信号后，设定待发送队列存储区内包括特紧急类消息、验证码类消息、通知提醒类消息以及营销类消息，占比为4:0.5:0.3:0.2。
60.设定每一个空闲度区间四类消息的占比时，根据四个待发送存储区内待发送消息优先级进行设定。
61.在本实施例中，待发送消息优先级由高到低分别为特紧急类消息、验证码类消息、通知提醒类消息、营销类消息。
62.以上所述的仅是本发明的实施例，方案中公知的具体结构及特性等常识在此未作过多描述。应当指出，对于本领域的技术人员来说，在不脱离本发明构思的前提下，还可以作出若干变形和改进，这些也应该视为本发明的保护范围。

技术特征：
1.一种高并发下的消息调度系统，其特征在于：包括调度处理器(1)、待发送信息存储器(2)和待发送队列存储区(3)；所述调度处理器(1)的队列检测端与待发送队列存储区(3)连接；所述待发送信息存储器(2)的分类和发送控制端与所述调度处理器(1)连接；所述待发送信息存储器(2)包括m个待发送存储区，m个待发送存储区包括n个特紧急类消息存储区(21)和m-n个普通类消息存储区(22)；m和n均为正整数，且m大于n；所述待发送信息存储器(2)的m个待发送存储区分别和所述待发送队列存储区(3)连接；所述待发送队列存储区(3)的输出端与消息输出通道连接。2.根据权利要求1所述的高并发下的消息调度系统，其特征在于：所述待发送队列存储区(3)包括特紧急类待发送分区和普通类待发送分区；所述特紧急类待发送分区与所述特紧急类消息存储区(21)连接；所述普通类待发送分区与所述普通类消息存储区(22)连接。3.根据权利要求2所述的高并发下的消息调度系统，其特征在于：所述调度处理器(1)设置有占比调节模块，用于调节所述待发送队列存储区(3)中特紧急类待发送分区和普通类待发送分区占用比例。4.一种高并发下的消息调度方法，其特征在于：包括权利要求1-3中任意一项的高并发下的消息调度系统，消息调度的具体步骤为：预处理：设定待发送队列存储区(3)空闲度分割值，两两相邻的空闲度分割值形成一个空闲度区间；并设定在每一个空闲度区间内，在一个发送周期内m类消息分别的占比；s1：待发送信息存储器(2)实时接收的待发送消息，并根据待发送消息属性进行m类分类，并将分类后的消息对应存放到对应的m个待发送存储区；s2：调度处理器(1)获取待发送队列存储区(3)的当前空闲度；s3：调度处理器(1)根据空闲度，控制待发送队列存储区(3)的m个待发送存储区向待发送队列存储区(3)传输消息，该传输消息量与预处理设定的占比相匹配；s4：调度处理器(1)实时获取紧急事项信号，若无，返回步骤s2；若有，进入步骤s5；s5:调度处理器(1)根据紧急事项信号进行信息调取并发送，直至获取到紧急事项信号结束信号。5.根据权利要求4所述的高并发下的消息调度方法，其特征在于：所述紧急事项信号至少包括紧急情况下每个发送周期内m类消息分别的占比。6.根据权利要求5所述的高并发下的消息调度方法，其特征在于：所述紧急事项信号还包括紧急事项信号占用起止时间段、紧急事项信号占用的发送通道、紧急事项信号启动属性中的一种或者多种。7.根据权利要求4所述的高并发下的消息调度方法，其特征在于：设定每一个空闲度区间m类消息的占比时，根据m个待发送存储区内待发送消息优先级进行设定。

技术总结
本发明涉及一种高并发下的消息调度系统及方法,包括调度处理器(1)、待发送信息存储器(2)和待发送队列存储区(3)；所述调度处理器(1)的队列检测端与待发送队列存储区(3)连接；所述待发送信息存储器(2)的分类和发送控制端与所述调度处理器(1)连接；待发送信息存储器(2)包括M个待发送存储区，M个待发送存储区包括N个特紧急类消息存储区(21)和M-N个普通类消息存储区(22)；所述待发送信息存储器(2)的M个待发送存储区分别和所述待发送队列存储区(3)连接；所述待发送队列存储区(3)的输出端与消息输出通道连接。无需增加通道，设计成本低，利用率高。利用率高。利用率高。


技术研发人员：幸禹可 王瑞 陆引 段勃 杨东鑫 吴余维
受保护的技术使用者：中科计算技术西部研究院
技术研发日：2021.12.03
技术公布日：2022/3/8