activemq的灾备和负载均衡实现.docxVIP

Master-Slave与Broker-Cluster相结合的部署方式可以看到Master-Slave的部署方式虽然解决了高可用的问题，但不支持负载均衡，Broker-Cluster解决了负载均衡，但当其中一个Broker突然宕掉的话，那么存在于该Broker上处于Pending状态的message将会丢失，无法达到高可用的目的。这里以Broker-A + Broker-B建立cluster，Broker-C作为Broker-B的slave为例：(LB)(HA)A -----B--------C(Broker-Cluster) (Master-Slave)注：networkConnector节点一定要加在persistenceAdapter节点之前。1）首先在Broker-A节点中添加networkConnector节点：networkConnectors? ??????????????? networkConnector?? uri=masterslave:(tcp://0.0.0.0:61617,tcp:// 0.0.0.0:61618) duplex=false//networkConnectors2）修改Broker-A节点中的服务提供端口为61616：transportConnectors?? ??????transportConnectorname=openwireuri=tcp://0.0.0.0:61616?maximumConnections=1000amp;wireFormat.maxFrameSize=104857600//transportConnectors3）在Broker-B节点中添加networkConnector节点：networkConnectors? ??????????????? networkConnector?? uri=static:(tcp://0.0.0.0:61616)duplex=false//networkConnectors4）修改Broker-B节点中的服务提供端口为61617：transportConnectors?? ??????transportConnectorname=openwireuri=tcp://0.0.0.0:61617?maximumConnections=1000amp;wireFormat.maxFrameSize=104857600//transportConnectors5）修改Broker-B节点中的持久化方式：??????persistenceAdapter???????????kahaDB directory=/localhost/kahadb/????? ??/persistenceAdapter6）在Broker-C节点中添加networkConnector节点：networkConnectors? ??????????????? networkConnector?? uri=static:(tcp://0.0.0.0:61616)duplex=false//networkConnectors7）修改Broker-C节点中的服务提供端口为61618：transportConnectors?? ??????transportConnectorname=openwireuri=tcp://0.0.0.0:61618?maximumConnections=1000amp;wireFormat.maxFrameSize=104857600//transportConnectors8）修改Broker-C节点中的持久化方式：??????persistenceAdapter???????????kahaDB directory=/localhost/kahadb/???????/persistenceAdapter9)进入Broker-B\conf\jetty.xml修改其控制台管理的端口号为8162.10）进入Broker-C\conf\jetty.xml修改其控制台管理的端口号为8163.11）分别启动broker-A、broker-B、broker-C，因为是broker-B先启动，所以“/localhost/kahadb”目录被lock住，broker-C将一直处于挂起状态，当人为停掉broker-B之后，broker-C将获取目录“/localhost/kahadb”的控制权，重新与broker-A组成cluster提供服务。结果：可以看到broker-C被lock住；当人为停掉broker-B之后，broker-C和broker-A组成cluster提供服务当然broker-A和broker-C也组成cluster提供服务