python - 使用 Paho MQTT 在 Python 中订阅 MQTT 时出现线程问题

Question

我有一个 python 程序，它监听 MQTT 主题并需要处理消息。我从命令行指定了一些参数来以不同方式评估消息。

import argparse
import datetime
import json

import paho.mqtt.client as mqtt

### MQTT Functions
def on_connect(mqttc, obj, flags, rc):
    print("Connected! - " + str(rc))

def on_message(mqttc, obj, msg):
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))

def on_publish(mqttc, obj, mid):
    print("Published! "+str(mid))

def on_subscribe(mqttc, obj, mid, granted_qos):
    print("Subscribed! - "+str(mid)+" "+str(granted_qos))

def on_log(mqttc, obj, level, string):
    print(string)

if __name__ == "__main__":
    # Handle args
    parser = argparse.ArgumentParser(
        description='This is to be usedin conjunction with the WifiScanner on a Raspberry Pi')
    parser.add_argument('--topic', metavar='base/sub', type=str, nargs='?', help='Full topic to listen to. (Example "proximity/sensor")', default="proximity/#")
    parser.add_argument('--host', metavar='url', type=str, nargs='?',
                        help='UQL of MQTT server.')
    parser.add_argument('--graph', metavar='True/False', type=bool, nargs='?', help='Whether to print the data.', default=True)
    parser.add_argument('--timeout', metavar='sec', type=int, nargs='?', help='How long the device will be remembered', default=10)
    args = parser.parse_args()
    # MQTT
    mqttc = mqtt.Client()
    # mqttc.on_message = on_message
    mqttc.on_connect = on_connect
    mqttc.on_publish = on_publish
    mqttc.on_subscribe = on_subscribe
    # Uncomment to enable debug messages
    #mqttc.on_log = on_log
    mqttc.connect(args.host, 1883, 60)
    mqttc.subscribe(args.topic, 0)
    # Start to listen    
    while True:
        print mqttc.loop()

这个问题是，我看不到将命令行参数传递给 on_message 回调的简单方法。所以我尝试使用 .loop 的返回值。但是，当我尝试使用 Ctrl+Z 退出时(只有键盘中断有效)，它不会退出 MQTT 线程并让它们继续运行。

文档和示例没有关于如何处理 on_message 回调之外的消息以及如何干净退出的示例。

因此，非常感谢任何解决此问题的帮助。

提前致谢

Answer 1

您可以使用 Client() 构造函数中的 userdata 参数。它最终被传递给每个回调。