activemq 數據存儲

1、jdbcPersistenceAdapter數據庫存儲

<persistenceAdapter>

   <jdbcPersistenceAdapter dataSource="#mysql-ds" createTablesOnStartup="true"/>

</persistenceAdapter>

注:紅色標記的地方,第一次啟動時建議設置成true,會自動生成 activemq_msgs/activemq_lock/activemq_acks三張表,同時需要注意,不同的activemq版本,表結構會有所區別.表生成之后,必須將其設置成false.

<bean id="mysql-ds" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">

    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>

    <property name="url" value="jdbc:mysql://localhost:3306/activemq?relaxAutoCommit=true"/>

    <property name="username" value="root"/>

    <property name="password" value="root"/>

    <property name="maxTotal" value="200"/>

    <property name="poolPreparedStatements" value="true"/>

</bean>

注:紅色標記的地方,是針對不同的dbcp版本而言的.如果是版本1.*,則是org.apache.commons.dbcp.BasicDataSource

更多參數設置請參考:http://blog.csdn.net/fairyhawk/article/details/7565391

2、memoryPersistenceAdapter 內存存儲

<persistenceAdapter>

   <memoryPersistenceAdapter/>

</persistenceAdapter>

或者將persistent=false。

3、kahaDB文件存儲

<persistenceAdapter>

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

</persistenceAdapter>

4、journalPersistenceAdapter文件存儲

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

適用場景:對于集群的broker用JDBC的消息和日志存儲,可以有效的避免數據丟失.

5、mKahaDB文件存儲

<persistenceAdapter>

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

</persistenceAdapter>

6、replicatedLevelDB文件存儲

<persistenceAdapter>

   <replicatedLevelDB

      directory="${activemq.data}"

      replicas="2"

      bind="tcp://0.0.0.0:61619"

      zkAddress="127.0.0.1:2181"

      zkPassword="password"

      zkPath="/activemq/leveldb-stores"

      />

</persistenceAdapter>

7、levelDB文件存儲

<persistenceAdapter>

  <levelDB directory="${activemq.data}/leveldb"/>

</persistenceAdapter>

參考：https://blog.51cto.com/881206524/1927604