ActiveMQ消息的几种持久化机制

╰半夏微凉° 2023-06-12 08:52 70阅读 0赞

## ActiveMQ的消息持久化机制 ##

为了避免意外宕机以后丢失信息，需要做到重启后可以恢复消息队列，消息系统一般都会采用持久化机制。  
ActiveMQ的消息持久化机制有JDBC，AMQ，KahaDB和LevelDB，无论使用哪种持久化方式，消息的存储逻辑都是一致的。  
就是在发送者将消息发送出去后，消息中心首先将消息存储到本地数据文件、内存数据库或者远程数据库等，然后试图将消息发送给接收者，发送成功则将消息从存储中删除，失败则继续尝试。  
消息中心启动以后首先要检查指定的存储位置，如果有未发送成功的消息，则需要把消息发送出去。

ActiveMQ的持久化机制包含:

JDBC： 持久化到数据库  
AMQ ：日志文件（已基本不用）  
KahaDB ： AMQ基础上改进，默认选择  
LevelDB ：谷歌K/V数据库

## 1.JDBC ##

使用JDBC持久化方式，数据库会创建3个表：activemq\_msgs，activemq\_acks和activemq\_lock。  
activemq\_msgs用于存储消息，Queue和Topic都存储在这个表中。

**1. 将持久化方式改为JDBC的方式**

配置持久化的方式，都是修改安装目录下conf/acticvemq.xml文件，

首先定义一个mysql-ds的MySQL数据源，然后在persistenceAdapter节点中配置jdbcPersistenceAdapter并且引用刚才定义的数据源。

**createTablesOnStartup默认值是true，即每次ActiveMQ启动的时候都重新创建数据表，一般是首次启动设置为true，之后设置为false。**

**2. 在broker标签外配置数据库源**

**3. 将mysql的jdbc jar包放置到activemq的lib目录下。同时，将commons-pool.jar、commons-dbcp.jar和commons-collections.jar放置到activemq的lib目录下。**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyODU2Ng_size_16_color_FFFFFF_t_70]  
commons-dbcp.jar免费下载 https://pan.baidu.com/s/1lAwt9BCntJZ1PGO3h7kjlw 密码：r478

**4. 重新启动ActiveMQ**  
查看启动的命令行输出信息和登录ActiveMQ的默认控制台http://127.0.0.1:8161/admin。  
若ActiveMQ正常启动和运行，则表示其JDBC持久化机制设置没有问题。  
因为使用了JDBC持久化方式，数据库会创建3个表：activemq\_msgs，activemq\_acks和activemq\_lock。activemq\_msgs用于存储消息，Queue和Topic都存储在这个表中。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyODU2Ng_size_16_color_FFFFFF_t_70 1]

## 2. AMQ方式 ##

性能高于JDBC，写入消息时，会将消息写入日志文件，由于是顺序追加写，性能很高。为了提升性能，创建消息主键索引，并且提供缓存机制，进一步提升性能。每个日志文件的大小都是有限制的（默认32m，可自行配置）。  
当超过这个大小，系统会重新建立一个文件。当所有的消息都消费完成，系统会删除这个文件或者归档（取决于配置）。  
主要的缺点是AMQ Message会为每一个Destination创建一个索引，如果使用了大量的Queue，索引文件的大小会占用很多磁盘空间。  
而且由于索引巨大，一旦Broker崩溃，重建索引的速度会非常慢。

配置片段如下：

## 3.LevelDB方式 ##

从ActiveMQ 5.6版本之后，又推出了LevelDB的持久化引擎。  
目前默认的持久化方式仍然是KahaDB，不过LevelDB持久化性能高于KahaDB，可能是以后的趋势。  
在ActiveMQ 5.9版本提供了基于LevelDB和Zookeeper的数据复制方式，用于Master-slave方式的首选数据复制方案。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyODU2Ng_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191111154433716.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyODU2Ng==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyODU2Ng_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191111154715260.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDMyODU2Ng==,size_16,color_FFFFFF,t_70