[发明专利]一种提高消息队列系统性能的装置及其方法

摘要

本发明公开一种提高消息队列系统性能的装置及其方法，包括：生产者模块，用于实现发送策略、连接管理功能；ThriftServer中转层模块，用于实现连接管理、队列与所在主机对应关系查询与维护、统计功能、配额管理功能以及发布消息功能；消费者模块，主要用于实现连接管理、队列与所在主机对应关系查询与维护、获取消息的功能；中心节点数据库，用于实现统一的后端存储，使用Redis实现，作为中心节点维护系统的元信息；自动化工具Tools，为一系列自动化工具；HTTP服务器，用于提供对读取和发送消息队列消息的RESTful访问接口。利用本发明，能够解决RabbitMQ的集群特性会出现实例内存暴涨的缺陷，并提高消息队列RabbitMQ的性能，提高其处理能力。

主权项

一种提高消息队列系统性能的装置，其特征在于，主要包括：生产者模块Producer，Thrift Server中转层模块，消费者模块Consumer，中心节点数据库Database，自动化工具Tools以及HTTP服务器；其中：所述生产者模块Producer，用于实现发送策略、连接管理功能；所述Thrift Server中转层模块，用于实现连接管理、队列与所在主机对应关系查询与维护、统计功能、配额管理功能以及发布消息功能；所述消费者模块Consumer，主要用于实现连接管理、队列与所在主机对应关系查询与维护、获取消息的功能；所述中心节点数据库Database，用于实现统一的后端存储，使用Redis实现，作为中心节点维护系统的元信息；所述Thrift Server中转层模块和消费者模块Consumer均将从该中间节点数据库Database中查找队列与所在主机的对应关系、更新统计和查询配额；所述自动化工具Tools，为一系列自动化工具，包括项目创建、队列创建、队列监控、配额管理工具；所述HTTP服务器，用于提供对读取和发送消息队列消息的RESTful访问接口。