ActiveMQ消息存儲持久化

---------------------------------------------------------------------------------------------------

ActiveMQ提供了插件式的消息存儲，主要有有如下幾種:

　　1.AMQ消息存儲-基於文件的存儲方式，是以前的默認消息存儲

　　2.KahaDB消息存儲-提供了容量的提升和恢復能力，是現在的默認存儲方式

　　3.JDBC消息存儲-消息基於JDBC存儲的

　　4.Memory消息存儲-基於內存的消息存儲

下面就分別進行介紹:

(1)kahaDB Message Store概述
　　KahaDB是目前默認的存儲方式，可用於任何場景，提高了性能和恢復能力。消息存儲使用一個事務日志和僅僅用一個索引文件來存儲它所有的地址。
　　KahaDB是一個專門針對消息持久化的解決方案，它對典型的消息使用模式進行了優化。在kaha中，數據被追加到 data logs中。 當不再需要log文件中的數據的時候,log文件會被丟棄。
　　KahaDB基本配置如下:

可用的屬性有:
1. director: KahaDB存放的路徑，默認值activemq-data
2. indexWriteBatchSize: 批量寫入磁盤的索引page數量,默認值為1000
3. indexCacheSize: 內存中緩存索引page的數量,默認值10000
4. enableIndexWriteAsync: 是否異步寫出索引,默認false
5. journalMaxFileLength: 設置每個消息data log的大小，默認是32MB
6. enableJournalDiskSyncs: 設置是否保證每個沒有事務的內容，被同步寫入磁盤，JMS持久化的時候需要，默認為true
7. cleanupInterval: 在檢查到不再使用的消息后,在具體刪除消息前的時間,默認30000
8. checkpointInterval: checkpoint的間隔時間，默認是5000
9. ignoreMissingJournalfiles: 是否忽略丟失的消息日志文件，默認false
10. checkForCorruptJournalFiles: 在啟動的時候，將會驗證消息文件是否損壞，默認false
11. checksumJournalFiles: 是否為每個消息日志文件提供checksum,默認false
12. archiveDataLogs: 是否移動文件到特定的路徑，而不是刪除它們，默認false
13. directoryArchive: 定義消息已經被消費過后，移動data log到的路徑，默認null
14. databaseLockedWaitDelay: 獲得數據庫鎖的等待時間(used by shared master/slave),默認10000
15. maxAsyncJobs: 設置最大的可以存儲的異步消息隊列，默認值10000，可以和concurrent MessageProducers設置成一樣的值。
16. concurrentStoreAndDispatchTransactions:是否分發消息到客戶端，同時事務存儲消息，默認true
17. concurrentStoreAndDispatchTopics: 是否分發Topic消息到客戶端，同時進行存儲，默認true
18. concurrentStoreAndDispatchQueues: 是否分發queue消息到客戶端，同時進行存儲，默認true

(2)AMQ Message Store概述

　　AMQ Message Store是ActiveMQ5.0缺省的持久化存儲，它是一個基於文件、事務存儲設計為快速消息存儲的一個結構，該結構是以流的形式來進行消息交互的。
　　這種方式中，Messages被保存到data logs中，同時被reference store進行索引以提高存取速度。Data logs由一些簡單的data log文件組成，缺省的文件大小是32M，如果某個消息的大小超過了data log文件的大小，那么可以修改配置以增加data log文件的大小。如果某個data log文件中所有的消息都被成功消費了，那么這個data log文件將會被標記，以便在下一輪的清理中被刪除或者歸檔。
　　AMQ Message Store配置示例：

(3)使用JDBC來持久化消息

ActiveMQ支持使用JDBC來持久化消息，預定義的表如下：
1.消息表,缺省表明為ACTIVEMQ_MSGS, queue和topic都存儲在里面，結構如下:

2.ACTIVEMQ_ACKS表存儲持久訂閱的信息和最后一個持久訂閱接收的消息ID,結構如下:

3.鎖定表，缺省表名為ACTIVEMQ_LOCK，用來確保在某一時刻，只能有一個ActiveMQ broker實例來訪問數據庫，結構如下：

使用JDBC來持久化消息的配置示例:
在activemq.xml中的配置如下:

<broker brokerName="test-broker" persistent=true xmlns="http://activemq.apache.org/schema/core">
　　<persistenceAdapter>
　　　　<jdbcPersistenceAdapter dataSource="#mysql_ds">
　　</persistenceAdapter>
</broker>
<bean name="mysql_ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
　　<property name="driverClassName">
　　　　<value>org.gjt.mm.mysql.Driver</value>
　　</property>
　　<property name="url">
　　　　<value>jdbc:mysql://192.168.1.102:3306/test?useUnicode=true&amp;characterEncoding=UTF-8</value>
　　</property>
　　<property name="username">
　　　　<value>root</value>
　　</property>
　　<property name="password">
　　　　<value>123123</value>
　　</property>
</bean>

JDBC Message Store with ActiveMQ Journal
這種方式克服了JDBC Store的不足，使用快速的緩存寫入技術，大大提高了性能。
配置如下：

<beans>
　　<broker brokerName="test-broker" xmlns="http://activemq.apache.org/schema/core">
　　　　<persistenceFactory>
　　　　<journalPersistenceAdapterFactory journalLogFiles="4" journalLogFileSize="32768"
　　　　　　useJournal="true" useQuickJournal="true" dataSource="#mysql_ds" dataDirectory="activemq-data">
　　　　</persistenceFactory>
　　</broker>
</beans>

JDBC Store和JDBC Message Store with ActiveMQ Journal的區別：
　　1. JDBC with journal的性能優於jdbc
　　2. JDBC用於master/slave模式的數據庫分享
　　3. JDBC with journal不能用於master/slave模式
　　4. 一般情況下，推薦使用jdbc with journal
(4)Memory Message Store
　　內存消息存儲主要是存儲所有的持久化的消息在內存中。這里沒有動態的緩存存在，所以你必須注意設置你的broker所在的JVM和內存限制。

<beans>
　　<broker brokerName="test_broker" persistent="false" xmlns="http://activemq.apache.org/schema/core">
　　　　<transportConnectors>
　　　　<transportConnector uri="tcp://localhost:61635">
　　　　</transportConnectors>
</beans>