如何运行 Demo

阿里云消息服务操作指南

以 Main 方式启动收发消息

发送普通消息: - 步骤1: 在您的Java项目中，找到SimpleMQProducer类。 - 步骤2: 运行该类。这将以纯Java方式发送普通消息至指定的Topic。

登录阿里云MQ控制台： - 在左侧菜单栏，依次点击“消息查询” > “Topic查询”。 - 选择您刚才发送消息的Topic名称进行查询，确认消息已成功发送至Topic。

接收普通消息: - 对于Spring方式，运行MQProducer4Spring类发送消息。 - 紧接着，运行MQConsumer4Spring类来接收这些消息。 - 观察控制台输出或日志，确认消息接收成功。初始化可能需要几秒钟，请耐心等待。

发送事务消息

• 操作: 运行SimpleTransactionProducer类以发送事务消息。
• 注意: 需要配置LocalTransactionCheckerImpl类作为本地事务检查接口，确保事务的正确校验。
• 详细事务处理机制请参考相关文档中的“发送分布式事务消息”。

收发顺序消息

• 发送: 运行SimpleOrderProducer类发送顺序消息。
• 接收: 运行SimpleOrderConsumer类接收这些顺序消息。
• 说明: 顺序消息保证了消息发布和消费的顺序性，适用于对消息处理顺序有严格要求的场景。

发送定时（延时）消息

• 使用MQTimerProducer类发送消息，并设置延时参数（例如，延时3秒）。
• 您也可以为消息指定一个精确的未来投递时间，最长可设置40天。
• 查看消息队列RocketMQ版控制台，确认消息在预定时间被投递。

HTTP、MQTT物联接入

• HTTP接入: 参考MQ HTTP接入文档配置相应接口与逻辑。
• MQTT接入: 请遵循MQTT接入指南，特别注意RAM用户权限配置及Topic规范化问题，避免子级Topic后出现不必要的“/”。

以上步骤涵盖了使用阿里云消息服务进行消息收发的主要操作，包括普通消息、事务消息、顺序消息以及定时消息的处理流程，同时提供了HTTP与MQTT物联网接入的基本指引。确保在操作前，已经正确配置了实例ID、接入点、AccessKey等必要信息，并根据实际业务需求调整实例规格以避免限流问题。