python - 每 10 秒发布一条消息 mqtt

Question

我是 mqtt 的新手，仍在探索这个有趣的协议(protocol)。我想在 python 中创建一个客户端，每 10 秒发布一条消息。到现在为止，我只成功发布了一条消息并保持客户端与代理的​​连接。

如何使发布部分成为一个循环？

下面是我的客户:

import mosquitto
mqttc=mosquitto.Mosquitto("ioana")
mqttc.connect("127.0.0.1",1884,60,True)
mqttc.publish("test","Hello")
mqttc.subscribe("test/", 2)

while mqttc.loop() == 0:
pass

谢谢。

Answer 1

我建议:

import paho.mqtt.client as mqtt # mosquitto.py is deprecated
import time

mqttc = mqtt.Client("ioana")
mqttc.connect("127.0.0.1", 1883, 60)
#mqttc.subscribe("test/", 2) # <- pointless unless you include a subscribe callback
mqttc.loop_start()
while True:
    mqttc.publish("test","Hello")
    time.sleep(10)# sleep for 10 seconds before next call