从阿里云IOT云平台获取设备数据
前言：
这篇文档主要讲述的就是当设备的数据发送到物联网套件之后，用户的服务端如何获取设备
的数据。
通过阅读阿里云IoT文档，我们了解到队列中消息结构体如下：
{
"payload": "Base64 Encode的数据",
"messagetype": "status",
"messageid": 996000000000000001,
"topic": "具体的设备Topic",
"timestamp": 1526450324
}
messageid：IoT套件生成的消息IDmessagetype：指的是消息类型:设备状态status和设备上报消息uploadtopic：表示该消息源自套件中的哪个topic，当messageType=status时，topic为null，当messageType=upload时，topic为具体的设备Topicpayload：数据为Base64 Encode的数据。当messageType=status时，数据是设备状态数据；当messageType=upload时，data即为设备发布到Topic中的原始数据。timestamp：队列中消息生成时间戳，并非业务的时间戳
一，基于HTTP/2通道的服务端订阅-设备状态和数据
1.服务端订阅
1.1 服务端订阅流程
在IoT场景，有时候我们期望业务服务器能接收到设备状态和设备采集的数据，而不是通过云产品中转。这时我们可以开启服务端订阅，IoT平台会把设备产生的消息通过HTTP/2通道推送到业务服务器，以便根据自身业务场景消费。
服务端可以直接订阅产品下配置的所有类型的消息。
目前，新版物联网平台通过HTTP/2通道进行消息流转。配置HTTP/2服务端订阅后，物联网平台会将消息通过HTTP/2通道推送至服务端。通过接入HTTP/2 SDK，企业服务器可以直接从物联网平台接收消息。HTTP/2 SDK提供身份认证、Topic订阅、消息发送和消息接收能力，并支持设备接入和云端接入能力。HTTP/2 SDK适用于物联网平台与企业服务器之间的大量消息流转，也支持设备与物联网平台之间的消息收发。
注：HTTP/2是方便、快捷、低延时，小堆积的消息流转通道，不是队列。目前是只有java8客户端sdk。 如果业务数据流非常大, 需要支持海量消息堆积，建议通过规则引擎流转队列方式处理。
不论那个方式，消费端还是需要提升自身消费速率才能高效处理业务消息。
目前服务端订阅是基于uid的，所有产品的消息都会被HTTP/2的client端消费，这时需要我们自己根据topic包含的productKey/deviceName区分
2.服务端订阅SDK使用
目前仅提供Java8版SDK
2.1 java sdk依赖
<!-- Aliyun core --><dependency> <groupId>com.aliyun</groupId><artifactId>aliyun-java-sdk-core</artifactId><version>3.7.1</version></dependency><!-- iot message client --><dependency> <groupId>com.aliyun.openservices</groupId> <artifactId>iot-client-message</artifactId> <version>1.1.2</version></dependency>
2.2 消费IoT平台设备消息
import .UnknownHostException;import java.util.concurrent.ExecutionException;import com.aliyun.openservices.iot.api.Profile;import com.aliyun.openservices.iot.api.message.MessageClientFactory;import com.aliyun.openservices.iot.api.message.api.MessageClient;import com.aliyun.openservices.iot.api.message.callback.MessageCallback;import com.aliyun.openservices.iot.api.message.entity.Message;public class H2Client {public static void main(String[] args) throws UnknownHostException, ExecutionException, InterruptedException {// 身份String accessKey = "阿里云accessKey";String accessSecret = "阿里云accessSecret";String regionId = "cn-shanghai";String uid = "阿里云账号 uid";String endPoint = "https://" + uid + ".iot-as-http2." + regionId + ".";// 连接配置Profile profile = Profile.getAccessKeyProfile(endPoint, regionId, accessKey, accessSecret);// 构造客户端MessageClient client = MessageClientFactory.messageClient(profile);// 数据接收client.connect(messageToken -> {Message m = messageToken.getMessage();System.out.println("\ntopic="+m.getTopic());System.out.println("payload=" + new String(m.getPayload()));System.out.println("generateTime=" + m.getGenerateTime());// 此处标记CommitSuccess已消费，IoT平台会删除当前Message，// 否则会保留到过期时间return mitSuccess;});}}
3,数据解析
3.1关于数据解析
由于低配置且资源受限或者对网络流量有要求的设备，不适合直接构造JSON数据和云端通信，因此选择将数据透传到云端，由云端运行转换脚本将透传的数据转换成Alink JSON格式的数据。您可以在创建产品时，选择数据格式为透传/自定义格式，目前转换脚本通过JavaScript语言开发，需要开发者自行开发转换脚本。物联网平台为开发者提供了用于数据解析的在线脚本编辑器，方便您进行在线的编辑和模拟调试。
3.2数据解析流程：
4,使用限制
当您使用服务端订阅时，请注意以下限制。
二，规则引擎 - 设备数据流转
1,什么是规则引擎
当设备基于Topic进行通信时，您可以使用规则引擎，编写SQL对Topic中的数据进行处理，并配置转发规则将处理后的数据转发到阿里云其他服务。例如：
可以转发到RDS、表格存储、TSDB中进行存储。可以转发到DataHub中，使用Streamcompute进行流计算，使用Maxcompute进行大规模离线计算。可以转发到函数计算进行事件计算。可以转发到另一个Topic中实现M2M通信。可以转发到消息队列MQ、消息服务实现高可靠消费数据·。
注意：如果数据格式为二进制的数据，不支持转发至表格存储、时序时空数据库和云数据库RDS版。
说明：二进制数据可使用to_base64(*)将原始数据转换成base64String，同时支持内置函数和条件筛选。
2，如何使用
具体使用细节参考：/cloud-dev/iot-tech/wr1bwu非常详细，在页面一顿配置即可，在此不再长篇大论。
3, 使用限制
规则引擎基于Topic对数据进行处理。只有通过Topic进行通信时，才能使用规则引擎。规则引擎通过SQL对Topic中的数据进行处理。SQL语法目前不支持子查询。支持部分函数，比如deviceName()获取当前设备名称，具体请参考函数列表。三,阿里收费规则
1,阿里收费规则
案例6：高级版
高级版的收费项目包括消息传输费用和设备管理费用。
有一个设备每秒向物联网平台发送0.4 KB大小的消息，然后物联网平台将该消息传输到5个设备，1个应用程序，即5个设备和1个应用程序接收该消息。当月有30天。
计费项：
消息传输费用
每条消息大小0.4 KB，小于每条消息的大小限制（0.5 KB），每条消息计为1条消息。
每月发送消息数：1×60×60×24×30=259.2万。
每月接收消息数：6×1×60×60×24×30=1555.2万。
总消息数：259.2万+1555.2万=1814.4万。
前100万条消息免费，所以，当月需付费的消息数：1814.4万–100万=1714.4万。
按照3.6元/100万条消息计费，当月消息传输费用：1714.4万x(3.6元/100万)=61.72元。
设备管理费用
日活设备数量为6个（1个消息发送设备和5个消息接收设备），小于每天每个账号10个免费日活设备赠额，所以设备管理费用为0元。
当月应付费用：61.72元+0元=61.72元。
注意：
您可以免费使用规则引擎转发消息，但是将数据转发至其他云产品中时，其他云产品正常计费。
