时间戳

首页 > 解决方案 > 互联网断开连接上的 Paho mqtt 未运行回调

python - 互联网断开连接上的 Paho mqtt 未运行回调

问题描述

我有这个 mqtt 类

class MQTT():
    def __init__(self):
        # Observer.__init__(self) # DON'T FORGET THIS

        self.mqttClient = paho.Client(client_id=constants.MQTT_CLIENT_ID)
        self.mqttClient.username_pw_set(username=constants.MQTT_BROKER_USERNAME, password=constants.MQTT_BROKER_PASSWORD)

        # assign mqtt event callbacks
        self.mqttClient.on_message = self.on_message
        self.mqttClient.on_connect = self.on_connect
        self.mqttClient.on_disconnect = self.on_disconnect
        self.mqttClient.on_socket_close = self.on_disconnect
        self.mqttClient.on_log = self.on_log

   def on_disconnect(self,client, userdata, rc):
        log("MQTT DISCONNECT:",client, userdata, rc)

进而

mqtt = MQTT()

如果我运行我的代码，它可以完美运行，但是当互联网连接丢失时，我必须运行一些功能。因此，我正在使用on_disconnect并且在运行代码之后如果网络没有任何反应。我希望一些回叫在 Internet 连接丢失时运行。我们有吗？

标签： pythonmqttpaho

解决方案

on_disconnect是正确的回调 - 问题是它何时被调用？

如果网络连接丢失，您的客户端只会在下一次尝试传输时注意到它。因此，如果客户端不打算发布某些内容（或确认在连接断开之前收到的订阅），下一个传输将是PINGREQ

默认keepalive设置为- 这意味着如果在此时间间隔内没有发送其他控制包60，您的客户端将每 60 秒发送一次。PINGREQ

所以on_disconnect回调将被调用，它只是没有像你预期的那么快发生。尝试降低keepalive以改善这一点

推荐阅读