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&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
#配置reply信息的删除
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue="*.reply.>" gcInactiveDestinations="true" inactiveTimoutBeforeGC="300000" />
<policyEntry topic=">" producerFlowControl="false"/>
</policyEntries>
</policyMap>
</destinationPolicy>
页:
[1]