54t23 发表于 2014-12-15 08:56:13

puppet mco 配置amq的集群

通过mco自带的failover可以很简单的去做一个高可用...那么问题来了....这个简单的高可用是...   当有a、b两个mq。一堆server和client现在连接在mq a,当一个网络抖动,部分的机器到了mq b。
   这个时候你用client 在mq a中是看不到在mq b中的主机...这..怎么办。。

配置ActiveMQ
   MQ的配置如下...


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
#保证每个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>







页: [1]
查看完整版本: puppet mco 配置amq的集群