如何退出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。