朋也的博客 » 首页 » 文章

ActiveMQ学习-HelloWorld (1)

作者：朋也
日期：2018-11-05
类别：ActiveMQ学习笔记 

版权声明：自由转载-非商用-非衍生-保持署名（创意共享3.0许可证）

安装ActiveMQ

ActiveMQ官网 下载ActiveMQ

解压，进入 bin 运行

cd [activemq_install_dir]/bin
./activemq console

我用的是MAC，还可以使用homebrew安装, 我这里用的是 5.15.7 版本

brew install apache-activemq
# 启动
activemq console

windows 平台可以到 http://activemq.apache.org/ 官网下载, 解压后, 运行 bin/win64/activemq.bat(如果是32位系统则运行 /bin/win32/activemq.bat文件) 文件即可

浏览器访问 http://localhost:8161/admin/ 用户名密码都是 admin

Java程序调用

Java调用分以下几步(提供者，消费者都一样)

  1. 创建连接工厂
  2. 从工厂里拿一个连接
  3. 从连接中获取Session(会话)
  4. 从会话中获取目的地(Destination)消费者会从这个目的地取消息
  5. 从会话中创建消息提供者
  6. 从会话中创建文本消息(也可以创建其它类型的消息体)
  7. 通过消息提供者发送消息到ActiveMQ
  8. 关闭连接

新建Maven项目，引入 ActiveMQ 依赖

<dependency>
  <groupId>org.apache.activemq</groupId>
  <artifactId>activemq-core</artifactId>
  <version>5.7.0</version>
</dependency>

消息提供者 Producer

public class Producer {

  public static void main(String[] args) throws JMSException {
    // ActiveMQConnectionFactory.DEFAULT_USER 与 ActiveMQConnectionFactory.DEFAULT_PASSWORD 是连接AMQ的默认用户名与密码，可以在AMQ的配置文件里修改
    // 地址连接使用 tcp 端口是61616
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
        ActiveMQConnectionFactory.DEFAULT_USER,
        ActiveMQConnectionFactory.DEFAULT_PASSWORD,
        "tcp://localhost:61616"
    );

    Connection connection = connectionFactory.createConnection();
    connection.start();

    // 如果session不支持事件，就是FALSE，支持事务就是true，如果开启事务要在关闭连接之前 commit() 一下，否则消息不会进入到 AMQ
    // AUTO_ACKNOWLEDGE 表示自动消费，除此还有手动消费
    Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
    Destination destination = session.createQueue("amq-demo");

    MessageProducer producer = session.createProducer(null);

    for (int i = 0; i < 100; i++) {
      TextMessage msg = session.createTextMessage("提供消息" + i);
      producer.send(destination, msg);
    }

    connection.close();
  }
}

消息消费者 Consumer

public class Consumer {

  public static void main(String[] args) throws JMSException {
    // 跟Producer一样创建连接工厂
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
        ActiveMQConnectionFactory.DEFAULT_USER,
        ActiveMQConnectionFactory.DEFAULT_PASSWORD,
        "tcp://localhost:61616"
    );

    Connection connection = connectionFactory.createConnection();
    connection.start();

    Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

    Destination destination = session.createQueue("amq-demo");
    MessageConsumer consumer = session.createConsumer(destination);

    while(true) {
      // receive() 方法当没有消息的时候会阻塞在这，等待提供者提供消息，后面介绍使用监听来获取消息
      TextMessage msg = (TextMessage) consumer.receive();
      System.out.println("消费消息：" + msg.getText());
    }
  }
}

相关文章