预览加载中,请您耐心等待几秒...
1/10
2/10
3/10
4/10
5/10
6/10
7/10
8/10
9/10
10/10

亲,该文档总共12页,到这已经超出免费预览范围,如果喜欢就直接下载吧~

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN112527527A(43)申请公布日2021.03.19(21)申请号202011490835.1(22)申请日2020.12.16(71)申请人深圳市分期乐网络科技有限公司地址518000广东省深圳市南山区粤海街道科苑南路3099号中国储能大厦第23--27层(72)发明人周鹏华(74)专利代理机构北京品源专利代理有限公司11332代理人潘登(51)Int.Cl.G06F9/54(2006.01)权利要求书1页说明书8页附图2页(54)发明名称消息队列的消费速度控制方法、装置、电子设备和介质(57)摘要本发明实施例公开了一种消息队列的消费速度控制方法、装置、电子设备和介质。该方法包括:响应于定时任务启动请求,从消息队列中取出第一数量的消息;其中,第一数量与所述定时任务的分片任务的数量相同;通过所述分片任务对所述消息进行处理。本发明实施例将消息队列与定时任务分片相结合,通过控制定时任务的分片任务的数量,实现了对消息队列的消费速度的控制,降低了消息队列的消费速度的控制方法的实现复杂度,同时可以有效的控制消息的消费线程数。CN112527527ACN112527527A权利要求书1/1页1.一种消息队列的消费速度控制方法,其特征在于,包括:响应于定时任务启动请求,从消息队列中取出第一数量的消息;其中,第一数量与所述定时任务的分片任务的数量相同;通过所述分片任务对所述消息进行处理。2.根据权利要求1所述的方法,其特征在于,在所述响应于定时任务启动请求,从消息队列中取出第一数量的消息之前,还包括:获取分片任务数量更新指令;根据所述分片任务数量更新指令,将所述定时任务分片为第二数量的分片任务;其中,第一数量等于第二数量。3.根据权利要求1所述的方法,其特征在于,在所述响应于定时任务启动请求,从消息队列中取出第一数量的消息之前,还包括:根据业务属性信息对业务数据进行分类,并得到分类结果;将所述分类结果作为消息存储至所述消息队列中;其中,同一消息队列中存储的所述分类结果所属业务属性相同。4.根据权利要求1所述的方法,其特征在于,在所述响应于定时任务启动请求,从消息队列中取出第一数量的消息之前,还包括:获取定时任务执行频率更新指令;根据所述执行频率更新指令设置所述定时任务的执行频率。5.根据权利要求1所述的方法,其特征在于,所述消息队列为redis消息队列。6.根据权利要求3所述的方法,其特征在于,所述消息队列中存储的为逾期还款账单数据。7.根据权利要求1或6所述的方法,其特征在于,所述定时任务用于以设定时间间隔对所述逾期还款账单数据进行罚息计算。8.一种消息队列的消费速度控制装置,其特征在于,包括:消息取出模块,用于响应于定时任务启动请求,从消息队列中取出第一数量的消息;其中,第一数量与所述定时任务的分片任务的数量相同;消息处理模块,用于通过所述分片任务对所述消息进行处理。9.一种电子设备,其特征在于,所述电子设备包括:一个或多个处理器;存储器,用于存储一个或多个程序;当所述一个或多个程序被所述一个或多个处理器执行,使得所述一个或多个处理器实现如权利要求1‑7中任一项所述的消息队列的消费速度控制方法。10.一种存储有计算机指令的非瞬时计算机可读存储介质,其特征在于,所述计算机指令用于使所述计算机执行权利要求1‑7中任一项所述的消息队列的消费速度控制方法。2CN112527527A说明书1/8页消息队列的消费速度控制方法、装置、电子设备和介质技术领域[0001]本发明实施例涉及计算机技术领域,尤其涉及一种消息队列的消费速度控制方法、装置、电子设备和介质。背景技术[0002]消息生产方在产生消息以后,会将消息送入消息队列中,然后由消息消费方从消息队列中取出消息进行消息消费。由于消息消费方的负载能力有限,对消息队列的消费速度进行控制,对于保证消息消费方系统稳定性,提高消息消费方工作效率具有重要意义。[0003]现有的控制消息队列的消费速度的方法如滑动窗口算法、漏桶算法和令牌桶算法虽能能够控制消息队列单位时间的消费速度,但要在分布式系统扩容时实现上述算法复杂度较高。发明内容[0004]本发明实施例提供一种消息队列的消费速度控制方法、装置、电子设备和介质,以达到控制消息队列的消费速度目的。[0005]第一方面,本发明实施例提供了一种消息队列的消费速度控制方法,包括:[0006]响应于定时任务启动请求,从消息队列中取出第一数量的消息;其中,第一数量与所述定时任务的分片任务的数量相同;[0007]通过所述分片任务对所述消息进行处理。[0008]第二方面,本发明实施例还提供了一种消息队列的消费速度控制装置,包括:[0009]消息取出模块,用于响应于定时任务启动请求,从消息队列中