如何退出mqtt forever_loop？

Question

我最近创建了一个接收数据的程序。

当我收到特定数据时，我想打破循环。

例如，如果我收到“1”到另一台机器，那么我的系统会将其视为非法编号，然后它会中断循环以停止接收数据。

这是我在下面的代码，你也可以在我的代码中看到client.loop_stop()。但它不起作用。

我也在我的代码中尝试过sys.exit()。

虽然它适用于这种情况，但它不适合在其他情况下使用。

所以我想知道如何打破客户端的循环，我不想通过sys.exit()关闭整个系统。

import paho.mqtt.client as mqtt
# This is the Subscriber
a=""
def on_connect(client, userdata, flags, rc):
  print("Connected with result code "+str(rc))
  client.subscribe("hello")

def on_message(client, userdata, msg):
    info=msg.payload.decode()
    print info
    if str(info)=='1':
      print "OK"
      client.loop_stop()


client = mqtt.Client()
client.connect("myIp",1883,60)

client.on_connect = on_connect
client.on_message = on_message
client.loop_forever()

Answer 1

为了阻止loop_forever，你必须使用client.disconnect，而不是loop_stop。