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

Question

我正在尝试连接到 DroneKit-SITL 并使用 loop_forever() 保持 MQTT-Broker 运行。每当我通过 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()