ActiveMQ 自学（三）集群部署

心已赠人 2022-07-24 08:27 238阅读 0赞

# ActiveMQ 自学（三） 集群部署 #

[转载---茂盛博客][---]

[gossip][]

[maosheng][]

这里我介绍Broker-cluster集群部署-------实现负载均衡

Broker-Cluster部署方式中，各个broker通过网络互相连接，并共享queue。

当broker-A上面指定的queue-A中接收到一个message处于pending状态，而此时没有consumer连接broker-A时

（没有消费者了，目前queue-A只能等待）；但如果cluster中的broker-B上面有一个consumer

在消费queue-A的消息（并且处于闲置状态）， 那么 broker-B 会先通过内部网络获取到 broker-A 上面的 message ，

并通知自己的consumer来消费。这样就实现了负载均衡。

此处基本配置-----修改activemq中的activemq.xml文件中静态指定broker需要建立桥连接的其他broker；

首先在Broker-A节点中添加networkConnector节点：

修改Broker-B节点添加networkConnector节点：

分别启动mqA、B

同理，如果您的ActiveMQ集群规划中有三个ActiveMQ服务节点，那么任何一个节点都应该配置其它两个服务节点的连接方式。

其他配置属性

下表列举了在networkConnector标签中还可以使用的属性以及其意义。请特别注意其中的duplex属性。如果只从字面意义理解该属性，

则被称为“双工模式”；如果该属性为true，当这个节点使用Network Bridge连接到其它目标节点后，

将强制目标也建立Network Bridge进行反向连接。其目的在于让消息既能发送到目标节点，又可以通过目标节点接受消息，

但实际上大多数情况下是没有必要的，因为目标节点一般都会自行建立连接到本节点。所以，该duplex属性的默认值为false。

<table style="width:948px; border-collapse:collapse; border-spacing:0px; border:1px solid rgb(238,238,238); color:rgb(85,85,85); font-family:&quot;microsoft yahei&quot;; font-size:14px"> 
 <thead style=""> 
  <tr style=""> 
   <th align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 属性名称</th> 
   <th align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 默认值</th> 
   <th style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 属性意义</th> 
  </tr> 
 </thead> 
 <tbody style=""> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> name</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> bridge</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 名称</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> dynamicOnly</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> false</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 如果为true, 持久订阅被激活时才创建对应的网路持久订阅。</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> decreaseNetworkConsumerPriority</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> false</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 如果为true，网络的消费者优先级降低为-5。如果为false，则默认跟本地消费者一样为0.</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> excludedDestinations</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> empty</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 不通过网络转发的destination</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> dynamicallyIncludedDestinations</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> empty</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 通过网络转发的destinations，注意空列表代表所有的都转发。</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> staticallyIncludedDestinations</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> empty</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 匹配的都将通过网络转发-即使没有对应的消费者，如果为默认的“empty”，<br> 那么说明所有都要被转发</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> duplex</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> false</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 已经进行详细介绍的“双工”属性。</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> prefetchSize</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 1000</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 设置网络消费者的prefetch size参数。如果设置成0，那么就像之前文章介绍过的那样：<br> 消费者会自己轮询消息。显然这是不被允许的。</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> suppressDuplicateQueueSubscriptions</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> false</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 如果为true, 重复的订阅关系一产生即被阻止（V5.3+ 的版本中可以使用）。</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> bridgeTempDestinations</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> true</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 是否广播advisory messages来创建临时destination。</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> alwaysSyncSend</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> false</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 如果为true，非持久化消息也将使用request/reply方式代替oneway方式发送到<br> 远程broker（V5.6+ 的版本中可以使用）。</td> 
  </tr> 
  <tr style=""> 
   <td align="right" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> staticBridge</td> 
   <td align="center" style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> false</td> 
   <td style="padding:8px; line-height:20px; vertical-align:top; border:1px solid rgb(238,238,238)"> 如果为true，只有staticallyIncludedDestinations中配置的destination<br> 可以被处理（V5.6+ 的版本中可以使用）。</td> 
  </tr> 
 </tbody> 
</table>

以下这些属性，只能在静态Network Connectors模式下使用

请注意这些属性，并不是networkConnector标签的属性，而是在uri属性中进行设置的，例如：

uri= "static:(tcp://host1:61616,tcp://host2:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"

[---]: http://maosheng.iteye.com/blog/2174247
[gossip]: http://www.cnblogs.com/gossip/p/5981106.html
[maosheng]: http://maosheng.iteye.com/blog/2224967