一种分布式消息队列的存储方法、装置、设备及可读介质
Abstract:
本发明公开了一种分布式消息队列的存储方法,包括在分布式消息队列中任意一个节点执行以下步骤:响应于接收到消息处理请求,获取消息处理请求的主题,并判断本节点是否为主题的主节点;若是本节点为主题的主节点,将消息处理请求加入优先队列;对优先队列中的消息处理请求进行处理,并向主题的其他主节点发送请求处理响应;以及响应于接收到所有其他主节点返回的请求处理完成标识,向主题的从节点发送数据同步请求。本发明还公开了一种分布式消息队列的存储装置、计算机设备和可读存储介质。本发明通过分布式消息队列节点内部建立交互机制,降低集群的运维成本、人力成本、管理成本,保障业务的稳定运行。
Patent Agency Ranking
0/0