用Python写一个连接mqtt的脚本
你可以使用paho-mqtt库来连接和交互MQTT代理。下面是一个使用Python编写的简单示例:
import paho.mqtt.client as mqtt
# 连接回调函数
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("连接成功")
client.subscribe("topic/test") # 订阅主题
else:
print("连接失败")
# 接收消息回调函数
def on_message(client, userdata, msg):
print(f"收到消息:{msg.topic} {str(msg.payload)}")
# 创建MQTT客户端
client = mqtt.Client()
# 设置连接回调函数
client.on_connect = on_connect
# 设置接收消息回调函数
client.on_message = on_message
# 设置用户名和密码(如果需要的话)
client.username_pw_set("username", "password")
# 连接MQTT代理
client.connect("broker.mqtt.com", 1883)
# 开始循环,保持连接
client.loop_forever()
你需要将broker.mqtt.com更改为你的MQTT代理的主机名或IP地址,以及适当设置用户名和密码(如果代理要求身份验证)。这个脚本将连接到MQTT代理并订阅topic/test主题。当收到消息时,它将打印消息的主题和有效负载
原文地址: https://www.cveoy.top/t/topic/ixMn 著作权归作者所有。请勿转载和采集!