本文以开源 Apache RocketMQ Client 为例，提供操作示例帮助您从零开始搭建阿里云 RocketMQ 收发消息的测试工程。Demo 工程包含普通消息、顺序消息、事务消息的测试代码。

前提条件

  • 安装 IDE。

    您可以使用 IntelliJ IDEA 或者 Eclipse，本文以 IntelliJ IDEA 为例。

    在 https://www.jetbrains.com/idea/ 下载 IntelliJ IDEA Ultimate 版本，并参考 IntelliJ IDEA 说明进行安装。

  • 下载 Demo 工程。

    在 https://github.com/AliwareMQ/mq-demo 下载 Demo 工程到本地，然后解压即可看到本地新增了 mq-demo 文件夹。

  • 下载安装 JDK。

配置 Demo 工程

  1. 将 Demo 工程文件导入 IntelliJ IDEA。
    1. 在 IntelliJ IDEA 界面，选择 Import Project，选择 mq-demo/rocketmq/java-rocketmq-demo 文件夹。
    2. 选择 Import 类型为 Maven。
    3. 默认单击 Next，直到导入完成。Demo 工程需要加载依赖的 JAR 包，因此导入过程需要等待 2-3 分钟。
  2. 创建资源。

    您需要先到控制台创建所需资源，包括阿里云 RocketMQ 的实例、Topic、Group ID（GID），以及鉴权需要的 AccessKey（AK）。

    更多详细信息和操作指导，请参见步骤二：创建资源。

  3. 配置 Demo。
    您需将在步骤 2 中创建好的资源信息配置到文件：MqConfig 类。 
    public static final String TOPIC = "刚才创建的 Topic";
public static final String GROUP_ID = "刚才创建的 Group ID";
public static final String ACCESS_KEY = "您的阿里云账号的 AccessKeyId";
public static final String SECRET_KEY = "您的阿里云账号 AccessKeySecret";
public static final String NAMESRV_ADDR = "您的阿里云 RocketMQ 实
例的 TCP 接入点，在控制台实例详情页面的获取接入点信息区域获取";
    说明
    • 创建 AccessKey（包括 AccessKeyId 和 AccessKeySecret）的具体步骤，请参见创建AccessKey。
    • 如果 RAM 子账号拥有该 Topic 的权限以及自己的 AccessKey，那么也可以使用 RAM 子账号的 AccessKey。

以 Main 方式运行 Demo

  1. 发送消息。
    • 发送普通消息：运行 RocketMQProducer 类。
    • 发送事务消息：运行 RocketMQTransactionProducer 类。

      LocalTransactionCheckerImpl 类为本地事务 Check 接口类，用于校验事务。详情请参见收发事务消息。

    • 发送顺序消息：运行 RocketMQOrderProducer 类。

      注意创建的 Topic 应该为顺序消息的 Topic。详情请参见收发顺序消息。

  2. 接收消息
    • 接收普通消息：运行 RocketMQConsumer 类。
    • 接收事务消息：运行 RocketMQConsumer 类。
    • 接收顺序消息：运行 RocketMQOrderConsumer 类。
    可以看到消息被接收打印的日志。因为有初始化，所以需等待几秒，在生产环境中不会经常初始化。
    从消息队列 RocketMQ 版控制台进入 Group 管理 > 消费者状态，可以看到启动的消费端已经在线，并且订阅关系一致。

更多信息