一、先安装Zookeeper 的eclipse插件吧。

1. 打开 eclipse， Help -》 Install New Software，点击Add，添加地址： http://www.massedynamic.org/eclipse/updates/

2. 点击OK，勾选Zookeeper插件，另外两个貌似没用

3. 安装完之后，点击Window-》Show View-》Other，选择安装的Zookeeper插件

4. 出现Zookeeper控制台后，点击右上角的按钮，增加Zookeeper节点。

出现界面

点击Add

添加你的Zookeeper IP，Finish

5. 查看集群信息。

如果你的Zookeeper+ActiveMQ开启的话，会出现

二、代码

一个简单的生产者：

package mq.cluster;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Sender {        public static void main(String[] args) throws Exception {                //1. 建立一个ConnectionFactory. 默认tcp://0.0.0.0:61616        String userName = ActiveMQConnectionFactory.DEFAULT_USER;        String password = ActiveMQConnectionFactory.DEFAULT_PASSWORD;        String brokerURL = "failover:(tcp://192.168.127.129:61616,tcp://192.168.127.130:61616,tcp://192.168.127.131:61616)?Randomize=false";        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName, password, brokerURL);                //2. 通过ConnectionFactory建立一个Connection连接，并且调用start方法开启        Connection connection = connectionFactory.createConnection();        connection.start();                //3. 通过Connection创建Session，用于接收消息[第一个参数：是否启用事务；第二个参数：设置签收模式]//        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);//手工签收--常用                //4. 通过Session创建Destination对象        Destination destination = session.createQueue("foodQueue");                //5. 通过Session创建发送或接受对象        MessageProducer messageProducer = session.createProducer(null);                //7. 使用JMS规范里面消息类型之一 TextMessage 来创建数据，用MessageProducer来发送        for (int i = 1; i < 500; i++) {            TextMessage message = session.createTextMessage();            message.setText("大萝卜" + i);            //参数：目标，消息，传递数据的模式，优先级，消息的过期时间            messageProducer.send(destination, message, DeliveryMode.NON_PERSISTENT, 0, 1000*60);            //System.out.println("生产者：" + message.getText());            Thread.sleep(1000);        }                //使用事务要手动提交        //session.commit();                //8. 关闭连接        connection.close();            }// main}

因为是集群，所以brokerUrl要与众不同，

String brokerURL = "failover:(tcp://192.168.127.129:61616,tcp://192.168.127.130:61616,tcp://192.168.127.131:61616)?Randomize=false";

一个简单的消费者：

package mq.cluster;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.Destination;import javax.jms.MessageConsumer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Receiver {public static void main(String[] args) throws Exception {                //1. 建立一个ConnectionFactory. tcp://0.0.0.0:61616        String userName = ActiveMQConnectionFactory.DEFAULT_USER;        String password = ActiveMQConnectionFactory.DEFAULT_PASSWORD;        String brokerURL = "failover:(tcp://192.168.127.129:61616,tcp://192.168.127.130:61616,tcp://192.168.127.131:61616)?Randomize=false";        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName, password, brokerURL);                //2. 通过ConnectionFactory建立一个Connection连接，并且调用start方法开启        Connection connection = connectionFactory.createConnection();        connection.start();                //3. 通过Connection创建Session，用于接收消息[第一个参数：是否启用事务；第二个参数：设置签收模式]        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);                //4. 通过Session创建Destination对象        Destination destination = session.createQueue("foodQueue");                //5. 通过Session创建发送或接受对象        MessageConsumer messageConsumer = session.createConsumer(destination);                //7. 使用JMS规范里面消息类型之一 TextMessage 来创建数据        while (true) {            TextMessage message = (TextMessage) messageConsumer.receive();            if(message == null) break;            System.out.println("消费者：" + message.getText());        }                //8. 关闭连接        connection.close();            }// main}

先开启消费者，让它先阻塞，准备吃饭。然后开启生产者：