ctiveMQ是當下最流行和強大的開源企業訊息整合元件。

ActiveMQ效能優良，支援多種跨語言的客戶端和協議，支援JMS1.1和J2EE1.4，易於使用並且特性多多。

ActiveMQ基於Apache 2.0 License軟體協議。

當前最新版本為5.2.0（目前最新的是5.13.X）

最新特性：

• 多語言多協議支援，Java、C、C++、C#可以通過OpenWire協議編寫高效的客戶端；
• Stomp協議的支援使得我們可以用Ruby、Perl、Python、AS等等語言方便的編寫客戶端程式。
• 通過整合Apache Camel 庫，中介軟體和客戶端可以完全支援Enterprise Integration Patterns(企業整合模式)
• 支援許多高階特性如：訊息群組(Message Groups)、虛擬端點(Virtual Destinations)、萬用字元(Wildcards)、複合端點(Composite Destinations)等
• 完全支援JMS1.1和J2EE1.4規範包括對臨時、持久、XA事務訊息的支援
• spring支援JMS規範，所以Acticemq可以整合到spring，集中管理。
• 在支援J2EE1.4規範的多個流行J2EE伺服器上通過測試。
• 可插拔的傳輸協議支援 比如：in-VM, TCP, SSL, NIO, UDP, multicast, JGroups and JXTA transports
• 支援超快的JDBC訊息持久化和高效的日誌系統
• 為高效服務叢集、客戶服務機、基於點通訊系統而設計。
• REST-ful支援。
• Ajax支援。
• 對CXF和Axis的支援可以幫助Activemq通過web service來提供可靠的訊息服務。
• 等等。。。

ActiveMq5.2.0 對JDK的要求是 JDK 5 and later。如果要搭建MQ服務，那麼在目標機器上必須設定JAVA_HOME變 量，指向JDK的安裝目錄。

依賴：

要正常使用ActiveMq的功能至少需要activemq-core.jar、commons-logging.jar、J2EE API。

AMQ Message Store 是什麼？

預設的activemq訊息儲存是通過一個所謂的AMQ Message Store來完成。

AMQ Message Store是一個高效的可嵌入支援事務的訊息儲存解決方案。

在此方案下訊息（Message）本身以日誌的形式實現持久化，存放在Data Log裡。並且還對日誌裡的訊息做了引用索引，方便快速取回Message。

一般情況下訊息索引存放於記憶體（Cache）中，MQ Server定期將索引內容持久化，存放到Reference Store。

Message Data Log檔案是有容量限制的，預設是32MB，可自行配置容量。當該Data Log檔案裡所有訊息都被消費完的時候，Data Log檔案就會被加上一個標記，通知下一次訊息清理時可以被處理掉（處理方式可以是delete或是轉移到Achieve目錄）。

AMQ Message Store方案中 Cache 、Data Log、Reference Store 協作圖如下：

AMQ Message Store的屬性是可以配置的，你可以在conf/activemq.xml配置檔案裡新增上如下配置：

Xml程式碼

 <persistenceAdapter> 
<amqPersistenceAdapter directory="activemq-data" maxFileLength="32mb"/>
 </persistenceAdapter> 

屬性說明

AMQ Message Store體系中 目錄結構參照下圖 ：

頂層目錄broker name

用broker name命名，預設目錄名是localhost，broker name在activemq的配置檔案裡指定，以下是它的子目錄:

archive

丟棄的Data Log就放到這裡，當archiveDataLogs 屬性配置為true時才會存在

journal

message data log的所在

kr-store

reference store 目錄

data

引用索引所在目錄

state

記錄store的狀態

tmp-storage

用來儲存一些事物性的訊息以減輕記憶體的負擔例如等待正常但是速度很慢的消費端來消費非持久化的Topic.

其他持久化方式

activemq同樣支援JDBC持久化Message，我們只需要把配置層

Xml程式碼

 <persistenceAdapter> 
<amqPersistenceAdapter directory="activemq-data" maxFileLength="32mb"/>
</persistenceAdapter>

改成AMQ Message Store and JDBC（推薦，同時使用兩者可以同時保證效率和可靠性）:

Xml程式碼

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

或是 JDBC only（現階段不推薦，單獨的JDBC儲存效率不高）：

Xml程式碼

 <persistenceAdapter>
<jdbcPersistenceAdapter dataSource="#oracle-ds"/>
</persistenceAdapter>

Oracle資料來源的配置如下：

Xml程式碼

 <bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
      <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
      <property name="url" value="jdbc:oracle:thin:@localhost:1521:AMQDB"/>
      <property name="username" value="scott"/>
      <property name="password" value="tiger"/>
      <property name="maxActive" value="200"/>
      <property name="poolPreparedStatements" value="true"/>
    </bean>

其他資料來源配置參照Activemq的文件。