一种消息队列的消费系统、方法及装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN107395729A(43)申请公布日2017.11.24(21)申请号201710624568.4(22)申请日2017.07.27(71)申请人深圳乐信软件技术有限公司地址518000广东省深圳市南山区粤海街道科苑南路3099号中国储能大厦第24层(72)发明人鲍明宇康彬龚晓晖陈延(74)专利代理机构北京品源专利代理有限公司11332代理人孟金喆(51)Int.Cl.H04L29/08(2006.01)权利要求书2页说明书9页附图5页(54)发明名称一种消息队列的消费系统、方法及装置(57)摘要本发明公开了一种消息队列消费系统、方法及装置。该系统包括：消息队列服务器集群，用于存储消息数据；消息队列统一消费者客户端，用于通过运行预先创建的消费者实例，与所述消息队列服务器集群建立连接，以及获取并分发订阅的所述消息队列服务器集群中的消息队列存储的消息数据；消费者服务，与所述消息队列统一消费者客户端相连，用于接收并处理所述消息队列统一消费者客户端分发的所述消息数据。本发明通过部署消息队列统一消费者客户端，实现了消费者服务中的业务代码逻辑与消息队列的应用程序接口之间的解耦，降低了由于消息队列产品变更带来的开发维护难度，同时减少用户投入的精力和成本。CN107395729ACN107395729A权利要求书1/2页1.一种消息队列消费系统，其特征在于，包括：消息队列服务器集群，用于存储消息数据；消息队列统一消费者客户端，用于通过运行预先创建的消费者实例，与所述消息队列服务器集群建立连接，以及获取并分发订阅的所述消息队列服务器集群中的消息队列存储的消息数据；消费者服务，与所述消息队列统一消费者客户端相连，用于接收并处理所述消息队列统一消费者客户端分发的所述消息数据。2.根据权利要求1所述的消费系统，其特征在于，还包括：配置中心，与所述消息队列统一消费者客户端相连，用于发布预先配置的连接参数信息和消费关系数据至所述消息队列统一消费者客户端；其中，所述消息队列统一消费者客户端根据所述连接参数信息与所述消息队列服务器集群建立连接关系；根据所述消费关系数据确定获取的消息数据与消费者服务的关联关系，并根据所述关联关系将获取的消息数据分发给对应的消费者服务。3.根据权利要求1或2所述的消费系统，其特征在于，还包括：消费者调用代理服务，连接在所述消息队列统一消费者客户端和所述消费者服务之间，用于作为代理适配层辅助所述消费者服务接收所述消息队列统一消费者客户端分发的所述消息数据。4.根据权利要求3所述的消费系统，其特征在于，所述消息队列服务器集群至少为一个；所述消息队列统一消费者客户端至少为一个；每个所述消息队列统一消费者客户端与一个或多个消息队列服务器集群相连，不同所述消息队列统一消费者客户端所连接的所述消息队列服务器集群相同或不同。5.一种消息队列消费方法，其特征在于，包括：通过运行预先创建的消费者实例，与消息队列服务器集群建立连接；在与所述消息队列服务器集群建立连接后，获取订阅的消息队列服务器集群中的消息队列存储的消息数据；分发所述消息数据至对应的消费者服务和/或消费者调用代理服务。6.根据权利要求5所述的消费方法，其特征在于，在运行预先创建的消费者实例之前，还包括：订阅并保存配置中心发布的连接参数信息；所述通过运行预先创建的消费者实例，与消息队列服务器集群建立连接，包括：运行预先创建的消费者实例，在所述消费者实例的运行过程中，读取保存的所述连接参数信息，根据所述连接参数信息与消息队列服务器集群建立连接。7.根据权利要求6所述的消费方法，其特征在于，在订阅并保存配置中心发布的连接参数信息时还包括：订阅并保存配置中心发布的消费关系数据；所述分发所述消息数据至对应的消费者服务和/或消费者调用代理服务，包括：读取保存的所述消费关系数据，根据所述消费关系数据确定获取的消息数据与消费者服务的关联关系，并根据该关联关系将获取的消息数据分发给对应的消费者服务或者分发给对应的消费者服务所连接的消费者调用代理服务。8.一种消息队列消费装置，其特征在于，包括：2CN107395729A权利要求书2/2页连接模块，用于通过运行预先创建的消费者实例，与消息队列服务器集群建立连接；获取模块，用于在与所述消息队列服务器集群建立连接后，获取订阅的消息队列服务器集群中的消息队列存储的消息数据；分发模块，用于分发所述消息数据至对应的消费者服务和/或消费者调用代理服务。9.根据权利要求8所述的消费装置，其特征在于，还包括：订阅保存模块，用于订阅并保存配置中心发送的连接参数信息；所述连接模块，包括：运行单元，用于运行预先创建的消费者实例，在所述消费者实例的运行过程中，读取保存的所述连接参数信息；连接单元，用