Demo工程

配置Demo工程

1. 将Demo工程文件导入IntelliJ IDEA。
2. 创建资源。

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

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

3. 配置Demo。
   您需将在步骤2中创建好的资源信息配置到2个文件：MqConfig类和common.xml。
   1. 按以下说明配置MqConfig类。

      public static final String TOPIC = "您刚创建的Topic";
      public static final String GROUP_ID = "您刚创建的Group ID";
      public static final String ORDER_TOPIC = "您刚创建的用于收发顺序消息的Topic";
      public static final String ORDER_GROUP_ID = "您刚创建的用于收发顺序消息的Group ID";
      public static final String ACCESS_KEY = "您的阿里云账号的AccessKey ID";
      public static final String SECRET_KEY = "您的阿里云账号的AccessKey Secret";
      public static final String TAG = "您自定义的消息Tag属性";
      public static final String NAMESRV_ADDR = "您刚创建的消息队列RocketMQ版实例的TCP接入点，可在消息队列RocketMQ版控制台的实例详情页面获取TCP协议客户端接入点";                              

      说明

      • 创建AccessKey（包括AccessKey ID和AccessKey Secret）的具体步骤，请参见创建AccessKey。
      • 如果RAM子账号拥有该Topic的权限以及自己的AccessKey，那么也可以使用RAM子账号的AccessKey。
      • 参数与接口的更多信息，请参见接口和参数说明。
   2. 配置common.xml。

       <props>
       <prop key="AccessKey">XXX</prop> <!-- 使用前请修改这些资源信息 -->
       <prop key="SecretKey">XXX</prop>
       <prop key="GROUP_ID">XXX</prop>
       <prop key="Topic">XXX</prop>
       <prop key="NAMESRV_ADDR">XXX</prop>
      </props>

以Main方式运行Demo

1. 发送消息。
   • 发送普通消息：
     • 以纯Java方式发送普通消息：运行SimpleMQProducer类。
     • 以Spring方式发送普通消息：运行ProducerClient类。
     • 以Spring Boot方式发送普通消息：运行ProducerClient类。
   • 发送事务消息：
     • 以纯Java方式发送事务消息：运行SimpleTransactionProducer类。

       LocalTransactionCheckerImpl类为本地事务check接口类，用于校验事务。更多信息，请参见收发事务消息。

     • 以Spring方式发送事务消息：运行TransactionProducerClient类。
     • 以Spring Boot方式发送事务消息：运行TransactionProducerClient类。
     运行SimpleTransactionProducer类。
   • 发送顺序消息：
     • 以纯Java方式发送顺序消息：运行SimpleOrderProducer类。
     • 以Spring方式发送顺序消息：运行OrderProducerClient类。
     • 以Spring Boot方式发送顺序消息：运行OrderProducerClient类。

     此方式下，消息发布和消费都按顺序进行。更多信息，请参见收发顺序消息。

   • 发送定时和延时消息：运行MQTimerProducer类发送消息。延时3秒后投递。

     您也可以指定一个精确的投递时间，最长定时时间为40天。更多信息，请参见收发定时消息。

   在消息队列RocketMQ版控制台，按Topic查询消息，可以看到消息已经发送至Topic。
2. 接收消息。
   • 接收普通消息：
     • 以纯Java方式接收普通消息：运行SimpleMQConsumer类。
     • 以Spring方式接收普通消息：运行ConsumerClient类。
     • 以Spring Boot方式接收普通消息：运行ConsumerClient类。
   • 接收事务消息：
     • 以纯Java方式接收事务消息：运行SimpleMQConsumer类。
     • 以Spring方式接收事务消息：运行ConsumerClient类。
     • 以Spring Boot方式接收事务消息：运行ConsumerClient类。
   • 接收顺序消息：
     • 以纯Java方式接收顺序消息：运行SimpleOrderConsumer类。
     • 以Spring方式接收顺序消息：运行OrderConsumerClient类。
     • 以Spring Boot方式接收顺序消息：运行OrderConsumerClient类。
   • 接收定时和延时消息：运行SimpleMQConsumer类。
     说明 Spring和Spring Boot框架暂不支持收发定时和延时消息。
   可以看到消息被接收打印的日志。因为有初始化，所以需等待几秒，在生产环境中不会经常初始化。

结果验证：在消息队列RocketMQ版控制台，查看消费者状态，可以看到启动的消费端已经在线，并且订阅关系一致。

更多信息

• Spring集成
• 使用 Exactly-Once 投递语义收发消息
• 发送普通消息（三种方式）
• 发送消息（多线程）