一种消息存储方法、装置及一种消息处理系统

摘要

本发明公开了一种消息存储方法及装置，以解决现有技术中采用单节点存储所存在的问题。所述方法包括：接收消息添加请求；从预置的存储节点列表中选择一个存储节点，存储该消息；将该消息与存储该消息的存储节点之间的映射关系进行保存。所述方案能够避免两个问题：第一，如果其中一个存储节点出现了问题，还可以将消息存储到其他节点上，因此不会造成消息中间件不能正常工作；第二，如果消息流量很大，多个存储节点可以分散存储上的压力。本发明还提供了一种消息处理系统，以解决单节点存储待转发的消息容易造成系统瓶颈或处理中断的问题。

主权项

一种消息存储方法，其特征在于，包括：接收消息添加请求；从预置的存储节点列表中选择一个存储节点，存储该消息；将该消息与存储该消息的存储节点之间的映射关系进行保存，所述映射关系由消息中间件进行维护;所述方法还包括：在应用服务器运行期间通过动态修改所述存储节点列表，增加或删除存储节点。