NodeMCU学习（十）--发送数据到OneNET物联网平台

╰+攻爆jí腚メ 2022-10-26 01:21 324阅读 0赞

通过NodeMCU发送数据到OneNET平台，序号先在OneNET平台上创建MQTT协议的产品，然后在产品线创建设备。在连接平台时需要用到产品ID、设备ID以及设备的鉴权信息。在OneNET平台，MQTT协议对应的服务器IP和端口为：183.230.40.39，6002。注意OneNET有多种协议可进行连接，不同的协议对应的服务器IP和端口号是不同的。想要实现本实验的功能，需要对TCP/IP和MQTT协议有一定的了解。（[《MQTT协议--MQTT协议解析》][MQTT_--MQTT]，[《MQTT协议--MQTT协议简介及原理》 ][MQTT_--MQTT 1]）

## 1、如何连接OneNET平台 ##

[《NodeMCU学习（九）--连接OneNET物联网平台》][NodeMCU_--_OneNET]

[《OneNET物联网平台介绍》][OneNET]

[OneNET物联网平台][OneNET 1]

## 2、主要API ##

### 2.1  WiFi ###

（1）wifi.setmode()

（2）wifi.sta.config()

（3）wifi.sta.connect()

关于API的使用方法，可以参考博客[《NodeMCU学习（六）--WiFi》][NodeMCU_--WiFi]，也可以参考[官网][Link 1]对API的说明。

### 2.2  MQTT ###

（1）[mqtt.Client()][mqtt.Client]

（2）[mqtt.client:connect()][mqtt.client_connect]

（3）[mqtt.client:publish()][mqtt.client_publish]

## 3、平台的接入流程 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70][]

## 4、编写Lua脚本 ##

### 4.1  源代码 ###

cfg = {}
    cfg.ssid = "OnePlus6"
    cfg.pwd = "1234567890"
    
    wifi.setmode(wifi.STATIONAP)
    wifi.sta.config(cfg)
    wifi.sta.connect()
    
    DeviceID = "1234567890"--根据自己的设备ID填写
    ProductID = "123456"--根据自己的产品ID填写
    KeepAlive = 20--保持连接的间隔时间，可根据实际需要填写
    AuthoInfo = "123456"--设备对应的鉴权信息
    
    host = "183.230.40.39"
    port = 6002
    
    myClient = mqtt.Client(DeviceID, KeepAlive, ProductID, AuthoInfo)
    
    timer1 = tmr.create()
    timer2 = tmr.create()
    
    function ReConnect()
        if wifi.sta.getip() == nil then
            print("Connect AP,waitting...")
        else
            print("Connected AP ,success!")
            print("IP is:"..wifi.sta.getip())
            timer1:stop()
    
            myClient:connect(host, port, function(client)
                print("Connected OneNET success!")
            end)
    
            timer2:alarm(1000, tmr.ALARM_AUTO, Update_Message)
        end
    end
    
    timer1:alarm(1000,tmr.ALARM_AUTO,ReConnect)
    
    currentSum = 0
    voltageSum = 0        
    function Update_Message()
        info = {}
        info.curr = currentSum
        info.volt = voltageSum
    
        currentSum = currentSum + 1
        voltageSum = voltageSum - 1
        ok,message = pcall(sjson.encode, info)
        print("message:"..message)
    
        header = string.char(3, 0 ,string.len(message))..message
        myClient:publish("$dp", header, 0, 0, function(client)
            print("Publish info success!")
        end)
    end

### 4.2  关键代码解析 ###

（1）myClient = mqtt.Client(DeviceID, KeepAlive, ProductID, AuthoInfo)

DeviceID = "1234567890"--根据自己的设备ID填写  
ProductID = "123456"--根据自己的产品ID填写  
KeepAlive = 20--保持连接的间隔时间，可根据实际需要填写  
AuthoInfo = "123456"--设备对应的鉴权信息

（2）

myClient:connect(host, port, function(client)  
            print("Connected OneNET success!")  
        end)

host：OneNET平台的MQTT协议对应的服务器IP

port：OneNET平台的MQTT协议对应的服务器开放的端口

function(client)（）：连接成功后的回调函数

（3）ok,message = pcall(sjson.encode, info)

1）pcall在保护模式（protected mode）下执行函数内容，同时捕获所有的异常和错误。若一切正常，pcall返回true以及“被执行函数”的返回值；否则返回nil和错误信息。

2）把info转换为json键值对；

（4）header = string.char(3, 0 ,string.len(message))..message

1）string.char()把数字或字符连接成字符串；

2）header为MQTT协议中的协议头，3表示`MQTT`数据包类型为PUBLISH

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 1][]

3）

myClient:publish("$dp", header, 0, 0, function(client)  
        print("Publish info success!")  
    end)

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 2][]

topic:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 3][]

Payload：包含真正的数据点内容；

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 4][]

function(client)（）为发送成功后的回调函数；

### 4.3  调试 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 6][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 7][]

[MQTT_--MQTT]: https://blog.csdn.net/zwb_578209160/article/details/113365620
[MQTT_--MQTT 1]: https://blog.csdn.net/zwb_578209160/article/details/113365191
[NodeMCU_--_OneNET]: https://blog.csdn.net/zwb_578209160/article/details/113414264
[OneNET]: https://blog.csdn.net/zwb_578209160/article/details/113413667
[OneNET 1]: https://open.iot.10086.cn/
[NodeMCU_--WiFi]: https://blog.csdn.net/zwb_578209160/article/details/113315330
[Link 1]: https://nodemcu.readthedocs.io/en/release/modules/wifi/#wifisetmode
[mqtt.Client]: https://nodemcu.readthedocs.io/en/release/modules/mqtt/#mqttclient
[mqtt.client_connect]: https://nodemcu.readthedocs.io/en/release/modules/mqtt/#mqttclientconnect
[mqtt.client_publish]: https://nodemcu.readthedocs.io/en/release/modules/mqtt/#mqttclientpublish
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70]: /images/20221024/d29149e8280f469eb3d63b5d584c2b8d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 1]: /images/20221024/2c73ed65fe284349bca8ebcfe8743ef7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 2]: /images/20221024/ea1488dd3a5646e3a8c9a6d238c0930c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 3]: /images/20221024/c1727a34912e40be934cd504412080ae.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 4]: /images/20221024/6f53a2871c0c47dbb16bc7fd3d349513.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 5]: /images/20221024/279924e7b0724900a8b1b372b4e6a313.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 6]: /images/20221024/26256e9618374703aaaf18f3a1d95224.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p3Yl81NzgyMDkxNjA_size_16_color_FFFFFF_t_70 7]: /images/20221024/cfcd7351f0654363b8c067b27c54144b.png