消息中间件Activemq之BrokerCluster

接着上一篇消息中间件-Activemq之Master-Slaver&＃xff0c;下面看看Broker-Cluster实现负载均衡
Broker-Cluster实现负载均衡

Broker-Cluster部署方式中&＃xff0c;各个broker通过网络互相连接&＃xff0c;并共享queue&＃xff0c;提供了2中部署方式&＃xff1a;
static Broker-Cluster和Dynamic Broker-Cluster

1).static Broker-Cluster

将ActiveMq拷贝2份&＃xff0c;分别命名:apache-activemq-5.10.0_M1,apache-activemq-5.10.0_M2&＃xff0c;
下面就是配置activemq,xml:
M1做如下配置:

M2做如下配置:

通过以上配置使M1和M2这两个 broker通过网络互相连接&＃xff0c;并共享queue&＃xff0c;
启动M1和M2,可以看到如下启动日志&＃xff1a;

可以看到M1和M2&＃xff0c;network connection has been established

测试我们还是用上一篇中的Sender和Receiver类&＃xff0c;只需要做一点点修改&＃xff1a;
Sender类还是链接tcp://localhost:61616&＃xff0c;发送消息到queue&＃xff0c;
Receiver做如下修改:

connectionFactory &＃61; new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61617");

经测试Receiver可以接受到数据&＃xff0c;表示M1和M2已经共享了queue

2).Dynamic Broker-Cluster

Dynamic Discovery集群方式在配置ActiveMQ实例时&＃xff0c;不需要知道所有其它实例的URI地址
对activemq.xml做如下配置:
M1做如下配置:

M2做如下配置:

启动M1和M2,可以看到如下启动日志&＃xff1a; network connection has been established

测试同static broker-cluster,可以得到相同的结果。
官网配置说明&＃xff1a;http://activemq.apache.org/networks-of-brokers.html

Master-Slaver保证了数据的可靠性&＃xff0c;Broker-Cluster提供了负载均衡&＃xff0c;所以一般正式环境中都会采用&＃xff1a;
Master-Slaver&＃43;Broker-Cluster的模式