BPI-Pico-RP2040 開發板 mqtt連接服務器

?1、安裝umqtt，點擊菜單工具->管理包

2、搜索umqtt

3、在查找結果里面點擊按裝：

4、然后在已安裝的包里就看到umqtt了。

5、書如程序代碼如下：

from umqtt.simple import MQTTClient
from machine import Pin
import network
import time

ssid='ssid'
passwd='wifipwd'
client_id = "po20t"
mserver = 'ip'
port=1883
mqttuser = "user"
mqttpwd = "pwd"
topic_ctl = b'led_ctl'#設備訂閱的主題,客戶端推送消息的主題
topic_sta = b'led_sta'#客戶端訂閱的主題,設備推送消息的主題
client = None
wlan = None

led1=Pin(2, Pin.OUT, value=1)
led2=Pin(5, Pin.OUT, value=1)
    
def sub_callback(topic, msg):
    """
    收到訂閱消息回調
    """
    global client
    print((topic_ctl, msg))
    if msg == b'led1 ON' or msg == b'led1 on':
        pub_msg = 'LED1: ON-state'
        led1.value(0)
    elif msg == b'led1 OFF' or msg == b'led1 off':
        pub_msg = 'LED1: OFF-state'
        led1.value(1)
    elif msg == b'led2 ON' or msg == b'led2 on':
        pub_msg = 'LED2: ON-state'
        led2.value(0)
    elif msg == b'led2 OFF' or msg == b'led2 off':
        pub_msg = 'LED2: OFF-state'
        led2.value(1)
    else:
        pub_msg = 'other msg'
    client.publish(topic_sta, pub_msg, retain=True)

def connectWiFi():
    """
    連接到WiFi網絡
    """
    global wlan
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    wlan.disconnect()
    wlan.connect('HUAWEI-H10R9U', "18977381885@")
    while(wlan.ifconfig()[0]=='0.0.0.0'):
        time.sleep(1)
    print(wlan.ifconfig())

try:
    connectWiFi()
    client = MQTTClient(client_id, mserver, port=1883,user=mqttuser,password=mqttpwd)
    client.set_callback(sub_callback)
    client.connect()
    client.subscribe(topic_ctl)
    client.publish(topic_sta, 'ESP32 Device online', retain=True)
    print("Connected to %s, subscribed to %s topic" % (mserver, topic_ctl))
    while True:
        client.wait_msg()
finally:
    if client is not None:
        print('off line')
        client.disconnect()
    wlan.disconnect()
    wlan.active(False)

5、保存到開發板，然后執行：

6、打開mqttx發送消息：這樣連接到遠程的Mqtt就愉快的完成了，后面可以完成一些數據交換與控制了。

審核編輯：湯梓紅

?