ActiveMQ的持久化方式

末蓝、 2022-06-01 03:57 217阅读 0赞

ActiveMQ持久化方式：AMQ、KahaDB、JDBC、LevelDB。

1、AMQ

AMQ是一种文件存储形式，它具有写入速度快和容易恢复的特点。消息存储在一个个文件中，文件的默认大小为32M，如果一条消息的大小超过了32M，那么这个值必须设置大一点。当一个存储文件中的消息已经全部被消费，那么这个文件将被标识为可删除，在下一个清除阶段，这个文件被删除。AMQ适用于ActiveMQ5.3之前的版本。默认配置如下：

<table> 
 <tbody> 
 <tr> 
 <td>1 2 3</td> 
 <td>&lt;persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&lt;amqPersistenceAdapter directory="activemq-data"maxFileLength="32mb"/&gt; &lt;/persistenceAdapter&gt;</td> 
 </tr> 
 </tbody> 
</table>

2、KahaDB

KahaDB是基于文件的本地数据库储存形式，虽然没有AMQ的速度快，但是它具有强扩展性，恢复的时间比AMQ短，从5.4版本之后KahaDB做为默认的持久化方式。默认配置如下：

<table> 
 <tbody> 
 <tr> 
 <td>1 2 3</td> 
 <td>&lt;persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&lt;kahaDB directory="activemq-data"journalMaxFileLength="32mb"/&gt; &lt;/persistenceAdapter&gt;</td> 
 </tr> 
 </tbody> 
</table>

每个KahaDB的实例都可以配置单独的适配器，如果没有目标队列提交给filteredKahaDB，那么意味着对所有的队列有效。如果一个队列没有对应的适配器，那么将会抛出一个异常。配置如下：

<table> 
 <tbody> 
 <tr> 
 <td>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19</td> 
 <td>&lt;persistenceAdapter&gt; &nbsp;&nbsp;&lt;mKahaDBdirectory="${activemq.base}/data/kahadb"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;filteredPersistenceAdapters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- match all queues --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;filteredKahaDBqueue="&gt;"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;kahaDBjournalMaxFileLength="32mb"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/filteredKahaDB&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- match all destinations --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;filteredKahaDB&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;kahaDBenableJournalDiskSyncs="false"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/filteredKahaDB&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;/filteredPersistenceAdapters&gt; &nbsp;&nbsp;&lt;/mKahaDB&gt; &lt;/persistenceAdapter&gt;</td> 
 </tr> 
 </tbody> 
</table>

如果filteredKahaDB的perDestination属性设置为true，那么匹配的目标队列将会得到自己对应的KahaDB实例。配置如下：

<table> 
 <tbody> 
 <tr> 
 <td>1 2 3 4 5 6 7 8 9 10 11 12</td> 
 <td>&lt;persistenceAdapter&gt; &nbsp;&nbsp;&lt;mKahaDBdirectory="${activemq.base}/data/kahadb"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;filteredPersistenceAdapters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- kahaDB per destinations --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;filteredKahaDB perDestination="true"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;kahaDBjournalMaxFileLength="32mb" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/filteredKahaDB&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;/filteredPersistenceAdapters&gt; &nbsp;&nbsp;&lt;/mKahaDB&gt; &lt;/persistenceAdapter&gt;</td> 
 </tr> 
 </tbody> 
</table>

3、JDBC

可以将消息存储到数据库中，例如：Mysql、SQL Server、Oracle、DB2。

配置JDBC适配器：

<table> 
 <tbody> 
 <tr> 
 <td>1 2 3</td> 
 <td>&lt;persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;jdbcPersistenceAdapterdataSource="#mysql-ds" createTablesOnStartup="false" /&gt; &lt;/persistenceAdapter&gt;</td> 
 </tr> 
 </tbody> 
</table>

dataSource指定持久化数据库的bean，createTablesOnStartup是否在启动的时候创建数据表，默认值是true，这样每次启动都会去创建数据表了，一般是第一次启动的时候设置为true，之后改成false。

<table> 
 <tbody> 
 <tr> 
 <td>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26&nbsp;&nbsp; 27 28 29 30 31 32 33 34</td> 
 <td>&lt;!--Mysql持久化bean：à --&gt; &lt;bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="driverClassName" value="com.mysql.jdbc.Driver"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="username" value="activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="password" value="activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="poolPreparedStatements" value="true"/&gt; &lt;/bean&gt; &lt;!--&nbsp;SQL Server持久化bean：--&gt; &lt;bean id="mssql-ds" class="net.sourceforge.jtds.jdbcx.JtdsDataSource" destroy-method="close"&gt; &nbsp;&nbsp;&nbsp;&lt;property name="serverName" value="SERVERNAME"/&gt; &nbsp;&nbsp;&nbsp;&lt;property name="portNumber" value="PORTNUMBER"/&gt; &nbsp;&nbsp;&nbsp;&lt;property name="databaseName" value="DATABASENAME"/&gt; &nbsp;&nbsp;&nbsp;&lt;property name="user" value="USER"/&gt; &nbsp;&nbsp;&nbsp;&lt;property name="password" value="PASSWORD"/&gt; &lt;/bean&gt; &lt;!--&nbsp;Oracle持久化bean：--&gt; &lt;bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="url" value="jdbc:oracle:thin:@10.53.132.47:1521:activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="username" value="activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="password" value="activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="maxActive" value="200"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="poolPreparedStatements" value="true"/&gt; &lt;/bean&gt; &lt;!--&nbsp;DB2持久化bean：--&gt; &lt;bean id="db2-ds" class="org.apache.commons.dbcp.BasicDataSource"&nbsp; destroy-method="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="driverClassName" value="com.ibm.db2.jcc.DB2Driver"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="url" value="jdbc:db2://hndb02.bf.ctc.com:50002/activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="username" value="activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="password" value="activemq"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="maxActive" value="200"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="poolPreparedStatements" value="true"/&gt; &nbsp;&nbsp;&lt;/bean&gt;</td> 
 </tr> 
 </tbody> 
</table>

4、LevelDB

这种文件系统是从ActiveMQ5.8之后引进的，它和KahaDB非常相似，也是基于文件的本地数据库储存形式，但是它提供比KahaDB更快的持久性。与KahaDB不同的是，它不是使用传统的B-树来实现对日志数据的提前写，而是使用基于索引的LevelDB。默认配置如下：

<table> 
 <tbody> 
 <tr> 
 <td>1 2 3</td> 
 <td>&lt;persistenceAdapter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;levelDBdirectory="activemq-data"/&gt; &lt;/persistenceAdapter&gt;</td> 
 </tr> 
 </tbody> 
</table>