你可以使用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主题。当收到消息时,它将打印消息的主题和有效负载

用Python写一个连接mqtt的脚本

原文地址: https://www.cveoy.top/t/topic/ixMn 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录