python创建mqtt子节点

要创建一个MQTT（Message Queuing Telemetry Transport）子节点，你需要：

1. 安装MQTT客户端库 - 你可以使用Python的paho-mqtt库来连接到MQTT代理服务器。

你可以使用以下命令安装paho-mqtt：

`pip install paho-mqtt`

2. 创建一个MQTT客户端实例 - 在创建MQTT客户端实例时，你需要指定一个唯一的客户端ID，并指定MQTT代理服务器的IP地址和端口号。

示例：

import paho.mqtt.client as mqtt

# 设置MQTT代理服务器的IP地址和端口号
MQTT_SERVER = "192.168.1.100"
MQTT_PORT = 1883

# 创建MQTT客户端实例
client = mqtt.Client(client_id="python_subscriber")
client.connect(MQTT_SERVER, MQTT_PORT)

3. 订阅主题 - 你需要订阅你想要接收消息的MQTT主题。你可以使用以下命令进行订阅：

client.subscribe("mytopic")

4. 处理接收到的消息 - 当你的MQTT客户端实例接收到消息时，它会调用一个回调函数来处理这些消息。你需要编写一个回调函数来处理接收到的消息。

使用以下命令设置回调函数：

def on_message(client, userdata, message):
    print("Received message: " + str(message.payload.decode("utf-8")))

client.on_message = on_message

5. 启动MQTT客户端实例 - 最后，你需要使用以下命令启动MQTT客户端实例并开始接收消息：

client.loop_forever()

完整的示例代码：

import paho.mqtt.client as mqtt

# 设置MQTT代理服务器的IP地址和端口号
MQTT_SERVER = "192.168.1.100"
MQTT_PORT = 1883

# 创建MQTT客户端实例
client = mqtt.Client(client_id="python_subscriber")
client.connect(MQTT_SERVER, MQTT_PORT)

# 订阅主题
client.subscribe("mytopic")

# 回调函数处理接收到的消息
def on_message(client, userdata, message):
    print("Received message: " + str(message.payload.decode("utf-8")))

client.on_message = on_message

# 启动MQTT客户端实例
client.loop_forever()