mqtt发送消息代码

当使用MQTT协议发送消息时，需要使用MQTT客户端库来实现。以下是一个使用Python语言的paho-mqtt库发送消息的示例代码：

import paho.mqtt.client as mqtt

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

# 接收消息回调函数
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("mqtt.example.com", 1883, 60)

# 循环处理网络流量，保持与MQTT代理服务器的通信
client.loop_start()

# 发布消息
client.publish("topic/test", "Hello, MQTT!")

# 断开连接
client.disconnect()

上述代码中，首先导入了paho-mqtt库，然后定义了连接成功和接收消息的回调函数。接着创建了一个MQTT客户端实例，并设置了回调函数。然后通过`connect()`方法连接到MQTT代理服务器，并通过`publish()`方法发布消息。最后通过`disconnect()`方法断开连接。