Changes for page 2 Script
Last modified by Devin Chen on 2025/06/06 14:03
Summary
-
Page properties (1 modified, 0 added, 0 removed)
Details
- Page properties
-
- Content
-
... ... @@ -465,8 +465,9 @@ 465 465 466 466 (% class="mark" %)2.If your server requires SSL certificate to log in,please use OpenCloud.Because only OpenCloud platform can support to upload certificate 467 467 468 - (% class="wikigeneratedid" %)468 +{{info}} 469 469 **✎Note: **Before program the script of MQTT, please make sure the server(MQTT broker) can be connected through MQTT Client tool. 470 +{{/info}} 470 470 471 471 (% class="wikigeneratedid" %) 472 472 Tool link: **[[MQTT.fx>>http://mqttfx.jensd.de/index.php/download]]** ... ... @@ -514,9 +514,13 @@ 514 514 --initialize mqtt 515 515 function mqtt_init() 516 516 print(string.format("mqtt init mqtt_url:%s mqtt_clientid:%s", MQTT_URL, MQTT_CLIENT_ID)) 518 + if g_mq then 519 + mqtt.close() --Close mqtt object 520 + end 517 517 g_mq, err = mqtt.create(MQTT_URL, MQTT_CLIENT_ID) -- create mqtt object,and declare it as a global variable 518 518 if g_mq then 519 519 g_mq:on("message", mqtt_msg_callback) -- Register a callback for receiving messages 524 + g_mq:on("offline", mqtt_msg_offline) -- Register a callback for offline 520 520 print("mqtt init success") 521 521 else 522 522 print("mqtt init failed:", err) ... ... @@ -536,6 +536,11 @@ 536 536 g_mq:subscribe(SUBSCRIBE_TOPIC, 0) 537 537 end 538 538 544 +--Offline callback function 545 +function mqtt_msg_offline(cause) 546 + print("mqtt offline, cause:", cause) 547 +end 548 + 539 539 -- Received message callback function 540 540 function mqtt_msg_callback(topic, msg) 541 541 print("topic:", topic) ... ... @@ -574,9 +574,11 @@ 574 574 if g_mq:isconnected() then 575 575 send_data() 576 576 else 577 - --if exceed 20sec not connect, reconnect once578 - if os.time() - LAST_TIME > 20then587 + --if exceed 5 sec not connect, reconnect once 588 + if os.time() - LAST_TIME > 5 then 579 579 LAST_TIME = os.time() 590 + --reinitial the mqtt object 591 + mqtt_init() 580 580 --connect to mqtt or reconnect 581 581 mqtt_connect() 582 582 end