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

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