[发明专利]一种可控式大并发分布式消息队列推送方法

摘要

本发明公开了一种可控式大并发分布式消息队列推送方法，包括FIFO列队模型，所述FIFO列队模型前端增设消息入列网关和消息分发模块，所述消息分发模块进行统一可控的消息推送控制，所述消息入列网关进行消息入列管理和容错处理/恢复，所述FIFO列队模型末端设有调度程序模块和消费者消息处理器。与现有技术相比，本发明能主动控制消息消费者接入数量或请求频率，节约队列服务资源，最大可能地使其避免了宕机风险，具有消息容错延后处理的功能，避免进程阻塞，消息队列数据堆积，服务资源急剧消耗，具有无服务容错处理的功能，避免了在队列依赖的存储服务不可用时，导致消息生产者发送消息失败的情况发生。

主权项

一种可控式大并发分布式消息队列推送方法，包括FIFO列队模型，其特征在于：所述FIFO列队模型前端增设消息入列网关和消息分发模块，所述消息分发模块进行统一可控的消息推送控制，将消息推送至消息入列网关，所述消息入列网关进行消息入列管理和容错处理/恢复，并将消息推送至FIFO列队模型，所述FIFO列队模型末端设有调度程序模块和消费者消息处理器，所述FIFO列队模型发出的消息经调度程序模块进行控制处理后，发送至消费者消息处理器。