使用Django时如何处理mqtt loop_forever函数？

Question

我正在一个网站上工作,并使用Django进行开发.我有一些使用MQTT与网站通信的设备,我计划使用paho-mqtt客户端.我的问题是,对于paho-mqtt来说,我必须调用一个永远循环的函数,而paho-mqtt继续监听消息.让这个循环调用并包含在它自己的线程中的最佳方法是什么？

我可以创建一个新线程,还是应该使用像芹菜这样的东西？

Answer 1

改用 paho-mqtt 的线程接口。这将启动一个后台线程来处理网络处理，并且可以使用loop_start(). 或者，您可以创建自己的线程并调用loop()自己。