ActiveMQ 集群——JDBC Master Slave + Broker Cluster
ActiveMQ 集群是指将多个 ActiveMQ 服务器组合在一起，以提高系统的可扩展性和可靠性。在这个集群中，我们可以使用 JDBC Master Slave 模式和 Broker Cluster 模式来实现高可用性和负载均衡。
一、JDBC Master Slave 模式
JDBC Master Slave 模式是 Master-Slave 方式中的一种，它更加容易地进行分布式部署。这种模式下，所有的 ActiveMQ 实例都共享同一个数据库，以便实现数据的一致性。如果数据库失效，那么所有的 ActiveMQ 实例都将失效。
要配置 JDBC Master Slave 模式，我们需要在每个 ActiveMQ 实例的配置文件（activemq.xml）中添加数据源，这些数据源都指向同一个数据库。例如：
```xml
<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#mysql-ds" createTablesOnStartup="false" useDatabaseLock="true" />
</persistenceAdapter>
<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://192.168.1.1:3306/activemq?relaxAutoCommit=true"/>
<property name="username" value="admin"/>
<property name="password" value="admin"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
```
在上面的配置中，我们使用了 MySQL 数据库，并配置了数据源的连接信息。在第一次运行时，我们需要将 `createTablesOnStartup` 字段设置为 `true`，以便创建所需的表。下次再运行时，我们需要将其设置为 `false`，以防止创建多个表。
二、Broker Cluster 模式
Broker Cluster 模式是 ActiveMQ 集群中的另一种实现方式。在这个模式下，我们可以将多个 Broker 服务器组合在一起，以提高系统的可扩展性和可靠性。
要配置 Broker Cluster 模式，我们需要配置每个 Broker 服务器的网络桥接，以便它们之间可以相互通信。例如，我们可以使用以下配置：
```xml
<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
```
在上面的配置中，我们配置了一个名为 `openwire` 的 Transport Connector，它监听在 61616 端口上，以便接受来自生产者的连接请求。
在 Broker Cluster 模式下，我们可以使用 Hub-and-Spoke 架构来实现消息的路由。例如，我们可以将生产者连接到 Hub 服务器，然后将 Hub 服务器连接到多个 Broker 服务器，以便将消息路由到不同的 Broker 服务器上。
```markdown
生产者(Producer)连接到 hub1/hub2
消费者连接到 broker1/broker2/broker3
```
如果我们需要扩展集群，我们可以增加新的 Broker 服务器，然后将其连接到 Hub 服务器上，以便实现消息的路由。
```markdown
如果以后要扩张，比如增加了 Broker4,Broker5...
直接修改 hub1/2 上的配置，增加与新的 broker 的连接即可，不影响消息的路由途径长度。
```
ActiveMQ 集群可以使用 JDBC Master Slave 模式和 Broker Cluster 模式来实现高可用性和负载均衡。在配置这些模式时，我们需要注意数据的一致性和网络桥接的配置，以便确保集群的稳定运行。
