消息队列的消费速度控制方法、装置、电子设备和介质.pdf
雨巷****珺琦
亲,该文档总共12页,到这已经超出免费预览范围,如果喜欢就直接下载吧~
相关资料
消息队列的消费速度控制方法、装置、电子设备和介质.pdf
本发明实施例公开了一种消息队列的消费速度控制方法、装置、电子设备和介质。该方法包括:响应于定时任务启动请求,从消息队列中取出第一数量的消息;其中,第一数量与所述定时任务的分片任务的数量相同;通过所述分片任务对所述消息进行处理。本发明实施例将消息队列与定时任务分片相结合,通过控制定时任务的分片任务的数量,实现了对消息队列的消费速度的控制,降低了消息队列的消费速度的控制方法的实现复杂度,同时可以有效的控制消息的消费线程数。
消息队列消费方法及系统、电子设备和可读介质、产品.pdf
本公开实施例提供一种消息队列消费方法及系统、电子设备和可读介质、产品,该方法通过队列消费集中管理平台创建目标业务子系统的目标消费任务,并将目标消费任务提交至平台任务下发中心,平台任务下发中心将目标消费任务分配至任务执行机器中的目标任务执行机器,通过目标任务执行机器从目标消费队列中间件中获取对应目标消费任务的目标消费数据,并将目标消费数据回调至对应的目标业务子系统,即队列消费集中管理平台统一监听目标业务子系统的消费队列业务并将目标消费数据回调至对应的目标业务子系统,使得目标业务子系统仅需关注自己的业务逻辑实
消息队列的管理方法、装置、电子设备及存储介质.pdf
本申请提供一种消息队列的管理方法、装置、电子设备及存储介质。无需人工进行选择就可以将消息发送进程和消息接收进程接入目标消息队列,实现了自动接入。无需管理员根据经验或专业知识进行操作,降低了管理员的操作难度。然后,根据确定好的消息队列在构建好的数据接口集合中确定与目标消息队列对应的目标数据接口,并根据数据接口集合和构建好的管理界面集合的映射关系,在管理界面集合中确定与目标数据接口对应的目标管理界面。目标管理界面的选择过程也是自动实现的。最后,在显示界面中显示目标管理界面,并通过目标管理界面管理目标消息队列。
消息队列管理方法、装置、电子设备及介质.pdf
本申请实施例公开了一种消息队列管理方法、装置、电子设备及介质。该方法包括:确定各项目对应的虚拟主机;针对各虚拟主机中的消息队列,通过配置界面确定所述消息队列的配置信息;通过队列实现工具类,根据所述消息队列的配置信息对消息队列进行管理。本申请技术方案克服了现有技术中难以便捷地进行消息队列属性修改以及消息队列动态切换的问题,通过配置界面实现消息队列属性的配置修改,通过队列实现工具类读取配置信息并对消息队列进行管理,在不影响原有消息队列消费进度的情况下,实现消息队列的动态切换。
消息消费方法、装置、电子设备和计算机可读介质.pdf
本公开的实施例公开了消息消费方法、装置、电子设备和计算机可读介质。该方法的一具体实施方式包括:调用多个线程从消息中间件中读取消息,其中,每个线程用于从消息中间件的一个分区中批量读取消息,消息中间件中所存储的消息满足以下条件:满足同一预设条件的消息存储在同一分区;将每个线程读取到的消息分成目标数量个内存分片,目标数量与当前设备的处理器的核数相关;启用目标数量个消费线程池对目标数量个内存分片中的消息进行消费,每个内存分片对应一个消费线程池。该实施方式实现了在不扩充分区的前提下,提高消息消费能力。