micropython下,如何使用mqtt对2个MQTT服务器发送和订阅消息
在 MicroPython 中使用 MQTT 连接到 MQTT 服务器并发送和订阅消息,你需要使用 umqtt.simple 模块。下面是一个示例代码,它将连接到一个 MQTT 服务器,然后订阅一个主题并在收到消息时打印出来。from umqtt.simple import MQTTClient# 创建 MQTTClient 实例,并指定它的名称、服务器地址和端口号client = MQT...
·
在 MicroPython 中使用 MQTT 连接到 MQTT 服务器并发送和订阅消息,你需要使用 umqtt.simple 模块。下面是一个示例代码,它将连接到一个 MQTT 服务器,然后订阅一个主题并在收到消息时打印出来。
from umqtt.simple import MQTTClient
# 创建 MQTTClient 实例,并指定它的名称、服务器地址和端口号
client = MQTTClient("my_client", "mqtt.example.com", 1883)
# 连接到 MQTT 服务器
client.connect()
# 订阅一个主题
client.subscribe("my_topic")
# 定义一个回调函数,在收到消息时被调用
def on_message(topic, message):
print("收到消息:", topic, message)
# 设置回调函数
client.set_callback(on_message)
# 循环接收消息
while True:
client.wait_msg()
# 关闭连接
client.disconnect()
要向 MQTT 服务器发送消息,你可以使用 MQTTClient 的 publish() 方法。
# 发布一条消息
client.publish("my_topic", "Hello, World!")
如果你想连接到多个 MQTT 服务器,你可以创建多个 MQTTClient 实例,并对每个实例分别调用 connect() 和相应的 publish() 和 subscribe() 方法。
更多推荐
所有评论(0)