Merge branch 'master' of https://gitee.com/openLuat/LuatOS

demo/mqtt/main.lua

@@ -13,6 +13,10 @@ _G.sys = require("sys")
 --[[特别注意, 使用mqtt库需要下列语句]]
 _G.sysplus = require("sysplus")
 
+-- 自动低功耗, 轻休眠模式
+-- Air780E支持uart唤醒和网络数据下发唤醒, 但需要断开USB,或者pm.power(pm.USB, false) 但这样也看不到日志了
+-- pm.request(pm.LIGHT)
+
 --根据自己的服务器修改以下参数
 local mqtt_host = "lbsmqtt.airm2m.com"
 local mqtt_port = 1884
@@ -21,9 +25,10 @@ local client_id = "abc"
 local user_name = "user"
 local password = "password"
 
-local topic1 = "/luatos/1"
-local topic2 = "/luatos/2"
-local topic3 = "/luatos/3"
+local pub_topic = "/luatos/pub/" .. (mcu.unique_id():toHex())
+local sub_topic = "/luatos/sub/" .. (mcu.unique_id():toHex())
+-- local topic2 = "/luatos/2"
+-- local topic3 = "/luatos/3"
 
 local mqttc = nil
 
@@ -37,33 +42,47 @@ sys.taskInit(function()
         local password = "12345678"
         log.info("wifi", ssid, password)
         -- TODO 改成esptouch配网
-        LED = gpio.setup(12, 0, gpio.PULLUP)
+        -- LED = gpio.setup(12, 0, gpio.PULLUP)
         wlan.init()
         wlan.setMode(wlan.STATION)
         wlan.connect(ssid, password, 1)
         local result, data = sys.waitUntil("IP_READY", 30000)
         log.info("wlan", "IP_READY", result, data)
         device_id = wlan.getMac()
+        pub_topic = "/luatos/pub/" .. (wlan.getMac():toHex())
+        sub_topic = "/luatos/sub/" .. (wlan.getMac():toHex())
+        client_id = wlan.getMac():toHex()
     elseif rtos.bsp() == "AIR105" then
         -- w5500 以太网, 当前仅Air105支持
         w5500.init(spi.HSPI_0, 24000000, pin.PC14, pin.PC01, pin.PC00)
         w5500.config() --默认是DHCP模式
         w5500.bind(socket.ETH0)
-        LED = gpio.setup(62, 0, gpio.PULLUP)
+        -- LED = gpio.setup(62, 0, gpio.PULLUP)
         sys.wait(1000)
-        -- TODO 获取mac地址作为device_id
+        pub_topic = "/luatos/pub/" .. (w5500.getMac():toHex())
+        sub_topic = "/luatos/sub/" .. (w5500.getMac():toHex())
     elseif rtos.bsp() == "EC618" then
         -- Air780E/Air600E系列
-        --mobile.simid(2)
-        LED = gpio.setup(27, 0, gpio.PULLUP)
+        --mobile.simid(2) -- 自动切换SIM卡
+        -- LED = gpio.setup(27, 0, gpio.PULLUP)
         device_id = mobile.imei()
         sys.waitUntil("IP_READY", 30000)
+        pub_topic = "/luatos/pub/" .. (mobile.imei())
+        sub_topic = "/luatos/sub/" .. (mobile.imei())
+        client_id = mobile.imei()
     end
 
+    -- 打印一下上报(pub)和下发(sub)的topic名称
+    -- 上报: 设备 ---> 服务器
+    -- 下发: 设备 <--- 服务器
+    -- 可使用mqtt.x等客户端进行调试
+    log.info("mqtt", "pub", pub_topic)
+    log.info("mqtt", "sub", sub_topic)
+
     -- 打印一下支持的加密套件, 通常来说, 固件已包含常见的99%的加密套件
-    if crypto.cipher_suites then
-        log.info("cipher", "suites", json.encode(crypto.cipher_suites()))
-    end
+    -- if crypto.cipher_suites then
+    --     log.info("cipher", "suites", json.encode(crypto.cipher_suites()))
+    -- end
 
     -------------------------------------
     -------- MQTT 演示代码 --------------
@@ -72,7 +91,7 @@ sys.taskInit(function()
     mqttc = mqtt.create(nil,mqtt_host, mqtt_port, mqtt_isssl, ca_file)
 
     mqttc:auth(client_id,user_name,password) -- client_id必填,其余选填
-    mqttc:keepalive(30) -- 默认值240s
+    -- mqttc:keepalive(240) -- 默认值240s
     mqttc:autoreconn(true, 3000) -- 自动重连机制
 
     mqttc:on(function(mqtt_client, event, data, payload)
@@ -80,10 +99,11 @@ sys.taskInit(function()
         log.info("mqtt", "event", event, mqtt_client, data, payload)
         if event == "conack" then
             sys.publish("mqtt_conack")
-            -- mqtt_client:subscribe(topic1)--单主题订阅
-            mqtt_client:subscribe({[topic1]=1,[topic2]=1,[topic3]=1})--多主题订阅
+            mqtt_client:subscribe(sub_topic)--单主题订阅
+            -- mqtt_client:subscribe({[topic1]=1,[topic2]=1,[topic3]=1})--多主题订阅
         elseif event == "recv" then
             log.info("mqtt", "downlink", "topic", data, "payload", payload)
+            sys.publish("mqtt_payload", data, payload)
         elseif event == "sent" then
             log.info("mqtt", "sent", "pkgid", data)
         -- elseif event == "disconnect" then
@@ -96,7 +116,7 @@ sys.taskInit(function()
 	sys.waitUntil("mqtt_conack")
     while true do
         -- mqttc自动处理重连
-        local ret, topic, data, qos = sys.waitUntil("mqtt_pub", 30000)
+        local ret, topic, data, qos = sys.waitUntil("mqtt_pub", 300000)
         if ret then
             if topic == "close" then break end
             mqttc:publish(topic, data, qos)
@@ -106,20 +126,38 @@ sys.taskInit(function()
     mqttc = nil
 end)
 
+-- 这里演示在另一个task里上报数据, 会定时上报数据,不需要就注释掉
 sys.taskInit(function()
-	local data = "123"
-	local qos = 1
+	local data = "123,"
+	local qos = 1 -- QOS0不带puback, QOS1是带puback的
     while true do
-        sys.wait(5000)
+        sys.wait(60000)
         if mqttc and mqttc:ready() then
-			-- mqttc:subscribe(topic)
-            local pkgid = mqttc:publish(topic1, data, qos)
-            local pkgid = mqttc:publish(topic2, data, qos)
-            local pkgid = mqttc:publish(topic3, data, qos)
-            -- 也可以通过sys.publish发布到指定task去
-            -- sys.publish("mqtt_pub", topic, data, qos)
+            local pkgid = mqttc:publish(pub_topic, data .. os.date(), qos)
+            -- local pkgid = mqttc:publish(topic2, data, qos)
+            -- local pkgid = mqttc:publish(topic3, data, qos)
+        end
+    end
+end)
+
+-- 以下是演示与uart结合, 简单的mqtt-uart透传实现,不需要就注释掉
+local uart_id = 1
+uart.setup(uart_id, 9600)
+uart.on(uart_id, "receive", function(id, len)
+    local data = ""
+    while 1 do
+        local tmp = uart.read(uart_id)
+        if not tmp or #tmp == 0 then
+            break
         end
+        data = data .. tmp
     end
+    log.info("uart", "uart收到数据长度", #data)
+    sys.publish("mqtt_pub", pub_topic, data)
+end)
+sys.subscribe("mqtt_payload", function(topic, payload)
+    log.info("uart", "uart发送数据长度", #payload)
+    uart.write(1, payload)
 end)