Question

怎么理解activeMQ 中的broker

Answer 1

ActiveMQ具有强大和灵活的集群功能，但在使用的过程中会发现很多的缺点，ActiveMQ的集群方式主要由两种：Master-Slave和Broker Cluster。
1、Master-Slave
Master-Slave方式中，只能是Master提供服务，Slave是实时地备份Master的数据，以保证消息的可靠性。当Master失效时，Slave会自动升级为Master，客户端会自动连接到Slave上工作。Master-Slave模式分为三类：Pure Master Slave、Shared File System Master Slave和JDBC Master Slave。
（1）PureMaster Slave
需要两个Broker，一个作为Master，另一个作为Slave，运行时，Slave通过网络实时从Master处复制数据，同时，如果Slave和Master失去连接，Slave就会自歼携动升级为Master，继续为客户端提供消息服务，如图所示：

实践时，我们使用两个ActiveMQ服务器，一个作为Master，Master不需要做特殊的配置；另一个作为Slave，配置${ACTIVEMQ_HOME}/conf/activemq.xml文件，在<broker>节点中添加连接到Master的URI和设置Master失效后不关闭Slave，如下：
<broker xmlns=" " brokerName="pure_slave"
masterConnectorURI="tcp://0.0.0.0:61616" shutdownOnMasterFailure="false" dataDirectory="${activemq.base}">
同时修改Slave的服务端口，如：
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61617"/>
</transportConnectors>

为了看到实践的效果，Master和Slave的消息持久化介质都是采用MySQL，并且Master和Slave分别连接不同的数据库。
在消息生产者应用和消息消费者应用的Spring配置文件中添加以下红色内容：
<property name="brokerURL" value="failover:(tcp://localhost:61616,tcp://localhost:61617)?initialReconnectDelay=100" />

配置完成后，我们可以通过以下步骤来进行测试：
A、启动Master和Slave，启动消息生产者应用，并分别发送一些Queue消息和Topic消息，如果此时订阅Topic消息的消费者设置了clientID，我们就可以在Master的数据库和Slave的数据库中看到尚未消费的消息，包括Queue和Topic的消息；
B、启动消费者应用，可以接收到消息；
C、关闭消费者，生产者继续发送一些消息A；
D、停止Master；
E、生产者继续发送消息B；
F、启动消费者应用，消费者可以接收到消息A和消息B，说明Slave接凯蔽替了Master的工作并复制了Master的消息。
这种方式只能两台机器做集群，可以起到很好的双机热备功能，但只能失效一次，只能停机恢复Master-Slave结构。
（2）SharedFile System Master Slave
SharedFile System Master Slave就是利用共享文件系统做ActiveMQ集群，是基于ActiveMQ的默认数据库kahaDB完成的，kahaDB的底层是文件系统。这种方式的集群，Slave的个数没有限制，哪个ActiveMQ实例先获取共享文件的锁，那个实例就是Master，其它的ActiveMQ实例就是Slave，当当前的Master失效，其它的Slave就会去竞争共享文件锁，谁竞争到了谁就是Master。这种模式的好处就是当Master失效时不用手动去配置，只要有足够多的Slave。Shared File System Master Slave模式如图所示：

本例子是在一台机器上运行氏孙伏三个ActiveMQ实例，需要对ActiveMQ的配置文件做一些简单的配置，就是把持久化适配器的存储目录改为本地磁盘的一个固定目录