[esp32]ESP8266使用micropython连接MQTT控制家电

import network
import time
from machine import Pin
from umqtt.simple import MQTTClient
import usocket as socket

status = 'run'
server = "192.168.0.10"
port = 1883
ClientId = "0"
TOPIC = b"iot_eps32_001"
username = 'iot'
password = 'passwd'
# 继电器
g0 = Pin(0, Pin.OUT, value=0)
# 指示灯
g2 = Pin(2, Pin.OUT, value=0)
client = None

print("clientid:", ClientId, "\n", "Broker:", server, "\n", "User Name:", username, "\n", "Password:", password, "\n")


def do_connect():
    sta_if = network.WLAN(network.STA_IF)
    ap_if = network.WLAN(network.AP_IF)
    if ap_if.active():
        ap_if.active(False)
    if not sta_if.isconnected():
        print('connecting to network...')
    sta_if.active(True)
    sta_if.connect('wifissid', 'wifipasswd')  # wifi的SSID和密码
    while not sta_if.isconnected():
        pass
    print('network config:', sta_if.ifconfig())
    return


def sub_cb(topic, msg):
    global client, status
    topic = topic.decode('utf-8')
    msg = msg.decode('utf-8')
    print(topic, ':', msg)
    if topic == 'iot_eps32_001':
        if msg == 'close':
            status = 'close'
            # client.disconnect()
            return
        elif msg == 'test':
            g2.on()
            time.sleep(1)
            g2.off()
            time.sleep(2)
            g2.on()
            time.sleep(1)
            g2.off()
            time.sleep(2)
            g2.on()
        elif msg == 'on':
            g0.on()
        elif msg == 'off':
            g0.off()
        pass
    return


def connect():
    global client
    client = MQTTClient(client_id=ClientId, server=server, port=port, user=username, password=password, keepalive=60)
    # please make sure keepalive value is not 0
    client.set_callback(sub_cb)
    client.connect()
    print(client, status)
    client.subscribe(TOPIC)
    print("Connected to %s, subscribed to %s topic" % (server, TOPIC))

    while status == 'run':
        client.wait_msg()
        time.sleep(0.01)
        pass
    client.disconnect()
    return


if __name__ == '__main__':
    do_connect()
    connect()