【发布时间】:2019-11-03 16:23:11
【问题描述】:
您好,我有一个 mqtt 代理正在运行。我正在使用 paho-mqtt 从 python 连接到它。 代码
def on_connect(client, userdata, flags, rc):
if rc==0:
print("connected OK Returned code=",rc)
else:
print("Bad connection Returned code=",rc)
print("Subscribing to topic","data/#")
client.subscribe("data/#")
def on_disconnect(client, userdata, rc):
print("Client Got Disconnected")
if rc != 0:
print('Unexpected MQTT disconnection. Will auto-reconnect')
else:
print('rc value:' + str(rc))
broker_address="ip"
port = 'port'
print("creating new instance")
client = mqtt.Client(clean_session=True) #create new instance
client.on_connect = on_connect
client.on_message = on_message #attach function to callback
client.on_disconnect = on_disconnect
print("connecting to broker")
client.connect(broker_address, port=port,) #connect to broker
client.loop_forever() #stop the loop
我在多个脚本中使用相同的代码,连接到代理并订阅一个主题。当有 5-6 个脚本时,断开连接的频率较少。我有大约 12-13 个脚本连接到代理,并且断开连接的频率显着增加。脚本中的连接或其与代理有关的连接是否有问题。有人可以帮我解决这个问题吗?
【问题讨论】:
-
我们无法回答这个问题,您正在从
on_disconnect回调中丢弃任何有用的信息,并且您没有从代理处提供任何关于连接中断原因的信息。跨度>