消息队列处理方法、线程池参数调整方法、装置和设备.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113722117A(43)申请公布日2021.11.30(21)申请号202011248590.1(22)申请日2020.11.10(71)申请人北京沃东天骏信息技术有限公司地址101116北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人姜振飞(74)专利代理机构北京唯智勤实知识产权代理事务所(普通合伙)11557代理人陈佳(51)Int.Cl.G06F9/54(2006.01)G06F11/14(2006.01)权利要求书2页说明书15页附图6页(54)发明名称消息队列处理方法、线程池参数调整方法、装置和设备(57)摘要本公开的实施例公开了消息队列处理方法、线程池参数调整方法、装置和设备。该方法的一具体实施方式包括：响应于确定本地缓存的线程池参数发生变化，对目标任务消息队列对应的线程池的线程池参数进行调整；响应于确定该目标任务消息队列中的任务消息消费成功，从用于备份该目标任务消息队列中的任务消息的备份消息队列中删除与消费成功的任务消息相匹配的备份消息；响应于确定该目标任务消息队列中的任务消息消费失败，将消费失败的任务消息作为失败消息加入失败消息队列。该实施方式实现了简便的达到有效避免消息丢失、确保数据的一致性以及消息队列可靠性的效果。CN113722117ACN113722117A权利要求书1/2页1.一种消息队列处理方法，包括：响应于确定本地缓存的线程池参数发生变化，对目标任务消息队列对应的线程池的线程池参数进行调整，其中，所述线程池用于创建以及启动目标任务消息队列处理线程；响应于确定所述目标任务消息队列中的任务消息消费成功，从用于备份所述目标任务消息队列中的任务消息的备份消息队列中删除与消费成功的任务消息相匹配的备份消息；响应于确定所述目标任务消息队列中的任务消息消费失败，将消费失败的任务消息作为失败消息加入失败消息队列。2.根据权利要求1所述的方法，其中，所述方法还包括：响应于确定所述目标任务消息队列中不包括与接收到的消息相匹配的任务消息，将所述接收到的消息作为任务消息加入目标任务消息队列以及将所述接收到的消息作为备份消息加入备份消息队列中。3.根据权利要求1所述的方法，其中，所述方法还包括：调用备份消息队列处理线程对所述备份消息队列中的备份消息进行处理，其中，所述备份消息队列处理线程用于以第一预设频率从所述备份消息队列中获取备份消息以及响应于从所述备份消息队列中获取到备份消息，将获取到的备份消息作为任务消息加入所述目标任务消息队列。4.根据权利要求1所述的方法，其中，所述方法还包括：调用失败消息队列处理线程对所述失败消息队列中的失败消息进行处理，其中，所述失败消息队列处理线程用于以第二预设频率从所述失败消息队列中获取失败消息以及响应于从所述失败消息队列中获取到失败消息，将获取到的失败消息作为任务消息加入所述目标任务消息队列。5.根据权利要求1-4之一所述的方法，其中，所述方法还包括：调用所述目标任务消息队列对应的线程池中的目标任务消息队列处理线程对所述目标任务消息队列中的任务消息进行处理，其中，所述目标任务消息队列处理线程用于调用业务接口对从所述目标任务消息队列中获取到的任务消息进行消费。6.一种线程池参数调整方法，包括：响应于确定线程池对接收到的任务消息的拒绝频率大于等于预设拒绝频率，基于所述线程池的线程池参数生成第一线程池参数，其中，所述线程池的线程池参数包括：核心线程数，最大线程数，阻塞队列容量；利用所述第一线程池参数替换本地缓存中存储的线程池参数，其中，所述本地缓存中存储的线程池参数用在如权利要求1所述的方法中。7.根据权利要求6所述的方法，其中，所述方法还包括：响应于确定所述线程池的线程池参数中包括的最大线程数与所述线程池中的目标任务消息队列处理线程的总数的差值满足预设条件，基于所述线程池的线程池参数生成第二线程池参数；利用所述第二线程池参数替换所述本地缓存中存储的线程池参数。8.根据权利要求6-7之一所述的方法，其中，所述基于所述线程池的线程池参数生成第一线程池参数，包括：基于预设最大线程数、第一预设调整比例和所述线程池的线程池参数中包括的最大线2CN113722117A权利要求书2/2页程数，确定第一最大线程数。9.根据权利要求8所述的方法，其中，所述基于所述线程池的线程池参数生成第一线程池参数，还包括：基于第二预设调整比例和所述第一最大线程数，确定第一核心线程数。10.根据权利要求7所述的方法，其中，所述基于所述线程池的线程池参数生成第二线程池参数，包括：基于第三预设调整比例、预设阻塞队列容量和所述线程池的线程池参数中包括的阻塞队列容量，确定第二阻塞队列容量。11.