引言

ActiveMQ在不提供持久化的情况下，数据保存在内存中，一旦应用崩溃或者重启之后，数据都将会丢失，这显然在大部分情况下是我们所不希望的。对此ActiveMQ提供了两种持久化方式以供选择。

一、kahaDB

kahaDB是一个基于文件，支持事务的、可靠，高性能，可扩展的消息存储器，目前是activeMQ默认的持久化方式，配置也十分简单

<persistenceAdapter>
<kahaDB directory="${activemq.data}/kahadb"/>
</persistenceAdapter>

以上配置是将存储目录设置为${activemq.data}/kahadb,到存储目录下查看会发现以下文件

• db.data
  索引文件，本质上是BTree的实现，存储到了db-*.log消息文件的索引。
• db.redo
  用来进行数据恢复的redo文件
• db-*.log
  存储消息内容的文件，包括消息元数据、订阅关系、事务等数据。
• lock

kahaDB配置支持的参数有:

• indexWriteBatchSize
  默认值1000，当缓存中更新的索引到达1000时，将数据同步到磁盘中，数据是批量同步的。
• indexCacheSize
  默认值10000，在内存中最多分配多个页面来缓存索引。缓存的索引越多，命中的概率就越大，检索的效率就越高
• journalMaxFileLength
  默认值32MB，配置单个消息文件的大小，超过一定大小以后重新创建一个新的文件进行保存。
• enableJournalDiskSyncs
  默认值true，表示采用同步写磁盘，即消息先存储到磁盘后再向Producer返回ACK
• cleanupInterval
  默认值30s，当消息被消息者成功消费之后，Broker就可以将消息删除的时间间隔。
• checkpointInterval
  默认值5s，每隔5s将内存中的index缓存更新到磁盘文件中。

Database

除了kahaDB外，activeMQ还支持将数据持久化到数据库中，配置也十分简单，在conf/activemq.xml中增加如下配置:

<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#mysql-ds"/>
</persistenceAdapter>

<bean id="mysql-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="root"/>
<property name="password" value=""/>
<property name="maxActive" value="200"/>
<property name="poolPreparedStatements" value="true"/>
</bean>