如何避免activeMQ数据丢失

做消息持久化  借助 jdbc, kahadb或 leveldb+zookeeper
首先将将消息发送设置为持久化发送(mq自带的属性),然后再借助jdbc kahadb leveldb+zookeeper等做消息的存储来持久化。
思想都是发送者(消息生产者)将消息发送出去后,消息中心首先将消息存储到本地数据文件、内存数据库或者远程数据库等。再试图将消息发给接收者,成功则将消息从存储中删除,失败则继续尝试尝试发送。消息中心启动以后,要先检查指定的存储位置是否有未成功发送的消息,如果有,则会先把存储位置中的消息发出去。

相关推荐