python - 如何在Python中后台运行MQTT客户端？

Question

我正在尝试连接到 DroneKit-SITL 并保持 MQTT-Broker 使用loop_forever() 运行。每当我通过 MQTT 收到消息时，我想通过 Dronekit Python API 向无人机发送命令。同时，我想每 5 秒通过 MQTT 向其他客户端发送一次无人机数据。

如何让我的 dronekit-sitl-class 和 mqtt-broker-class 相互交互？它们每个都应该在线程或进程中运行吗？

Answer 1

我通过在单独的线程中运行循环解决了这个问题，如下所示:

clientloop_thread = Thread(target=self.connect)
clientloop_thread.start()

def connect(self):
    self._client.loop_forever()