例程讲解14-mqtt_sub mqtt订阅

# MQTT示例
# 这个示例展示了如何使用MQTT库订阅主题。
#
# 1) 将mqtt.py库复制到OpenMV存储。
# 2）在OpenMV相机上运行这个脚本。
# 3) 将mosquito客户端安装在PC上，并运行以下命令:
#    mosquitto_pub -t "openmv/test" -m "Hello World!" -h test.mosquitto.org -p 1883
#
# 注意: 如果无法访问mosquito，请尝试另一个代理(例如:broker.hivemq.com)
import time, network
from mqtt import MQTTClient

SSID='' # Network SSID
KEY=''  # Network key

# 初始化wlan模块并连接到网络
print("Trying to connect... (may take a while)...")

wlan = network.WINC()
wlan.connect(SSID, key=KEY, security=wlan.WPA_PSK)

# 我们现在应该有一个通过DHCP的有效IP了
print(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)