官网
http://activemq.apache.org/persistence
有哪些
ActiveMQ Message Store (了解)
基于文件的存储方式,是以前的默认消息存储,现在不用了
KahaDB 消息存储(默认)
基于日志文件,从ActiveMQ5.4开始默认的持久化插件
验证
说明
http://activemq.apache.org/kahadb
kahaDB的存储原理
LevelDB消息存储(了解)
JDBC Message store with ActiveMQ Journal
JDBC消息存储
1.MQ+Mysql
2.添加mysql数据库的驱动包到lib文件夹
3.jdbcPersistanceAdapter配置
4.数据库连接池配置
5.建库建表说明
建一个名为activemq的数据库
三张表的说明
activemq_msgs
activemq_acks
activemq_lock
如果新建数据库OK+上述配置OK+代码运行OK,三张表会自动建立
万一情况,手动建表sql如果配置不好需要手动,应急
6.代码运行验证
一定要开启持久化
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
7.数据库情况
mysql
queue
在运行消费看看表msgs数据的变化情况
topic
先启动消费者订阅在运行生产者,看acks
8.小总结
9.开发有坑
JDBC Message store with ActiveMQ Journal
配置
重启配置文件激活
运行