阿里云国际站经销商，主营阿里云，腾讯云，华为云，亚马逊aws，谷歌云gcp,微软云az，免费开户，代充值优惠大，联系客服飞机@jkkddd
前提条件
已注册阿里云账号。
已开通物联网平台服务。
已开通消息队列RocketMQ服务。
如未开通，请登录消息队列 RocketMQ产品页面，开通服务。
已准备开发环境。本示例使用Java SDK开发的环境如下：
操作系统：Windows 10 64位
JDK版本：JDK8
集成开发环境：IntelliJ IDEA社区版
操作步骤
登录物联网平台控制台，创建产品和设备。
在控制台左上方，选择地域目标实例所在地域，然后在实例概览页面，找到对应实例，单击实例名称。
本示例选择地域华东2（上海）。
在左侧导航栏选择设备管理 > 产品，单击创建产品，配置参数，单击确认。
本示例中，产品名称为MQ_test，节点类型为直连设备，其他参数使用默认值。
单击查看产品详情，在产品详情页面，单击Topic类列表 > 自定义Topic，然后单击自定义Topic类，定义一个用于设备上报数据的Topic。
本示例中，定义的Topic类：/${YourProductKey}/${YourDeviceName}/user/data。
在左侧导航栏选择设备管理 > 设备，单击添加设备，为产品MQ_test创建设备。
本示例中，创建了一个名称为MQdevice的设备。
在消息队列RocketMQ控制台，创建Topic和消费者。
登录消息队列RocketMQ版控制台。
在左侧导航栏选择实例列表，单击创建实例，创建一个4.0系列的标准版实例，地域选择华东2（上海）。
具体操作，请参见创建实例。
在实例列表页面，单击实例名称。
在实例详情页面，单击创建 Group，配置如下图所示，然后单击确定。
创建消息消费者，然后在RocketMQ控制台查看消费者状态，确保消费者处于在线状态，订阅关系一致。
本文以调用TCP协议的SDK为例，进行收发消息。SDK获取和使用的详细内容，请参见调用TCP协议的SDK收发普通消息。
返回物联网平台控制台，在对应实例下，设置数据流转规则，将设备上报的数据转发至消息队列（RocketMQ）。
在左侧导航栏选择消息转发 > 云产品流转。
在云产品流转页面，单击创建规则。
输入规则名称MQ流转，数据格式选择为JSON，单击确认。
单击编写SQL，设置数据处理SQL，如下图所示，然后单击确认。
所有设置完成后，返回至云产品流转页面，单击MQ流转规则对应的启动。
规则启动后，物联网平台会将规则SQL中定义的设备上报消息转发至消息队列（RocketMQ）的Topic中。
使用Java SDK模拟设备接入物联网平台，并上报消息。
下载Java SDK Demo，然后解压。
在IntelliJ IDEA中，导入Demo包中的示例工程JavaLinkKitDemo。
在文件device_id.json中输入MQdevice的设备证书信息：productKey、deviceName和deviceSecret。
在文件srcmainjavacom.aliyun.alink.devicesdk.demoMqttSample.java中修改MQTT Topic为设备上报数据的Topic。
本示例中，使用的Topic是/{YourProductKey}/${YourDeviceName}/user/data。
