基于Redis实现优先级消息队列的方法及系统

摘要

本发明涉及一种基于Redis实现优先级消息队列的方法及系统，其包括写消息模块以及Redis集群，写消息模块通过连接池模块与Redis集群连接；通过连接池模块与Redis集群连接后，写消息模块能将消息体写入Redis集群内，所述消息体包括队列名称、消息内容以及消息优先级，Redis集群将消息体内的消息内容存储在与队列名称以及消息优先级对应消息队列的消息列表中，且在Redis集群将消息内容存储在对应的消息列表后，通过连接池模块释放写消息模块与Redis集群的连接。本发明通过Redis集群的多个列表来实现具有优先级功能的消息队列，可以实时查看的消息队列、消息队列中消息列表的数量及对应的消息内容，能使得消息的优先级可以实时进行修改。

主权项

一种基于Redis实现优先级消息队列的方法，其特征是：包括写消息模块（2）以及用于消息队列存储及管理的Redis集群（3），所述写消息模块（2）通过连接池模块（4）与Redis集群（3）连接；通过连接池模块（4）与Redis集群（3）连接后，写消息模块（2）能将消息体写入Redis集群（3）内，所述消息体包括队列名称、消息内容以及消息优先级，Redis集群（3）将消息体内的消息内容存储在与队列名称以及消息优先级对应消息队列的消息列表中，且在Redis集群（3）将消息内容存储在对应的消息列表后，通过连接池模块（4）释放写消息模块（2）与Redis集群（3）的连接。