消息服务实时消费设备状态变化和数据

0.准备工作



0.1 注册阿里云账号


使用个人淘宝账号或手机号，开通阿里云账号，并通过实名认证(可以用支付宝认证)

0.2 免费开通IoT物联网套件


IoT套件产品官网 
消息服务官网 

0.3 软件环境


Nodejs安装 
Java8 安装
开发工具:Sublime Text3/ IntelliJ IDEA 


1.阿里云IoT控制台配置服务端订阅


阿里云IoT物联网套件开通 

1.1 创建产品（基础版）


我们在阿里云IoT控制台，创建产品：空气检测，选择基础版。



1.2 在产品下添加设备


我们在阿里云IoT控制台，设备管理里空气检测产品下添加一个具体设备。



1.2 在产品下配置服务端订阅


我们在阿里云IoT控制台，为空气检测产品开通服务端订阅，勾选设备上报消息和设备状态变化通知，开通后会有MNS的区域：cn-shanghai和队列信息：aliyun-iot-a1jnUEKYhw4，如下。


通过阅读阿里云IoT文档，我们了解到队列中消息结构体如下：

• 
  topic：表示该消息源自套件中的哪个topic，当messageType=status时，topic为null，当messageType=upload时，topic为具体的设备Topic
• 
  payload：数据为Base64 Encode的数据。当messageType=status时，数据是设备状态数据；当messageType=upload时，data即为设备发布到Topic中的原始数据。

2.2 编写设备端应用程序代码


我们需要在控制台获取设备身份三元组：productKey，deviceName，deviceSecret，以及产品分区regionId

11.     deviceName: "officeThermometer",
12.     deviceSecret: "oauYYavdIV9QOt7d9WcrnIjXSNc2i26A",
20. const topic = `${options.productKey}/${options.deviceName}/update`;

我们切换到MNS控制台，选择华东2区域，可以看到消息队列aliyun-iot-a1jnUEKYhw4有3条活跃消息MNS控制台：

3 消费队列中设备消息



3.1 消息服务MNS使用

我们以java开发为例，pom中添加依赖aliyun-sdk-mns，httpasyncclient，fastjson，如下：

9.     "deviceName": "suw8umOqgJ72yCADerZp",

8.     "deviceName": "suw8umOqgJ72yCADerZp",