| Web管理控制台 | 消息服务接口 | 集群通讯接口 | |
| mq1 | 8161 | 51511 | 61601 |
| mq2 | 8162 | 51512 | 61602 |
| mq3 | 8163 | 51513 | 61603 |
服务接口没有使用默认的61611是因为activemq默认还会使用61613,61614等端口，如何开放端口及配置控制台端口请自行百度
|
1
|
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="V1MQ" dataDirectory="${activemq.data}">
|
2、配置levelDB，加载<broker>节点内
bind：集群间通讯的ip和端口
zkAddress：ZooKeeper地址，多个可用，逗号分隔
hostname：主机名，可在/etc/hosts中进行配置
zkPath：zkPath目录，可在ZooInspetor中进行查看
|
1
2
3
4
5
6
7
8
9
10
11
|
<persistenceAdapter>
<!-- kahaDB directory="${activemq.data}/kahadb"/ -->
<replicatedLevelDB
directory="${activemq.data}/leveldb"
replicas="3"
zkAddress="192.168.146.130:2181"
hostname="V1"
zkPath="/activemq/leveldb-stores"
/>
</persistenceAdapter>
|
4、启动activemq
/usr/local/src/activemq1/bin/activemq start
可通过/usr/local/src/activemq1/data/activemq.log查看启动日志
5、关于管控台
虽然3个activemq都启动了，但是同一时间只有Master对应的管控台可用，Slaver对应的管控台不可用
四、结合ZooInspector测试（推荐使用dubbokeeper中查看zookeeper的一个UI插件，https://github.com/dubboclub/dubbokeeper）
1、打开ZooInspector（可自行搜索下载或从群中下载），输入ZooKeeper地址进行监控，如果3个activemq都启动成功，则显示如下：
2、Java测试代码
代码可参考：http://www.cnblogs.com/gossip/p/5970090.html
a) 配置集群IP（这里3个activemq的端口分别是51511,51512,51513）
|
1
2
3
4
5
6
7
8
|
<!-- 配置JMS连接工厂 --><bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="failover:(tcp://192.168.146.129:51511,tcp://192.168.146.129:51512,tcp://192.168.146.129:51513)" />
<!--解决接收消息抛出异常：javax.jms.JMSException: Failed to build body from content. Serializable class not available to broke-->
<property name="trustAllPackages" value="true"/>
<!-- 是否异步发送 -->
<property name="useAsyncSend" value="true" />
</bean>
|
b) 测试代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
@Test public void produceMsg_DefaultQueue() {
for (int i = 0; i < 10000; i++) {
final String msg ="序号："+String.valueOf(i) + " " +"这里是向默认队列发送的消息" + new Date().toString();
System.out.println(msg);
String destination = jmsTemplate.getDefaultDestination().toString();
jmsTemplate.send(new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage(msg);
}
});
try {
Thread.sleep(300);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
|
3、启动Java程序并发送消息
4、关闭Master队列（注意此时的Master队列为mq2）
a) 此时的ZooInspetor
5、重启mq2队列（重启后mq2加入队列成为Slaver，但是mq1还是Master，队列不受影响）
6、关闭mq1、mq2，仅剩mq3（由于只有一个队列，无法进行选举，所以整个队列都无法提供服务）
7、重启mq1（重启mq1后，mq1和mq3选举了Master队列，从而重新对外提供服务）
a) ZooInspecto显示mq1被选举为Master
b) 程序重新向队列消息，数据并没有中断
五、总结
本文演示了activemq伪集群的搭建过程及高可用的测试过程，通过举一反三可以将activemq部署到不同的机器上，从而实现相同的功能。
遗留问题：ZooInspetor的activemq编号是自动生成的，很难发现其对应的队列，请问有没有可以自定义编号的方法，谢谢。