设为首页 收藏本站
查看: 1347|回复: 0

[经验分享] ActiveMQ.xml文件的主要配置

[复制链接]
发表于 2017-3-2 08:54:18 | 显示全部楼层 |阅读模式
  ActiveMQ.xml文件默认位置位于 activemq/conf/目录下,主要的配置及解析如下:
<beans  
  xmlns="http://www.springframework.org/schema/beans"  
  xmlns:amq="http://activemq.org/config/1.0"  
  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   
  http://activemq.org/config/1.0 http://activemq.apache.org/schema/activemq-core.xsd   
  http://activemq.apache.org/camel/schema/spring>  
   
  <!-- persistent="true"表示要持久化存储消息,和子元素persistenceAdapter结合使用 -->  
  <!-- dataDirectory默认的存储持久化数据的目录 -->  
  <!-- brokerName 设置broker的name,在注意在网络上必须是唯一的-->  
  <!-- 更多参考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement -->  
  <broker xmlns="http://activemq.org/config/1.0" brokerName="192.168.1.148" persistent ="true" dataDirectory="${activemq.base}/data" useShutdownHook="false">  
   
    <!-- Destination specific policies using destination names or wildcards -->  
    <!-- wildcards意义见http://activemq.apache.org/wildcards.html -->  
    <destinationPolicy>  
      <policyMap>  
        <policyEntries>  
       <!-- 这里使用了wildcards,表示所有以EUCITA开头的topic -->  
          <policyEntry topic="EUCITA.>" producerFlowControl="false" memoryLimit="10mb">  
            <!-- 分发策略 -->  
        <dispatchPolicy>  
          <!-- 按顺序分发 -->  
              <strictOrderDispatchPolicy/>  
            </dispatchPolicy>  
        <!--  恢复策略-->  
            <subscriptionRecoveryPolicy>  
          <!-- 只恢复最后一个message -->  
              <lastImageSubscriptionRecoveryPolicy/>  
            </subscriptionRecoveryPolicy>  
          </policyEntry>  
        </policyEntries>  
      </policyMap>  
    </destinationPolicy>  
  
    <!-- The transport connectors ActiveMQ will listen to -->  
    <transportConnectors>  
       <transportConnector name="openwire" uri="tcp://192.168.1.148:61616" discoveryUri="multicast://default"/>  
       <transportConnector name="ssl"     uri="ssl://192.168.1.148:61617"/>  
       <transportConnector name="stomp"   uri="stomp://192.168.1.148:61613"/>  
       <transportConnector name="xmpp"    uri="xmpp://192.168.1.148:61222"/>  
    </transportConnectors>  
      
    <!-- 消息持久化方式 -->  
    <persistenceAdapter>  
      <amqPersistenceAdapter directory="${activemq.base}/data"/>  
    </persistenceAdapter>  
</broker>  
  
  <!-- lets create a command agent to respond to message based admin commands on the ActiveMQ.Agent topic -->  
    <commandAgent xmlns="http://activemq.org/config/1.0"/>  
     
  <!-- An embedded servlet engine for serving up the Admin console -->  
  <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">  
    <connectors>  
      <nioConnector port="8161" />  
    </connectors>  
  
    <handlers>  
      <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" />        
      <webAppContext contextPath="/demo" resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" />         
    </handlers>  
  </jetty>   
</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种恢复策略,可以自行选择使用不同的策略:
  <fixedCountSubscriptionRecoveryPolicy>: keep a fixed count of last messages.
        <fixedSizedSubscriptionRecoveryPolicy>: keep a fixed amount of memory available in RAM for message history which is
          evicted in time order.
        <lastImageSubscriptionRecoveryPolicy>:only keep the last message.
        <noSubscriptionRecoveryPolicy>:disable recovery of messages.
        <queryBasedSubscriptionRecoveryPolicy>:perform a user specific query mechanism to load any messages they may have missed.
        <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.2使用AMQ Message Store 持久化消息,这种方式提供了很好的性能(The AMQ Message Store is an embeddable transactional message storage solution that is extremely fast and reliable.) 默认使用该存储方式即可,如果想使用JDBC来存储,可以查找文档配置。

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-349048-1-1.html 上篇帖子: Solr学习笔记-在Tomcat上部署执行Solr 下篇帖子: Jmeter测试webocket协议
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表