小编Sag*_*gre的帖子

我尝试在python3中设置一个mqtt客户端。这不是我第一次这样做，但是我遇到了一个很奇怪的行为。尝试从其中一个回调函数（on_connect或on_message）调用包含错误的函数时，python不会引发异常（至少不打印异常），而只是在此停止。我把一个简短的例子捆绑在一起，再现了这种行为。

有人有主意吗？

import paho.mqtt.client as mqtt

import re
import os.path

import json
from termcolor import colored

client = mqtt.Client()

def func():
    test = 1 + "1"
    print("Should never reach that")

def on_connect(client, userdata, flags, rc):
    """Establishes connection to broker
    """
    print("Connected to broker with result code " + str(rc))
    client.subscribe("test")

def on_message(client,userdata,msg):
    print("Recieved message on " + msg.topic)
    params = {}
    if msg.topic == "test":

        print("Invoke func")
        func()

if __name__ == "__main__":
    client.on_connect = on_connect
    client.on_message = on_message

    client.connect("localhost",1883,60)

    client.loop_forever() …