1. 程式人生 > >ActiveMQ5.0實戰三:使用Spring傳送,消費topic和queue訊息

ActiveMQ5.0實戰三:使用Spring傳送,消費topic和queue訊息

簡介

上一篇http://www.iteye.com/topic/15317介紹了ActiveMQ5.0的安裝,這一篇將介紹的配置。ActiveMQ包含了很多features(詳見http://activemq.apache.org/features.html ),   
不同的需求,不同的環境,需要不同的features,當然需要不同的配置。在這裡我只寫了最基本的配置,算是拋磚了,希望引出更多關於ActiveMQ的高階配置。
假設已經正確安裝ActiveMQ5.0,同時及其IP地址為192.168.1.148,具體使用時可以改為自己的IP。下面講解的配置實現的features如下:

  1. 客戶端可以通過tcp://192.168.1.148連線ActiveMQ。
  2. 訊息持久化儲存,重啟伺服器不會丟失訊息。
  3. 可以通過http://192.168.1.148:8161/admin監控ActiveMQ伺服器

配置

Xml程式碼  收藏程式碼
  1. <beans  
  2.   xmlns="http://www.springframework.org/schema/beans"  
  3.   xmlns:amq="http://activemq.org/config/1.0"  
  4.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd  
  5.   http://activemq.org/config/1.0 http://activemq.apache.org/schema/activemq-core.xsd  
  6.   http://activemq.apache.org/camel/schema/spring>  
  7.   <!-- persistent="true"表示要持久化儲存訊息,和子元素persistenceAdapter結合使用 -->  
  8.   <!-- dataDirectory預設的儲存持久化資料的目錄 -->  
  9.   <!-- brokerName 設定broker的name,在注意在網路上必須是唯一的-->
      
  10.   <!-- 更多參考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement -->  
  11.   <broker xmlns="http://activemq.org/config/1.0" brokerName="192.168.1.148" persistent ="true" dataDirectory="${activemq.base}/data" useShutdownHook="false">  
  12.     <!-- Destination specific policies using destination names or wildcards -->  
  13.     <!-- wildcards意義見http://activemq.apache.org/wildcards.html -->  
  14.     <destinationPolicy>  
  15.       <policyMap>  
  16.         <policyEntries>  
  17.        <!-- 這裡使用了wildcards,表示所有以EUCITA開頭的topic -->  
  18.           <policyEntry topic="EUCITA.>" producerFlowControl="false" memoryLimit="10mb">  
  19.             <!-- 分發策略 -->  
  20.         <dispatchPolicy>  
  21.           <!-- 按順序分發 -->  
  22.               <strictOrderDispatchPolicy/>  
  23.             </dispatchPolicy>  
  24.         <!--  恢復策略-->  
  25.             <subscriptionRecoveryPolicy>  
  26.           <!-- 只恢復最後一個message -->  
  27.               <lastImageSubscriptionRecoveryPolicy/>  
  28.             </subscriptionRecoveryPolicy>  
  29.           </policyEntry>  
  30.         </policyEntries>  
  31.       </policyMap>  
  32.     </destinationPolicy>  
  33.     <!-- The transport connectors ActiveMQ will listen to -->  
  34.     <transportConnectors>  
  35.        <transportConnector name="openwire" uri="tcp://192.168.1.148:61616" discoveryUri="multicast://default"/>  
  36.        <transportConnector name="ssl"     uri="ssl://192.168.1.148:61617"/>  
  37.        <transportConnector name="stomp"   uri="stomp://192.168.1.148:61613"/>  
  38.        <transportConnector name="xmpp"    uri="xmpp://192.168.1.148:61222"/>  
  39.     </transportConnectors>  
  40.     <!-- 訊息持久化方式 -->  
  41.     <persistenceAdapter>  
  42.       <amqPersistenceAdapter directory="${activemq.base}/data"/>  
  43.     </persistenceAdapter>  
  44. </broker>  
  45.   <!-- lets create a command agent to respond to message based admin commands on the ActiveMQ.Agent topic -->  
  46.     <commandAgent xmlns="http://activemq.org/config/1.0"/>  
  47.   <!-- An embedded servlet engine for serving up the Admin console -->  
  48.   <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">  
  49.     <connectors>  
  50.       <nioConnector port="8161" />  
  51.     </connectors>  
  52.     <handlers>  
  53.       <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" />       
  54.       <webAppContext contextPath="/demo" resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" />         
  55.     </handlers>  
  56.   </jetty>   
  57. </beans>  

註釋

DispathPolicy

ActiveMQ支援3中不同的分發策略(避免翻譯了以後誤解,這裡用原文):

  1. <roundRobinDispatchPolicy>:Simple dispatch policy that sends a message to every subscription that matches the message.
  2. <simpleDispatchPolicy>:Simple dispatch policy that sends a message to every subscription that matches the message.
  3. <strictOrderDispatchPolicy>:Dispatch policy that causes every subscription to see messages in the same order.

SubscriptionRecoveryPolicy

ActiveMQ支援6種恢復策略,可以自行選擇使用不同的策略

  1. <fixedCountSubscriptionRecoveryPolicy>: keep a fixed count of last messages.
  2. <fixedSizedSubscriptionRecoveryPolicy>: keep a fixed amount of memory available in RAM for message history which is evicted in time order.
  3. <lastImageSubscriptionRecoveryPolicy>:only keep the last message.
  4. <noSubscriptionRecoveryPolicy>:disable recovery of messages.
  5. <queryBasedSubscriptionRecoveryPolicy>:perform a user specific query mechanism to load any messages they may have missed.
  6. <timedSubscriptionRecoveryPolicy>:keep a timed buffer of messages around in memory and use that to recover new subscriptions.

PersistenceAdapter

http://activemq.apache.org/persistence 講解了關於persistence的資訊。ActiveMQ5.0使用AMQ Message Store持久化訊息,這種方式提供了很好的效能(The AMQ Message Store is an embeddable transactional message storage solution that is extremely fast and reliable.) 預設使用該儲存方式即可,如果想使用JDBC來儲存,可以查詢文件配置。 

Summary

本篇文章只提供了基本配置資訊。如果需要更多的文章,可以檢視ActiveMQ的文件。

講了安裝和簡單的配置,下一篇將介紹和Sping的整合,以及多個queue,多個topic,多個producer,多個consumer的配置,使用。