Example: 09-WiFi/mqtt_sub.py

# 本作品采用MIT许可证授权。
# 版权所有 (c) 2013-2023 OpenMV LLC。保留所有权利。
# https://github.com/openmv/openmv/blob/master/LICENSE
#
# MQTT 示例。
# 此示例展示了如何使用 MQTT 库订阅主题。
#
# 1) 将 mqtt.py 库复制到 OpenMV 存储中。
# 2) 在 OpenMV 摄像头上运行此脚本。
# 3) 在 PC 上安装 mosquitto 客户端并运行以下命令：
#    mosquitto_pub -t "openmv/test" -m "Hello World!" -h test.mosquitto.org -p 1883
#
# 注意：如果 mosquitto 代理无法访问，请尝试另一个代理（例如：broker.hivemq.com 或 broker.emqx.io）

import time
import network
from mqtt import MQTTClient

SSID = ""  # 网络 SSID
KEY = ""  # 网络密钥

# 初始化wlan模块并连接到网络
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(SSID, KEY)

while not wlan.isconnected():
    print('Trying to connect to "{:s}"...'.format(SSID))
    time.sleep_ms(1000)

# 我们现在应该通过DHCP获得一个有效的IP地址
print("WiFi Connected ", wlan.ifconfig())

client = MQTTClient("openmv", "test.mosquitto.org", port=1883)
client.connect()


def callback(topic, msg):
    print(topic, msg)


# 必须先设置回调
client.set_callback(callback)
client.subscribe("openmv/test")

while True:
    client.check_msg()  # 轮询消息。
    time.sleep_ms(1000)