一种消息队列服务系统和方法

摘要

本发明实施方式提出一种消息队列服务系统和方法。消息队列访问单元向逻辑接入服务器发送队列访问请求，在队列访问请求中包括消息操作命令和队列访问信息；逻辑接入服务器根据队列访问信息生成key，按照key从key-value存储系统中检索出消息队列，并对该消息队列执行消息操作命令。本发明实施方式提高了可扩展性，在保证系统高效的同时，使得逻辑处理服务器无状态，而且可以只通过加机器的方式进行便捷地横向扩展，满足更高的访问量。

主权项

一种消息队列服务系统，其特征在于，该消息队列服务系统包括消息队列访问单元、逻辑接入服务器和key‑value存储系统，其中：key‑value存储系统，用于以key‑value方式储存消息队列；消息队列访问单元，用于向逻辑接入服务器发送队列访问请求，在所述队列访问请求中包括消息操作命令和队列访问信息；逻辑接入服务器，用于根据所述队列访问信息生成key，按照所述key从该key‑value存储系统中检索出消息队列，并对该消息队列执行所述消息操作命令；该消息队列服务系统进一步包括锁服务器；所述锁服务器，用于当存在并发操作同一消息队列的多个队列访问请求时，对该同一消息队列进行上锁，以使得所述多个队列访问请求顺序执行；所述key‑value存储系统具有多个，并构成分布式的key‑value存储系统群。