if __name__=='__main__': try: ConnectWifi(SSID,PASSWORD) client = MQTTClient(CLIENT_ID, SERVER,1883,username,password,60) #create a mqtt client print(client) client.set_callback(sub_cb) #set callback client.connect() #connect mqtt client.subscribe(subscribe_TOPIC) #client subscribes to a topic i=0 while True: d.measure() t = d.temperature() h = d.humidity() time.sleep(0.5) mymessage='{"method":"thing.service.property.set","params":{"Humidity":%.1f,"temperature":%.1f},"version":"1.0.0"}'%(h,t) client.publish(topic=publish_TOPIC,msg= mymessage, retain=False, qos=0) print('temperature: {:.1f} °C,Humidity: {:.1f} %'.format(t,h)) client.wait_msg() time.sleep_ms(3) if t > 30: for tone in melody: freq = tones[tone] if freq: beeper.init(duty=1000, freq=freq) else: beeper.duty(0) utime.sleep_ms(400) beeper.duty(0) utime.sleep_ms(100) beeper.deinit() if AlarmSwitch == 1: yly.value(0) jm.value(0) else: yly.value(1) jm.value(1) except Exception as ex_results: print('exception1',ex_results) finally: if(client is not None): client.disconnect() wlan.disconnect() wlan.active(False)

这段代码使用 DHT11 传感器测量温湿度，并将数据发布到 MQTT 服务器上。同时，如果温度超过 30 度，蜂鸣器会发出警报声。如果接收到的 MQTT 消息中包含 AlarmSwitch 为 1，则会关闭一个 LED 和一个继电器。如果不是 1，则会打开它们。最后，无论是否出现异常，都会断开 MQTT 和 WiFi 连接。

相关问题

上面的代码如何实现MQTT的断线重连，请给出响应micropython代码

以下是一个基本的MQTT断线重连的Micropython代码示例：

import time
import network
from umqtt.simple import MQTTClient

# MQTT服务器的地址和端口
MQTT_SERVER = "mqtt.server.com"
MQTT_PORT = 1883

# MQTT客户端ID
MQTT_CLIENT_ID = "myclientid"

# MQTT主题
MQTT_TOPIC = "mytopic"

# MQTT用户名和密码
MQTT_USER = "myusername"
MQTT_PASSWORD = "mypassword"

# MQTT客户端实例
mqtt_client = None

# WiFi连接
wifi_ssid = "mywifissid"
wifi_password = "mywifipassword"

def connect_wifi():
    """连接WiFi"""
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    if not wlan.isconnected():
        print("Connecting to WiFi...")
        wlan.connect(wifi_ssid, wifi_password)
        while not wlan.isconnected():
            time.sleep(1)
    print("WiFi connected:", wlan.ifconfig())

def mqtt_callback(topic, msg):
    """MQTT消息回调函数"""
    print(topic, msg)

def connect_mqtt():
    """连接MQTT"""
    global mqtt_client
    mqtt_client = MQTTClient(MQTT_CLIENT_ID, MQTT_SERVER, MQTT_PORT, MQTT_USER, MQTT_PASSWORD)
    mqtt_client.set_callback(mqtt_callback)
    mqtt_client.connect()
    mqtt_client.subscribe(MQTT_TOPIC)

def main():
    """主函数"""
    connect_wifi()  # 连接WiFi
    connect_mqtt()  # 连接MQTT

    while True:
        try:
            mqtt_client.wait_msg()
        except OSError:
            print("MQTT connection lost. Reconnecting...")
            connect_mqtt()

if __name__ == "__main__":
    main()

在这个示例中，我们使用`MQTTClient.wait_msg()`方法来循环等待MQTT消息。如果发生连接丢失错误（`OSError`），则会打印一条消息，并尝试重新连接MQTT服务器。在重新连接之前，我们需要重新创建MQTT客户端实例，并重新订阅我们感兴趣的主题。