以下是一个使用 Python 和 paho-mqtt 库创建一个简单的 MQTT 代理的示例代码,该代理将在本地指定端口搭建并持续接收发布的信息,支持消息订阅。

import paho.mqtt.client as mqtt

# 连接成功回调函数
def on_connect(client, userdata, flags, rc):
    print('Connected with result code ' + str(rc))
    # 订阅主题
    client.subscribe('test/topic')

# 接收消息回调函数
def on_message(client, userdata, msg):
    print('Received message: ' + msg.topic + ' ' + str(msg.payload))

# 创建MQTT客户端
client = mqtt.Client()

# 设置回调函数
client.on_connect = on_connect
client.on_message = on_message

# 连接代理服务器
client.connect('localhost', 1883, 60)

# 循环接收消息
client.loop_forever()

在这个示例代码中,我们使用 paho-mqtt 库创建了一个 MQTT 客户端。在 on_connect 回调函数中,我们订阅了一个名为 'test/topic' 的主题。在 on_message 回调函数中,我们打印出接收到的消息。

你可以将代理服务器的 IP 地址和端口号替换为你自己的 MQTT 代理服务器的地址和端口号。

运行这个示例代码后,它将连接到指定的 MQTT 代理服务器,并持续接收发布到 'test/topic' 主题的消息,并将其打印出来。你可以根据需要修改这个代码来实现更复杂的功能,比如增加更多的订阅主题或处理接收到的消息。

Python MQTT 代理示例:使用 paho-mqtt 创建本地代理

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

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