如何避免activeMQ数据丢失

Posted 2021-03-01 wl889490

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