数据转发至RocketMQ

场景说明

将数据流转到RocketMQ云服务，兼容开源RocketMQ客户端。提供顺序、延迟、定时、重投、死信、事务消息等功能，更好的适配电商、金融等多样的业务场景。提供消息追踪、消息溯源、链路诊断、死信导出、监控告警等能力，帮助您全方面的了解服务状况，保证业务正常运行。

购买RocketMQ

1. 登录华为云，访问分布式消息服务RocketMQ版， 进入分布式消息服务管理控制台。
2. 单击右上角“购买RocketMQ实例”, 按照需求选择RocketMQ规格，单击“立即购买”。
   图1 购买RocketMQ
   

3. 单击进入购买的RocketMQ实例，开启ACL访问控制后，单击“用户管理”添加用户，可参考创建用户。
   图2 添加用户

   

4. 单击左侧导航栏“topic管理”，单击“创建topic”创建RocketMQ的topic。

配置设备接入服务

在设备接入服务中设置数据转发规则，实现当设备上报数据时将数据转发至RocketMQ。

1. 访问设备接入服务，单击“立即使用”进入设备接入控制台。
2. 在左侧导航栏选择“规则>数据转发”，单击左上角的“创建规则”。
3. 参考下表参数说明，填写规则内容。以下参数取值仅为示例，您可参考数据转发简介创建自己的规则，填写完成后单击“创建规则”。

   表1 创建规则参数说明

   参数名	参数说明
   规则名称	自定义，如“iotda-rocketmq”。
   规则描述	自定义，如“数据转发至RocketMQ”。
   数据来源	选择“设备属性”。
   触发事件	自动匹配“设备属性上报”。
   资源空间	选择“所有资源空间”。

4. 单击“设置转发目标”页签，单击“添加”，设置转发目标，设置完成后单击“确定”按钮。

   表2 创建转发目标参数说明

   参数名	参数说明
   转发目标	选择“分布式消息服务（RocketMQ）”。
   对接地址	填写RocketMQ的连接地址，需填写元数据公网连接地址。
   SSL	选择是否开启SSL， 开启SSL需要RocketMQ支持SSL。
   主题	填写RocketMQ的topic。
   账户名	填写在RocketMQ中用户管理添加的用户名。
   密码	填写在RocketMQ中用户管理中设置的用户密码。

   图3 修改转发目标

   

5. 单击“启动规则”，激活配置好的数据转发规则。

验证操作

• 您可以使用配置设备接入服务时注册的真实设备接入平台，上报任意数据。
• 您也可以使用模拟器模拟设备上报数据，操作方法请参考在线开发MQTT协议的智慧路灯。

期望结果：

登录RocketMQ控制台， 单击“消息查询”， 选择查询的topic即可看到推送至RocketMQ的消息。

图4 验证消息