### ActiveMQ JDBC 集群总结
#### 一、ActiveMQ版本及环境信息
- **ActiveMQ 版本**：5.9.0
- **安装环境**：JDK 1.6，Linux 操作系统，MySQL 5.6
- **服务器信息**：
- 服务器1：IP地址 192.168.1.188
- 服务器2：IP地址 192.168.1.189
- 服务器3：IP地址 192.168.1.190
#### 二、ActiveMQ JDBC 集群简介
##### JDBCMasterSlave 模式
JDBCMasterSlave 是一种利用数据库系统来实现ActiveMQ集群的方式。该模式允许多个ActiveMQ实例通过竞争数据库锁的方式来确定主节点（Master）与从节点（Slave）。具体来说：
- 当一个ActiveMQ实例首先获取到数据库中的共享锁时，它就成为主节点（Master）。
- 其他未能获取锁的ActiveMQ实例则成为从节点（Slave）。
- 如果当前的主节点出现故障，其他的从节点将尝试获取锁，成功获取锁的从节点将晋升为主节点。
这种模式的优点在于当主节点失效时，能够自动完成主备切换，无需手动配置，同时理论上可以从节点数量不受限制。
#### 三、JDBC 集群配置信息
为了实现ActiveMQ的JDBCMasterSlave集群，需要对各个ActiveMQ实例进行相应的配置。具体步骤如下：
##### 1. 添加数据源配置
在所有ActiveMQ实例的主配置文件（通常位于 `${ACTIVEMQ_HOME}/conf/activemq.xml` ）中添加数据源配置，确保所有的数据源都指向同一个数据库。
示例配置代码如下：
```xml
<broker xmlns="http://activemq.apache.org/schema/core">
<!-- 数据源配置 -->
<persistenceAdapter>
<jdbcPersistenceAdapter dataSource="#ds"/>
</persistenceAdapter>
<!-- 数据源定义 -->
<bean id="ds" class="org.apache.commons.dbcp.BasicDataSource" lookup="false">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://your-db-host:3306/yourdb"/>
<property name="username" value="your-user"/>
<property name="password" value="your-password"/>
</bean>
</broker>
```
其中，`dataSource="#ds"` 表示引用上面定义的数据源 `ds`。
##### 2. 修改持久化适配器配置
还需要修改持久化适配器的相关配置，确保集群能够正确工作。
示例配置代码如下：
```xml
<persistenceAdapter>
<jdbcPersistenceAdapter dataSource="#ds" createTablesOnStartup="true" useDatabaseLock="true"/>
</persistenceAdapter>
```
- `createTablesOnStartup="true"`：设置为 `true` 表示启动时自动创建数据库表。建议仅在首次启动时设置为 `true`，之后应改为 `false`，以避免重复创建表。
- `useDatabaseLock="true"`：必须设置为 `true`，用于在保存数据时锁定数据库资源，防止出现主键冲突等异常情况。
##### 3. 修改 TCP 端口号
为了避免端口冲突，每个ActiveMQ实例的TCP端口号需要设置为不同的值。默认情况下，端口号为61616。可以在配置文件中修改该值。
示例配置代码如下：
```xml
<transportConnectors>
<transportConnector name="openwire" uri="tcp://localhost:61617?maximumConnections=1000"/>
</transportConnectors>
```
这里将端口号修改为61617。
#### 四、程序调用示例
程序调用ActiveMQ集群时，通常需要指定集群中某个节点作为连接点。以下是一个简单的Java程序调用示例：
```java
import org.apache.activemq.ActiveMQConnectionFactory;
public class Consumer {
public static void main(String[] args) throws Exception {
// 创建连接工厂
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.1.188:61617");
// 创建连接
Connection connection = connectionFactory.createConnection();
// 启动连接
connection.start();
// 创建会话
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建目的地（队列）
Destination destination = session.createQueue("MyQueue");
// 创建消息消费者
MessageConsumer consumer = session.createConsumer(destination);
// 接收消息
TextMessage message = (TextMessage) consumer.receive();
System.out.println("Received message: " + message.getText());
// 关闭资源
consumer.close();
session.close();
connection.close();
}
}
```
此示例展示了如何创建一个连接到ActiveMQ集群的消息消费者，并接收消息。
通过以上步骤，可以实现一个基本的ActiveMQ JDBC集群，并且通过示例程序验证其功能。需要注意的是，在实际部署过程中可能还会遇到各种问题，比如网络配置、权限管理等，都需要根据实际情况进行调整。
