CNIPA.AI
검색으로 돌아가기
기록

基于消息队列的延迟消息处理方法、介质、设备及产品

발명유효
1조회수
14청구항 · 5 독립항
§ Ⅰ

개요

발명자

邹海鹏; 沈辉; 杨国栋; 龚云飞; 高昌利

IPC 분류

G06F 9/54 (2006.01)G06F 9/50 (2006.01)G06F 9/48 (2006.01)

一种基于消息队列的延迟消息处理方法、介质、设备及产品,涉及计算机技术领域,通过在分布式消息队列系统中的计算节点接收到延迟消息时,将延迟消息存储至与计算节点分离的存储节点,并在计算节点中存储延迟消息的调度元数据,然后根据计算节点中存储的各延迟消息的调度元数据,选择时间到期的目标延迟消息,根据目标延迟消息对应的元数据从存储节点中读取目标延迟消息,并按照目标延迟消息对应的消息队列标识,向消息队列标识对应的目标消息队列发送目标延迟消息,不仅可以提高分布式消息队列系统的资源利用率、降低存储成本,而且,通过将延迟消息存储在存储节点中,还可以实现对分布式消息队列系统的自动扩缩容。