Luat实例教程：连接aliyun
本示例实现的功能是：MQTT_TCP连接阿里云物联网后台的demo项目（华东2节点）注意：在demo中，aliyun和aliyun_ssl是连接阿里云物联网杭州节点。aliyun_ssl_huadong2是连接阿里云物联网华东2节点，目前阿里云主推的华东2节点，所以用该节点示例。1.如果要用ssl，必须下载包含ssl的lod（固件）。关于固件的说明和下载参见固件2.打开阿里云物联网套件，打开管理控制台，新建一个项目。
//upload-images.jianshu.io/upload_images/4830067-363f21af9503dbed
创建
3.在设备管理处添加设备，设备名称为模块的IMEI号，可以通过misc.getimei()获取。
//upload-images.jianshu.io/upload_images/4830067-1703a1103b63a92a
添加设备
4.将生成的deviceSecret当做sn写入到模块，可以通过misc.setsn()写入
//upload-images.jianshu.io/upload_images/4830067-aa06c46c113f4f41
设备证书
//upload-images.jianshu.io/upload_images/4830067-c046a6f921269f96
SN
可以看到SN已经修改为deviceSecret了--将要写入设备的新SN号local newsn = "E4xrt3tdYYAiQ91e6WMEXxdDIv9ITNt2"--3秒后开始写SNsys.timer_start(misc.setsn,3000,newsn)--查询SN和IMEIsys.timer_start(misc.getsn,5000)sys.timer_start(misc.getimei,5000)--完整代码参见write_sn(https://github.com/openLuat/Luat_Air202-Air800-Air201/tree/master/script/demo/write_sn)5.打开aliyun_ssl_huadong2，将test.lua里面的PRODUCT_KEY修改为阿里云上的。module(...,package.seeall)require"aliyuniotssl"--阿里云华东2节点上创建的productKey，用户如果自己在阿里云上创建项目，根据自己的项目信息，修改此值local PRODUCT_KEY = "OiStgsPb69t"--除了上面的PRODUCT_KEY外，还需要DEVICE_NAME和DEVICE_SECRET--lib中会使用设备的IMEI和SN号用做DEVICE_NAME和DEVICE_SECRET，所以在阿里云上添加设备时，DEVICE_NAME就用IMEI，然后把生成的DEVICE_SECRET当做SN写入设备中local qos1cnt = 1--[[函数名：print功能：打印接口，此文件中的所有打印都会加上aliyuniot前缀参数：无返回值：无]]local function print(...) _G.print("test",...)end--[[函数名：pubqos1testackcb功能：发布1条qos为1的消息后收到PUBACK的回调函数参数： usertag：调用mqttclient:publish时传入的usertag result：true表示发布成功，false或者nil表示失败返回值：无]]local function pubqos1testackcb(usertag,result) print("pubqos1testackcb",usertag,result) sys.timer_start(pubqos1test,20000) qos1cnt = qos1cnt+1end--[[函数名：pubqos1test功能：发布1条qos为1的消息参数：无返回值：无]]function pubqos1test() --注意：在此处自己去控制payload的内容编码，aliyuniot库中不会对payload的内容做任何编码转换 aliyuniotssl.publish("/"..PRODUCT_KEY.."/"..misc.getimei().."/update","qos1data",1,pubqos1testackcb,"publish1test_"..qos1cnt)end--[[函数名：subackcb功能：MQTT SUBSCRIBE之后收到SUBACK的回调函数参数： usertag：调用mqttclient:subscribe时传入的usertag result：true表示订阅成功，false或者nil表示失败返回值：无]]local function subackcb(usertag,result) print("subackcb",usertag,result)end--[[函数名：rcvmessage功能：收到PUBLISH消息时的回调函数参数： topic：消息主题（gb2312编码） payload：消息负载（原始编码，收到的payload是什么内容，就是什么内容，没有做任何编码转换） qos：消息质量等级返回值：无]]local function rcvmessagecb(topic,payload,qos) print("rcvmessagecb",topic,payload,qos) aliyuniotssl.publish("/"..PRODUCT_KEY.."/"..misc.getimei().."/update","device receive:"..payload,qos)end--[[函数名：connectedcb功能：MQTT CONNECT成功回调函数参数：无 返回值：无]]local function connectedcb() print("connectedcb") --订阅主题 aliyuniotssl.subscribe({{topic="/"..PRODUCT_KEY.."/"..misc.getimei().."/get",qos=0}, {topic="/"..PRODUCT_KEY.."/"..misc.getimei().."/get",qos=1}}, subackcb, "subscribegetopic") --注册事件的回调函数，MESSAGE事件表示收到了PUBLISH消息 aliyuniotssl.regevtcb({MESSAGE=rcvmessagecb}) --发布一条qos为1的消息 pubqos1test()end--[[函数名：connecterrcb功能：MQTT CONNECT失败回调函数参数： r：失败原因值 1：Connection Refused: unacceptable protocol version 2：Connection Refused: identifier rejected 3：Connection Refused: server unavailable 4：Connection Refused: bad user name or password 5：Connection Refused: not authorized返回值：无]]local function connecterrcb(r) print("connecterrcb",r)endaliyuniotssl.config(PRODUCT_KEY)aliyuniotssl.regcb(connectedcb,connecterrcb)然后下载烧录到模块里。华东2和杭州节点的区别在于：杭州节点有PRODUCT_SECRET，而华东节点没有，其他都一样。6.这时，可以在设备管理处看到模块已经上线
//upload-images.jianshu.io/upload_images/4830067-3b3aab199558d171
上线
7.发布订阅消息点击设备管理->Topic列表则可以看到默认的主题
//upload-images.jianshu.io/upload_images/4830067-3cdd5acb6b2bb8be
topic
平台向模块发布消息：demo默认订阅主题为/productKey/imei/get,对应本例的主题为/vNmSDLf5G33/868575021153269/get，可以看到权限为订阅。发送了一条内容为“test”，qos为0的消息，trace中打印接收到的消息。
//upload-images.jianshu.io/upload_images/4830067-66b6b20faa0675e4
pub
模块向平台发布消息：
//upload-images.jianshu.io/upload_images/4830067-b8d8f57030ccea19
sub
可以查看到已经接收到了80条消息，但平台不支持查看消息内容。
8.如果用户想新增topic，对应的在模块代码中订阅或向该topic发布消息即可。
//upload-images.jianshu.io/upload_images/4830067-445c7da4046988ba
添加topic
[*]完整代码见下链接
[*]Air200
[*]Air202_Air800_Air201
页:
[1]