ESP8266 阿里云 MQTT物联网测试

阿里云 MQTT物联网测试"/>

ESP8266 阿里云 MQTT物联网测试

 前面写了篇恢复ESP8266 发布APRS的文章

ESP8266 APRS 板子修改为提交数据到T2服务器的方法_五块钱的方便面的博客-CSDN博客一年多前，我折腾好了基于ESP8266 + BMP280 + 锂电池 方案做了个nodeMCU固件的APRS WX板子。://github/bg6cq/nodemcu_bme280自己动手编译nodemcu固件（ESP8266）_五块钱的方便面的博客-CSDN博客_nodemcu 固件编译起因或者说好处最近在玩ESP8266 + BMP280 的APRS气象数据报，其实很早之前就看到过BG6CQ老师的gi，正好把MQTT的也玩玩，大名鼎鼎的物联网，首选肯定是阿里云了，对我这种玩具型的免费，而且服务端稳定。

nodeMCU的固件当时是编译进了MQTT支持的，BG6CQ老师的程序代码里面也同时写了MQTT的部分，不过不是针对阿里云，需要修改。

先说下结论：如果不是有大量的代码而使用他人的程序，真不如自己写了（lua上手程度真的和arduino没啥区别了），改了几天下来，逻辑改的乱七八糟，居然也能正常工作，真是神奇。

阿里云有好多SDK之类，我没用，还是用的nodeMCU 的Lua来改，毕竟有现成的代码。

还是做个笔记吧

1.阿里云部分

云端部分网上有很多现成的文章，但是都写的过于复杂，我自己简单整理了下：

开通物联网--》新建产品--》添加设备。  

个人理解：产品代表一个完整产品，设备代表产品上的小的功能模块，但是模块的功能定义或者说数据模型（就是传感器的温度气压电压这些）是在产品里面定义的。

创建好这几个以后，mqtt连接参数直接在设备的信息里面有个MQTT连接参数，并不需要网上那些文章说的还要单独去做什么计算。

2.软件测试

创建好后不要直接去设备上改代码测试，下载MQTTX这个软件，垮平台的，UOS上用完全没问题。

MQTTX添加个连接，几个参数第一步说了设备信息里面有现成的了。

 点链接后，可以直接订阅个topic，topic其实相当于一个消息通道，客户端订阅后，服务器下发消息，客户端就会收到。

服务器的topic在产品的topic类列可以看到，已经有很多现成的topic了，也可以自定义topic，我只想通过服务器获取esp8266上报的温度气压电压等信息，所以客户端不需要订阅，但这里为了获取8266要push的json报文格式，所以选下面的属性设置 订阅一个。

订阅后在设备的调试界面，对产品定义的几个属性做设置，这时候MQTTX应该能收到服务器下发的topic信息，这样就能得到报文的json格式，属性的标识符见产品的功能定义，这里面还可以对产品属性做修改。比如标识符，数据类型，取值范围，布进。除了里面默认有的，还可以自定义功能。

 3.设备端代码

设备商代码主要就是：

mqtt客户端创建-》mqtt连接-》mqtt publish（包含温度气压等）-》mqtt:close

3.1 mqtt 客户端创建及连接到服务器

function mqtt_connect()m = mqtt.Client(mqtt_client_id,30,mqtt_user,mqtt_password)print(mqtt_client_id)
-- resolv ali iot host ip
sk = net.createConnection(net.TCP, 0)
net.dns.setdnsserver("114.114.114.114", 0)
net.dns.resolve(mqtt_host_dns, function(sk, ip) mqtt_host=ip end)
print("resolved mqtt_host:"..mqtt_host.."\n") 
sk = nilprint("begin connect mqtt,mqtt_host:"..mqtt_host.."!")
m:connect(mqtt_host, mqtt_port, false,function(m) mqtt_connected = true print("mqtt online") end,
function(m,reason) print("fail with:"..reason) end)
end

3.2 mqtt  publish

if count%2 == 0 thenif mqtt_connected thenprint("mqtt publish") 
-- publish to ali iot serverhumi_ali=string.format("%.1f",humi)temp_ali=string.format("%.1f",temp)press_ali=string.format("%.1f",press)voltage_ali=string.format("%.2f",Voltage)mqttstr="{\"method\":\"thing.service.property.set\",\"id\":\"1540317865\",\"params\":{\"CurrentHumidity\":"..humi_ali..",\"CurrentTemperature\":"..temp_ali..",\"Atmosphere\":"..press_ali..",\"WiFiRSSI\":"..rssi..",\"CurrentVoltage\":"..voltage_ali.."},\"version\":\"1.0.0\"}"print("str is:"..mqttstr)m:publish(mqtt_topic,mqttstr,0,0)data_send = truem:close()elseif send_mqtt thenmqtt_connect()m:on("offline", function(c)print("mqtt offline, try connect to "..mqtt_host..":"..mqtt_port)mqtt_connected = falseend)  endsend_data()  
end

这个里面send_data()主要发送的APRS数据，写这一段是纠结的不行，BG6CQ老师原来的代码写了发送aprs mqtt http三类，想删吧又怕搞乱了，不删吧这些逻辑看起来头晕，凑合用吧。

主要就是mqttstr的连接，然后发送完关闭mqtt连接，这个Lua里面的回调函数（函数执行成功后可以将返回的数

据用来做新写的函数参数并在函数执行成功后执行）真是不习惯啊。比如：

sk = net.createConnection(net.TCP, 0)
net.dns.setdnsserver("114.114.114.114", 0)net.dns.resolve(mqtt_host_dns, 
--下面2行就是net.dns.resolve这个函数的回调函数，function(sk, ip) 是函数头，
-- 就一个语句mqtt_host=ip 然后加上 end表示这个回调函数结束，end后面的）是net.dns.resolve这个函数的括号function(sk, ip) 
mqtt_host=ip end)

半吊子改程序就是慢啊，上传后在esp8266上调试也费时间。

调试成功后，上阿里云管理界面可以选调试，能实时收到客户端传上来的报文。

最后在设备的物模型数据里面可以看到我们产品里面定义的属性，值就是我们ESP8266报上来的数据 

据说可以微信小程序来查看这些数据。接下来搞一个玩完，至于设备端订阅topic，目前我还没想到有需要esp8266控制的，所以目前暂时不搞，要做成好用的，那就可以订阅下topic，通过mqtt做代码更新等等，反正官方都给你定义好了那么多topic。

微信小程序未完待续～