传感器上传数据到阿里云Iot，然后从阿里云Iot传输数据到我的服务器和数据库.pdf

传感器上传数据到阿⾥云Iot，然后从阿⾥云Iot传输数据到我的 服务器和数据库 整个系统架构如下： MQTT 和RocketMQ的区别： 1、传感器采⽤GPRS传输数据，采⽤微消息队列MQTT，微消息队列 MQTT 主要承担移动端连接接⼊、连接管理、数据转发等⼯作，相当 于⼀个⽆限扩展能⼒的连接⽹关。传感器传送数据到阿⾥云Iot。MQTT⽀持Python，java，有相应的sdk，地址如下： 阿⾥云Iot的设备传输数据格式是json格式，采⽤post⽅式提交数据，具体格式如下： 设备属性上报 通过该Topic获取设备上报的属性信息。 Topic：/sys/{productKey}/{deviceName}/thing/event/property/post 数据格式： { "iotId":"4z819VQHk6VSLmmBJfrf00107ee200", "productKey":"1234556554", "deviceName":"deviceName1234", "gmtCreate":1510799670074, "deviceType":"Ammeter", "items":{ "Power":{ "value":"on", "time":1510799670074 }, "Position":{ "time":1510292697470, "value":{ "latitude":39.9, "longitude":116.38 } } } } 参数说明： 参数 类型 说明 iotId String 设备在平台内的唯⼀标识 productKey String 设备所属产品的唯⼀标识 deviceName String 设备名称 deviceType String 设备类型 items Object 设备数据 Power String 属性名称，产品所具有的属性名称请参考TSL描述 Position String 属性名称，产品所具有的属性名称请参考TSL描述 value 根据TSL定义 属性值 time Long 属性产⽣时间，如果设备没有上报默认采⽤云端⽣成时间 gmtCreate Long 数据流转消息产⽣时间 发送⽅式如下： MQTT采⽤topic形式发送数据，⽣产者产⽣数据，通过topic进⾏发送，消费者订阅消息，接收消息。 RocketMQ是⼀个消息队列，吞吐性能强⼤。格式如下， ⾃定义⽣产者与消费者如下： producer 发送消息 public class Producer { public static void main(String[] args) throws MQClientException, InterruptedException { DefaultMQProducer producer = new DefaultMQProducer("pay_topic_01"); producer.setNamesrvAddr("8:9876"); producer