ActiveMQ之消息持久化方式

缺乏、安全感 2022-08-05 02:25 185阅读 0赞

ActiveMQ 5.3以后，出现了KahaDB。她是一个基于文件支持事务的消息存储器，是一个可靠，高性能，可扩展的消息存储器。  
她的设计初衷就是使用简单并尽可能的快。KahaDB的索引使用一个transactionlog，并且所有的destination只使用一个index，有人测试表明：如果用于生产环境，支持1万个active connection，每个connection有一个独立的queue。该表现已经足矣应付大部分的需求。  
KahaDB内部分为：data logs, 按照Message ID高度优化的索引，memory message cache。  
![Center][]

data logs扮演一个message journal，存储消息和命令。当大小超过了规定，将会新建一个data log.所有在data log里的消息是引用计数的，所以当一个log里的消息不在需要了，可以被删除或者放入archived文件夹。每次消息的写入都是在log的末尾增加记录，所以存储速度很快。缓存则是临时持有那些有对应消费者在线的消息。如果消费者反馈消息已经成功接收，那么这些消息就不用写入磁盘。BTree索引，保存消息的引用，并按照message ID排序。Redo log是用来保证MQ broker未干净关闭情况下，用于Btree index的重建。KahaDB的目录会在你启动MQ后自动创建（使用了KAhaDB作为存储器）

![Center 1][]

db log files：以db-递增数字.log命名。  
archive directory: 当配置支持archiving(默认不支持)并且存在，该文件夹才会创建。用于存储不再需要的data logs。  
db.data：存储btree索引

db.redo：用于hard-stop broker后，btree索引的重建

默认的情况下，ActiveMQ的消息持久化是基于文件系统的KahaDB。

当然我们也可以使用其他数据库储存消息：如mysql、oracle等

修改conf/activemq.xml 配置文件：persistenceAdapter节点。  
  
<persistenceAdapter>  
<kahaDB directory="$\{activemq.data\}/data"  dataSource="\#derby-ds"/>  
</persistenceAdapter>  
  
<bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>  
<property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>  
<property name="username" value="activemq"/>  
<property name="password" value="activemq"/>  
<property name="maxActive" value="200"/>  
<property name="poolPreparedStatements" value="true"/>  
</bean>  
然后重新启动消息队列，你会发现多了3张表  
1：activemq\_acks  ActiveMQ的签收信息  
2：activemq\_lock  ActiveMQ的锁信息  
3：activemq\_msgs ActiveMQ的消息的信息

oralce类似配置，别忘记了添加数据库驱动。

参考：[http://itindex.net/detail/44553-activemq][http_itindex.net_detail_44553-activemq]

[Center]: /images/20220805/f6f85a949c20486fa1bb8da925f198b7.png
[Center 1]: /images/20220805/cb3c5ab926524473926ab4b7b1402d45.png
[http_itindex.net_detail_44553-activemq]: http://itindex.net/detail/44553-activemq