如何在Python中后台运行MQTT客户机？

Question

我正在尝试连接到DroneKit SITL，并使MQTT代理始终使用loop_forever（）运行。每当我通过MQTT收到消息时，我想通过dronekit python API向无人机发送命令。同时，我希望每隔5秒通过MQTT向其他客户机发送无人机数据。在

如何让dronekit sitl类和mqtt代理类彼此交互？它们应该在线程或进程中运行吗？在

Answer 1

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

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

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