[发明专利]一种基于消息队列系统的消息处理方法和装置

摘要

本公开提供一种基于消息队列系统的消息处理方法和装置，其中方法包括：一个队列分组接收作为生产者的消息队列客户端发送的消息；队列分组判断当前的队列长度是否达到阈值，若达到阈值，则向生产者的消息队列客户端返回队列满指令和推荐切换的目标队列分组；作为生产者的消息队列客户端根据队列满指令，将生产的消息转发至目标队列分组；队列分组在接收到作为消费者的消息队列客户端拉取消息的请求时，同样进行队列长度是否达到阈值的判断，若达到阈值，则向消费者的消息队列客户端返回队列满指令和目标队列分组；作为消费者的消息队列客户端将由队列分组拉取的消息转发至目标队列分组。本公开加快了消息整体的处理速度，降低消息处理的延迟时间。

主权项

一种基于消息队列系统的消息处理方法，所述消息队列系统包括消息队列服务端和消息队列客户端，所述消息队列服务端包括属于同一消息主题的多个队列分组；所述方法包括：一个队列分组接收作为生产者的消息队列客户端发送的消息；所述队列分组判断当前的队列长度是否达到阈值，若达到阈值，则向所述作为生产者的消息队列客户端返回队列满指令，并且返回推荐切换的目标队列分组；所述作为生产者的消息队列客户端根据所述队列满指令，将生产的消息转发至所述目标队列分组；所述队列分组接收作为消费者的消息队列客户端拉取消息的请求，所述作为消费者的消息队列客户端用于订阅所述消息主题并处理所述消息主题下的队列分组中发布的消息；所述队列分组判断当前的队列长度是否达到阈值，若达到阈值，则向所述消费者的消息队列客户端返回队列满指令，并且返回推荐切换的目标队列分组；所述作为消费者的消息队列客户端根据所述队列满指令，将由所述队列分组拉取的消息转发至所述目标队列分组，以由所述目标队列分组对应的消费者的消息队列客户端进行处理。