ActiveMQ(2) ActiveMQ创建HelloWorld

启动ActiveMQ：

 请参见：ActiveMQ(1) 初识ActiveMQ

创建Maven工程:

pom文件:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <groupId>com.itdoc.learn</groupId>
  <artifactId>activemq</artifactId>
  <version>1.0-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>activemq</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-all</artifactId>
      <version>5.15.2</version>
    </dependency>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
  </dependencies>
</project>

创建消息生产者:

/**
 * @filename Sender.Java
 * @desc 消息生产者
 * @blog http://www.cnblogs.com/goodcheap
 * @author Chinda Wang
 * @create 2017-12-02 16:06
 * @version v1.0
 * @copyright Copyright © 2017 达华信息科技有限公司 版权所有
 * @modifyhistory 2017-12-02 16:06
 * @modifyauthor Chinda Wang
 * @modifydesc
 */
package com.itdoc.learn.activemq.helloworld;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * @author Chinda Wang
 * @desc 消息生产者
 * @create 2017-12-02 16:06
 */
public class Sender {

    public static void main(String[] args) throws Exception {
        // 第一步: 建立 ConnectionFactory 工厂对象, 需要填入用户名、密码、以及要连接的地址, 均使用默认即可, 默认端口为"tcp//loclhost:61616"
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                ActiveMQConnectionFactory.DEFAULT_USER,
                ActiveMQConnectionFactory.DEFAULT_PASSWORD,
                "tcp://localhost:61616");
        // 第二步: 通过ConnectionFactory工厂对象创建一个Connection连接, 并且调用Connection的start方法开启连接, Connection默认是关闭的。
        Connection connection = connectionFactory.createConnection();
        connection.start();
        /*
         * 第三步: 通过Connection对象创建Session会话(上下文环境对象), 用于接收消息, 参数位置1为是否启用事务, 参数位置2为签收模式,
         * 一般设置为自动签收。
         */
        Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
        /*
         * 第四步: 通过Session创建Destination对象, 指的是一个客户端用来指定生产消息目标和消费消息来源的对象, 在PTP模式中, Destination
         * 被称作为Queue, 即队列; 在Pub/Sub模式, Destination被称作Topic, 即主题。在程序中可以使用多个Queue和Topic。
         */
        Destination destination = session.createQueue("queue1");
        // 第五步: 需要通过Session对象创建消息的发送和接收对象(生产者和消费者)MessageProducer/MessageConsumer
        MessageProducer producer = session.createProducer(destination);
        // 第六步: 可以使用MessageProducer的setDeliveryMode()方法为其设置持久化特性和非持久化特性(DeliveryMode)。
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        /*
         * 第七步: 使用JMS规范的TextMessage形式创建数据(通过Session对象), 并用MessageProducer的send()方法发送数据。同理, 客户端使用
         * receive()方法进行接收数据。
         */
        TextMessage textMessage = session.createTextMessage();
        for (int i = 1; i <= 10; i++) {
            textMessage.setText("I am Message! id: " + i);
            producer.send(textMessage);
            System.out.println("生产者: " + textMessage.getText());
        }
        // 第八步: 关闭Connection连接
        if (connection != null) {
            connection.close();
        }
    }
}

 创建消息消费者:

/**
 * @filename Receiver.Java
 * @desc 消息消费者
 * @blog http://www.cnblogs.com/goodcheap
 * @author Chinda Wang
 * @create 2017-12-02 16:07
 * @version v1.0
 * @copyright Copyright © 2017 达华信息科技有限公司 版权所有
 * @modifyhistory 2017-12-02 16:07
 * @modifyauthor Chinda Wang
 * @modifydesc
 */
package com.itdoc.learn.activemq.helloworld;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * @desc 消息消费者
 * @author Chinda Wang
 * @create 2017-12-02 16:07
 */
public class Receiver {

    public static void main(String[] args) throws Exception {
        // 第一步: 建立 ConnectionFactory 工厂对象, 需要填入用户名、密码、以及要连接的地址, 均使用默认即可, 默认端口为"tcp//loclhost:61616"
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                ActiveMQConnectionFactory.DEFAULT_USER,
                ActiveMQConnectionFactory.DEFAULT_PASSWORD,
                "tcp://localhost:61616");
        // 第二步: 通过ConnectionFactory工厂对象创建一个Connection连接, 并且调用Connection的start方法开启连接, Connection默认是关闭的。
        Connection connection = connectionFactory.createConnection();
        connection.start();
        /*
         * 第三步: 通过Connection对象创建Session会话(上下文环境对象), 用于接收消息, 参数位置1为是否启用事务, 参数位置2为签收模式,
         * 一般设置为自动签收。
         */
        Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
        /*
         * 第四步: 通过Session创建Destination对象, 指的是一个客户端用来指定生产消息目标和消费消息来源的对象, 在PTP模式中, Destination
         * 被称作为Queue, 即队列; 在Pub/Sub模式, Destination被称作Topic, 即主题。在程序中可以使用多个Queue和Topic。
         */
        Destination destination = session.createQueue("queue1");
        // 第五步: 需要通过Session对象创建消息的发送和接收对象(生产者和消费者)MessageProducer/MessageConsumer
        MessageConsumer consumer = session.createConsumer(destination);
        /*
         * 第六步: 使用JMS规范的TextMessage形式创建数据(通过Session对象), 并用MessageProducer的send()方法发送数据。同理, 客户端使用
         * receive()方法进行接收数据。
         */
        while (true) {
            TextMessage msg = (TextMessage) consumer.receive();
            if (msg == null) {
                break;
            }
            System.out.println("收到内容: " + msg.getText());
        }
        // 第七步: 关闭Connection连接
        if (connection != null) {
            connection.close();
        }
    }
}

运行消息生产者，控制台输出：

ActiveMQ消息页：

消息生产者创建了一个名称为 queue1的消息队列, 队列中有10条消息待消费, 通过Browse查询消息详情。 

 

这些队列中的消息被删除, 消息消费者则无法消费此消息。

运行消息消费者, 控制台输出：

 

 消息页：