我是 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

谢谢。

最佳答案

您可以在通话之间休眠:

import mosquitto
import time # import time module
mqttc=mosquitto.Mosquitto("ioana")
mqttc.connect("127.0.0.1",8000,60,True)
mqttc.subscribe("test/", 2)
while mqttc.loop() == 0:
    mqttc.publish("test","Hello")
    time.sleep(10)# sleep for 10 seconds before next call

关于python - 每 10 秒发布一条消息 mqtt,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/23909292/

10-12 19:33