在 MQTT 客户端中持续运行代码部分的解决方案？

Question

我正在尝试通过 mqtt 连接向我发送一条消息，然后对收件箱中收集的收到的消息执行一项任务。问题是当我运行代码时，消息还没有被接收到，代码中对消息中的信息起作用的部分没有再次运行。

我曾考虑为该位使用while True: 循环，但随后根本无法访问 mqtt 脚本。这不起作用。

这可能是一个非常基础的问题，但是我怎样才能实现连续运行 mqtt 客户端并在稍后的某个时间处理收集到的消息呢？

import paho.mqtt.client as client

hostname = 'test.mosquitto.org'
topic = "personal/topic"

# receiving the data
inbox = []    

def on_message(client, userdata, msg):
    msg = msg.payload.decode()
    inbox.append(msg)
    print("Received Message No. %s:    %s" % (len(inbox), msg))    

def on_connect(client, userdata, flags, rc):
    print("Connection returned result: " + str(rc))
    client.subscribe(topic)

# this is where I want to perform a task on the message
y = []
X = []
for msg in inbox:
    label, data = msg.split(': ')
    data = data.split(', ')
    y.append(label)
    X.append(data)

# the mqtt part
client = client.Client()
client.on_message = on_message
client.on_connect = on_connect
client.connect(hostname)
client.loop_forever()

这是在脚本末尾使用client.loop_start()的构造（与@hardillb 的回答有关）：

# the mqtt part
client = client.Client()
client.on_message = on_message
client.on_connect = on_connect
client.connect(hostname)
client.loop_start()

while True:
    y = []
    X = []
    for msg in inbox:
        label, data = msg.split(': ')
        data = data.split(', ')
        y.append(label)
        X.append(data)

client.disconnect()
client.loop_stop()

Answer 1

paho 客户端可以使用client.loop_start() 函数在单独的线程上启动它的网络工作者。

之后您可以开始自己的处理循环，但on_message 回调函数将在客户端的网络工作线程上运行，因此如果您想将传入消息排队以便稍后处理，您需要确保当您以线程安全的方式存储消息。