开心豆豆2010 / activemq / ActiveMQ的activemq.xml详细配置讲解

0 0

   

ActiveMQ的activemq.xml详细配置讲解

2011-04-07  开心豆豆2...
  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.     
  8.   <!-- persistent="true"表示要持久化存储消息,和子元素persistenceAdapter结合使用 -->  
  9.   <!-- dataDirectory默认的存储持久化数据的目录 -->  
  10.   <!-- brokerName 设置broker的name,在注意在网络上必须是唯一的-->  
  11.   <!-- 更多参考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement -->  
  12.   <broker xmlns="http://activemq.org/config/1.0" brokerName="192.168.1.148" persistent ="true" dataDirectory="${activemq.base}/data" useShutdownHook="false">  
  13.     
  14.     <!-- Destination specific policies using destination names or wildcards -->  
  15.     <!-- wildcards意义见http://activemq.apache.org/wildcards.html -->  
  16.     <destinationPolicy>  
  17.       <policyMap>  
  18.         <policyEntries>  
  19.        <!-- 这里使用了wildcards,表示所有以EUCITA开头的topic -->  
  20.           <policyEntry topic="EUCITA.>" producerFlowControl="false" memoryLimit="10mb">  
  21.             <!-- 分发策略 -->  
  22.         <dispatchPolicy>  
  23.           <!-- 按顺序分发 -->  
  24.               <strictOrderDispatchPolicy/>  
  25.             </dispatchPolicy>  
  26.         <!--  恢复策略-->  
  27.             <subscriptionRecoveryPolicy>  
  28.           <!-- 只恢复最后一个message -->  
  29.               <lastImageSubscriptionRecoveryPolicy/>  
  30.             </subscriptionRecoveryPolicy>  
  31.           </policyEntry>  
  32.         </policyEntries>  
  33.       </policyMap>  
  34.     </destinationPolicy>  
  35.   
  36.     <!-- The transport connectors ActiveMQ will listen to -->  
  37.     <transportConnectors>  
  38.        <transportConnector name="openwire" uri="tcp://192.168.1.148:61616" discoveryUri="multicast://default"/>  
  39.        <transportConnector name="ssl"     uri="ssl://192.168.1.148:61617"/>  
  40.        <transportConnector name="stomp"   uri="stomp://192.168.1.148:61613"/>  
  41.        <transportConnector name="xmpp"    uri="xmpp://192.168.1.148:61222"/>  
  42.     </transportConnectors>  
  43.       
  44.     <!-- 消息持久化方式 -->  
  45.     <persistenceAdapter>  
  46.       <amqPersistenceAdapter directory="${activemq.base}/data"/>  
  47.     </persistenceAdapter>  
  48. </broker>  
  49.   
  50.   <!-- lets create a command agent to respond to message based admin commands on the ActiveMQ.Agent topic -->  
  51.     <commandAgent xmlns="http://activemq.org/config/1.0"/>  
  52.      
  53.   <!-- An embedded servlet engine for serving up the Admin console -->  
  54.   <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">  
  55.     <connectors>  
  56.       <nioConnector port="8161" />  
  57.     </connectors>  
  58.   
  59.     <handlers>  
  60.       <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" />        
  61.       <webAppContext contextPath="/demo" resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" />          
  62.     </handlers>  
  63.   </jetty>    
  64. </beans>  
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>  

注释

关于XML配置中元素的具体信息可以参考http://activemq.apache.org/xbean-xml-reference-50.html 下面介绍本篇配置使用的一些重要元素。

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.

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。如发现有害或侵权内容,请点击这里 或 拨打24小时举报电话:4000070609 与我们联系。

    猜你喜欢

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多
    喜欢该文的人也喜欢 更多