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/qe27 著作权归作者所有。请勿转载和采集!