配置过程
1. 节点准备
mkdir activemq创建目录
cp -rf apache-activemq-5.15.0 activemq/activemq-a
cp -rf apache-activemq-5.15.0 activemq/activemq-b
cp -rf apache-activemq-5.15.0 activemq/activemq-c
cd activemq
mkdir kahadb
2. 配置a节点
cd activemq-a/
cd conf/
vim activemq.xml
vim jetty.xml：配置管理端口号，a节点使用默认端口，无须配置
3. 配置b节点
vim activemq.xml
配置网络连接器
配置持久化存储路径
配置服务端口
vim jetty.xml
配置管理端口号
4. 配置c节点
vim activemq.xml
配置网络连接器
配置持久化存储路径
配置服务端口
vim jetty.xml
配置管理端口号
5.启动服务
回到activemq目录，分别启动a，b，c三个节点
./activemq-a/bin/activemq start
./activemq-b/bin/activemq start
./activemq-c /bin/activemq start
检查是否都启动成功
ps -ef |grep activemq
检查是否对外提供服务，即端口是否被监听（占用）
netstat -anp |grep 61616
netstat -anp |grep 61617
netstat -anp |grep 61618
检查发现61618即c节点没有提供服务，但是c节点的进程是启动成功了的。因为b节点和c点击是master/slave配置，现在b节点获取到了共享文件夹的所有权，所以c节点正在等待获得资源，并且提供服务。即c节点在未获得资源之前，是不提供服务的。
测试，把b节点杀掉，看c节点能不能提供61618的服务
./activemq-b/bin/activemq stop
netstat -anp |grep 61618
./activemq-b/bin/activemq start
netstat -anp |grep 61617
检查发现，重新启动b节点后，b节点61617端口并没有提供服务，是因为现在b节点成为了slave节点，而c节点成为了master节点。所以，现在b节点启动了，但是它并不对外提供服务。只有当c节点出现问题后，b节点才对外提供服务。
6.通过代码测试集群配置是否生效
生产者
packagecom.myimooc.jms.queue; importjavax.jms.Connection; importjavax.jms.ConnectionFactory; importjavax.jms.Destination; importjavax.jms.JMSException; importjavax.jms.MessageProducer; importjavax.jms.Session; importjavax.jms.TextMessage; importorg.apache.activemq.ActiveMQConnectionFactory; /*** App 生产者-队列模式-集群配置测试*/publicclassAppProducerTest { /** failover 为状态转移的存在部分* 因a节点只作为消费者使用，所以这里不配置61616节点了。* */privatestaticfinalStringURL="failover:(tcp://127.0.0.1:61617,tcp://127.0.0.1:61618)?randomize=true"; /** 指定队列的名称 */privatestaticfinalStringQUEUE_NAME="queue-test"; publicstaticvoidmain(String[] args) throwsJMSException { // 1.创建ConnectionFactoryConnectionFactoryconnectionFactory=newActiveMQConnectionFactory(URL); // 2.创建ConnectionConnectionconnection=connectionFactory.createConnection(); // 3.启动连接connection.start(); // 4.创建会话（第一个参数：是否在事务中处理）Sessionsession=connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // 5. 创建一个目标Destinationdestination=session.createQueue(QUEUE_NAME); // 6.创建一个生产者MessageProducerproducer=session.createProducer(destination); for (inti=0; i<100; i++) { // 7.创建消息TextMessagetextMessage=session.createTextMessage("test"+i); // 8.发布消息producer.send(textMessage); System.out.println("消息发送："+textMessage.getText()); } // 9.关闭连接connection.close(); } }
消费者
packagecom.myimooc.jms.queue; importjavax.jms.Connection; importjavax.jms.ConnectionFactory; importjavax.jms.Destination; importjavax.jms.JMSException; importjavax.jms.Message; importjavax.jms.MessageConsumer; importjavax.jms.MessageListener; importjavax.jms.Session; importjavax.jms.TextMessage; importorg.apache.activemq.ActiveMQConnectionFactory; /*** App 消费者-队列模式-集群配置测试*/publicclassAppConsumerTest { /** failover 为状态转移的存在部分* */privatestaticfinalStringURL="failover:(tcp://127.0.0.1:61616,tcp://127.0.0.1:61617,tcp://127.0.0.1:61618)?randomize=true"; /** 指定队列的名称 */privatestaticfinalStringQUEUE_NAME="queue-test"; publicstaticvoidmain(String[] args) throwsJMSException { // 1.创建ConnectionFactoryConnectionFactoryconnectionFactory=newActiveMQConnectionFactory(URL); // 2.创建ConnectionConnectionconnection=connectionFactory.createConnection(); // 3.启动连接connection.start(); // 4.创建会话（第一个参数：是否在事务中处理）Sessionsession=connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // 5.创建一个目标Destinationdestination=session.createQueue(QUEUE_NAME); // 6.创建一个消费者MessageConsumerconsumer=session.createConsumer(destination); // 7.创建一个监听器consumer.setMessageListener(newMessageListener() { publicvoidonMessage(Messagemessage) { TextMessagetextMessage= (TextMessage)message; try { System.out.println("接收消息："+textMessage.getText()); } catch (JMSExceptione) { System.out.println("接收消息异常："); e.printStackTrace(); } } }); // 8.关闭连接//connection.close(); } }
运行生产者，然后到管理界面查看消息发送到了那里
查看发现，8162无法访问，是因为b节点是slave节点，不提供服务，消息都发送到了c节点
把8163即c节点宕掉后，运行消费者，查看消息是否能够使用
./activemq-c/bin/activemq stop
