python mqtt订阅

要在 Python 中使用 MQTT 订阅消息，需要先安装 Python 的 MQTT 客户端库，比如 paho-mqtt。安装方法可以使用 pip 包管理器执行以下命令：

pip install paho-mqtt

安装完成后，可以编写 Python 代码来订阅 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(msg.topic+" "+str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect("broker.hivemq.com", 1883, 60)

client.loop_forever()

这个代码会连接到 HiveMQ 的公共 MQTT 代理，并订阅 `test/topic` 主题。当消息到达时，`on_message` 回调函数会被调用，打印出消息的主题和内容。整个程序会一直运行，直到手动停止。

相关问题

python mqtt 订阅回调

在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(msg.topic + " " + str(msg.payload))

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

# 设置连接成功回调函数
client.on_connect = on_connect

# 设置消息接收回调函数
client.on_message = on_message

# 连接MQTT代理服务器
client.connect("broker.hivemq.com", 1883, 60)

# 循环监听MQTT消息
client.loop_forever()

在上面的代码中，我们定义了两个回调函数：on_connect和on_message。on_connect函数在连接成功后被调用，我们在其中订阅了一个主题。on_message函数在接收到消息时被调用，我们在其中打印了接收到的消息。

最后，我们创建了一个MQTT客户端实例，设置了连接成功和消息接收回调函数，连接到MQTT代理服务器，并循环监听MQTT消息。

python取消mqtt订阅

取消MQTT订阅可以使用Paho MQTT客户端库中的unsubscribe()方法。该方法需要传入一个主题参数，表示要取消订阅的主题。下面是一个示例代码：

client.unsubscribe("topic")

其中，client是Paho MQTT客户端对象，"topic"是要取消订阅的主题。