使用python建立一个mqtt节点，要求能够订阅主题并接收该主题下的消息

首先需要安装MQTT库，可以使用paho-mqtt库。

安装方法：

pip install paho-mqtt

代码实现如下：

import paho.mqtt.client as mqtt

# 定义回调函数处理消息
def on_message(client, userdata, message):
    print(f"Received message: {str(message.payload.decode('utf-8'))}")
    print(f"From topic: {message.topic}")

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

# 定义回调函数
client.on_message = on_message

# 连接MQTT服务器
broker_address = "broker.hivemq.com"  # 采用公共MQTT测试服务器
client.connect(broker_address)

# 订阅主题
topic = "test_topic"
client.subscribe(topic)

# 循环等待消息
client.loop_forever()

这个程序会建立一个MQTT客户端，并连接到公共的MQTT测试服务器进行订阅，接收输入主题下的消息。用户可以替换公共测试服务器的地址为自己的MQTT服务器地址，然后运行程序，使用MQTT客户端订阅自己设定的主题，收到消息后会打印出消息内容和主题名称。

相关问题

使用python建立一个mqtt节点，并接收同一主题别的节点发布的消息

可以使用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))

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

client.connect("localhost", 1883, 60)

client.loop_forever()

这个代码会连接到本地的mqtt broker，并订阅名为"test/topic"的主题。当别的节点发布消息到这个主题时，on_message函数会被调用，并打印出消息的内容。

micropython下,如何使用mqtt对2个MQTT服务器发送和订阅消息

在 MicroPython 中使用 MQTT 连接到 MQTT 服务器并发送和订阅消息，你需要使用 umqtt.simple 模块。下面是一个示例代码，它将连接到一个 MQTT 服务器，然后订阅一个主题并在收到消息时打印出来。

from umqtt.simple import MQTTClient

# 创建 MQTTClient 实例，并指定它的名称、服务器地址和端口号
client = MQTTClient("my_client", "mqtt.example.com", 1883)

# 连接到 MQTT 服务器
client.connect()

# 订阅一个主题
client.subscribe("my_topic")

# 定义一个回调函数，在收到消息时被调用
def on_message(topic, message):
    print("收到消息:", topic, message)

# 设置回调函数
client.set_callback(on_message)

# 循环接收消息
while True:
    client.wait_msg()

# 关闭连接
client.disconnect()

要向 MQTT 服务器发送消息，你可以使用 MQTTClient 的 publish() 方法。

# 发布一条消息
client.publish("my_topic", "Hello, World!")

如果你想连接到多个 MQTT 服务器，你可以创建多个 MQTTClient 实例，并对每个实例分别调用 connect() 和相应的 publish() 和 subscribe() 方法。