ActiveMQ的安装和使用

.....
<activemq.version>5.13.0</activemq.version>
<spring.version>4.2.4.RELEASE</spring.version>
.....
<dependency>
       <groupId>org.apache.activemq</groupId>
       <artifactId>activemq-all</artifactId>
       <version>${activemq.version}</version>
       </dependency>
<dependency>
       <groupId>org.springframework</groupId>
       <artifactId>spring-jms</artifactId>
       <version>${spring.version}</version>
</dependency>
<dependency>
       <groupId>org.springframework</groupId>
       <artifactId>spring-context-support</artifactId>
       <version>${spring.version}</version>
</dependency>
......

public class Producer {

    @Test
    public void testQueueProduce() throws JMSException {
        // 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。
        //brokerURL服务器的ip及端口号
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.1.124:61616");
        // 第二步：使用ConnectionFactory对象创建一个Connection对象。
        Connection connection = connectionFactory.createConnection();
        // 第三步：开启连接，调用Connection对象的start方法。
        connection.start();
        // 第四步：使用Connection对象创建一个Session对象。
        //第一个参数：是否开启事务。true：开启事务，第二个参数忽略。
        //第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。
        //参数：队列的名称。
        Queue queue = session.createQueue("queue-test");
        // 第六步：使用Session对象创建一个Producer对象。
        MessageProducer producer = session.createProducer(queue);
        // 第七步：创建一个Message对象，创建一个TextMessage对象
        TextMessage textMessage = session.createTextMessage("this is my first mq message");
        // 第八步：使用Producer对象发送消息。
        producer.send(textMessage);
        //第九步：关闭资源
        producer.close();
        session.close();
        connection.close();
    }
}

public class Consumer {

    @Test
    public void testQueueConsumer() throws JMSException, InterruptedException {
        //1.建立连接
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.1.124:61616");
        //2.获取连接
        Connection connection = connectionFactory.createConnection();
        //3.开启连接
        connection.start();
        //4.根据连接对象创建session
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5.根据session创建Destination(目的地，Queue,Topic)
        Queue queue = session.createQueue("queue-test");
        //6.创建消费者
        MessageConsumer consumer = session.createConsumer(queue);
        //7.接收消息
        System.out.println("start");
        consumer.setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                if(message instanceof TextMessage) {
                    TextMessage message1 = (TextMessage) message;
                    try{
                        String text = message1.getText();
                        System.out.println("获取的消息为："+text);
                    }catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }
        });
        System.out.println("end");
        Thread.sleep(10000);
        //8.关闭资源
        consumer.close();
        session.close();
        connection.close();
    }
}

@Test
    public void testTopicProducer() throws JMSException {
        // 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。
        //brokerURL服务器的ip及端口号
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.1.124:61616");
        // 第二步：使用ConnectionFactory对象创建一个Connection对象。
        Connection connection = connectionFactory.createConnection();
        // 第三步：开启连接，调用Connection对象的start方法。
        connection.start();
        // 第四步：使用Connection对象创建一个Session对象。
        //第一个参数：是否开启事务。true：开启事务，第二个参数忽略。
        //第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。
        //参数：队列的名称。
        Topic topic = session.createTopic("topic-test");
        // 第六步：使用Session对象创建一个Producer对象。
        MessageProducer producer = session.createProducer(topic);
        // 第七步：创建一个Message对象，创建一个TextMessage对象
//        TextMessage textMessage = session.createTextMessage("this is my first topic message");
        TextMessage message = new ActiveMQTextMessage();
        message.setText("my first topic message");
        // 第八步：使用Producer对象发送消息。
        producer.send(message);
        //第九步：关闭资源
        producer.close();
        session.close();
        connection.close();
    }

@Test
    public void testTopicProducer() throws JMSException {
        // 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。
        //brokerURL服务器的ip及端口号
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.1.124:61616");
        // 第二步：使用ConnectionFactory对象创建一个Connection对象。
        Connection connection = connectionFactory.createConnection();
        // 第三步：开启连接，调用Connection对象的start方法。
        connection.start();
        // 第四步：使用Connection对象创建一个Session对象。
        //第一个参数：是否开启事务。true：开启事务，第二个参数忽略。
        //第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。
        //参数：队列的名称。
        Topic topic = session.createTopic("topic-test");
        // 第六步：使用Session对象创建一个Producer对象。
        MessageProducer producer = session.createProducer(topic);
        // 第七步：创建一个Message对象，创建一个TextMessage对象
//        TextMessage textMessage = session.createTextMessage("this is my first topic message");
        TextMessage message = new ActiveMQTextMessage();
        message.setText("my first topic message");
        // 第八步：使用Producer对象发送消息。
        producer.send(message);
        //第九步：关闭资源
        producer.close();
        session.close();
        connection.close();
    }