<!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-all -->
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.11.1</version>
</dependency>

/**
 * ActiveMQ中的生产者(Producer)
 * @author dengp
 *
 */
public class HelloProducer {
  public void sendhello2ActiveMq(String messageText) {
    // 连接工厂，用于创建Connection对象
    ConnectionFactory factory = null;
    // activeMQ 连接对象
    Connection conn = null;
    // 一次和ActiveMQ的持久会话对象
    Session session = null;
    // 目的地
    Destination destination = null;
    // 消息发送者
    MessageProducer producer = null;
    // 封装消息的对象
    Message message = null;
    try {
      /*
       * 创建链接工厂 ActiveMQConnectionFactory -由ActiveMQ实现的ConnectionFactory接口实现类. 
       * 构造方法: public ActiveMQConnectionFactory(String userName, String password,
       * String brokerURL) 
       * userName - 访问ActiveMQ服务的用户名,用户名可以通过jetty-realm.properties配置文件配置. 
       * password - 访问ActiveMQ服务的密码,密码可以通过jetty-realm.properties配置文件配置. 
       * brokerURL -访问ActiveMQ服务的路径地址. 路径结构为 - 协议名://主机地址:端口号 此链接基于TCP/IP协议.
       */
      factory = new ActiveMQConnectionFactory("admin", "admin", "tcp://192.168.88.121:61616");
      // 创建链接对象
      conn = factory.createConnection();
      // 启动连接对象
      conn.start();
      /*
       * 创建会话对象 
       * 方法 - connection.createSession(boolean transacted, int acknowledgeMode); 
       * transacted - 是否使用事务, 
       * 可选值为true|false 
       * true - 使用事务, 当设置此变量值, 则acknowledgeMode参数无效, 
       * 建议传递的acknowledgeMode参数值为 Session.SESSION_TRANSACTED 
       * false - 不使用事务, 设置此变量值,则acknowledgeMode参数必须设置. 
       * acknowledgeMode - 消息确认机制, 可选值为:
       * Session.AUTO_ACKNOWLEDGE - 自动确认消息机制 
       * Session.CLIENT_ACKNOWLEDGE -客户端确认消息机制 
       * Session.DUPS_OK_ACKNOWLEDGE - 有副本的客户端确认消息机制
       */
      session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      // 创建目的地，目的地的命名既是队列的命令
      destination = session.createQueue("MQ-Hello");
      // 创建消息生成者, 创建的消息生成者与某目的地对应, 即方法参数目的地.
      producer = session.createProducer(destination);
      // 创建消息对象，创建一个文本消息对象。此消息对象中保存要传递的文本数据.
      message = session.createTextMessage(messageText);
      // 发送消息
      producer.send(message);
    } catch (Exception e) {
      e.printStackTrace();
      System.out.println("访问ActiveMQ服务发生错误!!");
    } finally {
      try {
        // 回收消息发送者资源
        if (null != producer)
          producer.close();
      } catch (JMSException e) {
        e.printStackTrace();
      }
      try {
        // 回收会话资源
        if (null != session)
          session.close();
      } catch (JMSException e) {
        e.printStackTrace();
      }
      try {
        // 回收链接资源
        if (null != conn)
          conn.close();
      } catch (JMSException e) {
        e.printStackTrace();
      }
    }
  }
}

/**
 * ActiveMQ中的消费者(Consumer)
 * @author dengp
 *
 */
public class HelloConsumer {
  public void reciveHelloFormActiveMq() {
    // 连接工厂，用于创建Connection对象
    ConnectionFactory factory = null;
    // activeMQ 连接对象
    Connection conn = null;
    // 一次和ActiveMQ的持久会话对象
    Session session = null;
    // 目的地
    Destination destination = null;
    // 消息消费者
    MessageConsumer consumer = null;
    // 封装消息的对象
    Message message = null;
    try {
      /*
       * 创建链接工厂 ActiveMQConnectionFactory -由ActiveMQ实现的ConnectionFactory接口实现类. 
       * 构造方法: public ActiveMQConnectionFactory(String userName, String password,
       * String brokerURL) 
       * userName - 访问ActiveMQ服务的用户名,用户名可以通过jetty-realm.properties配置文件配置. 
       * password - 访问ActiveMQ服务的密码,密码可以通过jetty-realm.properties配置文件配置. 
       * brokerURL -访问ActiveMQ服务的路径地址. 路径结构为 - 协议名://主机地址:端口号 此链接基于TCP/IP协议.
       */
      factory = new ActiveMQConnectionFactory("admin", "admin", "tcp://192.168.88.121:61616");
      // 创建链接对象
      conn = factory.createConnection();
      // 启动连接对象
      conn.start();
      /*
       * 创建会话对象 
       * 方法 - connection.createSession(boolean transacted, int acknowledgeMode); 
       * transacted - 是否使用事务, 
       * 可选值为true|false 
       * true - 使用事务, 当设置此变量值, 则acknowledgeMode参数无效, 
       * 建议传递的acknowledgeMode参数值为 Session.SESSION_TRANSACTED 
       * false - 不使用事务, 设置此变量值,则acknowledgeMode参数必须设置. 
       * acknowledgeMode - 消息确认机制, 可选值为:
       * Session.AUTO_ACKNOWLEDGE - 自动确认消息机制 
       * Session.CLIENT_ACKNOWLEDGE -客户端确认消息机制 
       * Session.DUPS_OK_ACKNOWLEDGE - 有副本的客户端确认消息机制
       */
      session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      // 创建目的地，目的地的命名既是队列的命令
      destination = session.createQueue("MQ-Hello");
      // 创建消息消费者, 创建的消息消费者与某目的地对应, 即方法参数目的地.
      consumer = session.createConsumer(destination);
      // 从ActiveMQ中获取消息
      message = consumer.receive();
      String textMessage = ((TextMessage)message).getText();
      System.out.println("ActiveMQ获取的消息是:"+textMessage);
    } catch (Exception e) {
      e.printStackTrace();
      System.out.println("访问ActiveMQ服务发生错误!!");
    } finally {
      try {
        // 回收消息发送者资源
        if (null != consumer)
          consumer.close();
      } catch (JMSException e) {
        e.printStackTrace();
      }
      try {
        // 回收会话资源
        if (null != session)
          session.close();
      } catch (JMSException e) {
        e.printStackTrace();
      }
      try {
        // 回收链接资源
        if (null != conn)
          conn.close();
      } catch (JMSException e) {
        e.printStackTrace();
      }
    }
  }
}

public static void main(String[] args) {
  HelloProducer pro = new HelloProducer();
  pro.sendhello2ActiveMq("你好啊...");
}

public static void main(String[] args) {
  HelloConsumer con = new HelloConsumer();
  con.reciveHelloFormActiveMq();
}