【跟我學Puppet】1.7 mco 配置amq的集羣

  在以前的1.2 Puppet 3.7 Mcollective+SSL加密和權限驗證 中你們能夠成功的部署mco。而且結合ssl證書作權限管理....

   經過mco自帶的failover能夠很簡單的去作一個高可用...那麼問題來了....這個簡單的高可用是...

   當有a、b兩個mq。一堆server和client如今鏈接在mq a，當一個網絡抖動，部分的機器到了mq b。

   這個時候你用client 在mq a中是看不到在mq b中的主機...這..怎麼辦。。

配置ActiveMQ

     MQ的配置以下...

     

#保證每一個mq的brokerName的名字不重複
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="puppet1" dataDirectory="${activemq.data}" >

<networkConnectors> 
  <networkConnector 
    name="sina-topics" 
    uri="static:(tcp://172.16.43.20:61616)" 
    userName="mcollective" 
    password="secret" 
    duplex="true" 
    ecreaseNetworkConsumerPriority="true" 
    networkTTL="2" 
    dynamicOnly="true"> 
    <excludedDestinations> 
      <queue physicalName=">" /> 
    </excludedDestinations> 
  </networkConnector> 
  <networkConnector 
    name="sina-queues" 
    uri="static:(tcp://172.16.43.20:61616)" 
    userName="mcollective" 
    password="secret" 
    duplex="true" 
    decreaseNetworkConsumerPriority="true" 
    
    networkTTL="5" 
    dynamicOnly="true" 
    conduitSubscriptions="false"> 
    <excludedDestinations> 
      <topic physicalName=">" /> 
    </excludedDestinations> 
  </networkConnector> 
</networkConnectors>

#必須配置，AMQ集羣須要使用openwire
<transportConnectors>
  <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
</transportConnectors>

#配置reply信息的刪除
<destinationPolicy>
  <policyMap>
    <policyEntries>
      <policyEntry queue="*.reply.>" gcInactiveDestinations="true" inactiveTimoutBeforeGC="300000" />
      <policyEntry topic=">" producerFlowControl="false"/>
    </policyEntries>
  </policyMap>
</destinationPolicy>