mqtt连接代码示例

当然，这里是一个简单的MQTT连接代码示例，你可以参考：

import paho.mqtt.client as mqtt

# 定义回调函数，用于处理连接成功和接收消息
def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("Connected to MQTT broker!")
    else:
        print("Failed to connect, return code %d\n", rc)

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

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

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

# 设置MQTT服务端地址和端口号
broker_address = "mqtt.example.com"
port = 1883

# 连接到MQTT代理
client.connect(broker_address, port=port)

# 订阅主题
client.subscribe("topic/example")

# 保持连接
client.loop_forever()

请确保在运行代码之前安装了 paho-mqtt 库（`pip install paho-mqtt`）。这个例子使用了 `paho-mqtt` 库来实现MQTT连接和消息处理。你需要将 `broker_address` 更改为你实际使用的MQTT代理地址，以及根据需求修改其他设置。