MQTT循环发消息脚本

MQTT (Message Queuing Telemetry Transport) 是一种轻量级的发布/订阅式的消息协议，常用于物联网(IoT)设备之间的通信。如果你想编写一个简单的MQTT循环发送消息的脚本，通常会涉及以下几个步骤：

1. **安装依赖库**：首先需要安装Python的paho-mqtt客户端库，可以使用pip来安装：

   pip install paho-mqtt

2. **初始化连接**：

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("Connected to MQTT broker")
    else:
        print("Connection failed with code:", rc)

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

3. **设置主题和消息**：

topic = "your/topic"
message = "Your message here"

4. **连接并开始循环发送**：

client.connect("your_broker_address", port=1883, keepalive=60)  # 替换为你的MQTT服务器地址和端口

while True:
    client.publish(topic, message)
    time.sleep(5)  # 每隔5秒发送一次，你可以调整这个时间间隔

5. **断开连接**：

# 当你需要停止发送时，添加以下部分关闭连接
client.disconnect()
print("Disconnected from MQTT broker")

请注意，这只是一个基本的示例，实际应用中可能还需要处理异常、用户输入等。