问题描述:
你好:
是这样的,用贵公司mqtt测试,服务器每25秒发出消息,中间是有重连,等了好一会才重新接受到数据,但跑了2天后,发现怎么也收不到数据,只有disconnect后重连才能有接受数据,谢谢!
还有一个问题,当贵公司掉线后,这些中间时间的消息就收不到了,而我用下面代码的运行,他会把中间数据一起推送过来,谢谢!
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
client.subscribe("SN123456789",1)
def on_log(client, userdata, l*l, buf):
print(buf)
def on_message(client, userdata, msg):
print("on_message: ", msg.p*load)
e = client.subscribe
client = mqtt.Client(client_id="huifu-client-*123", clean_session=False, userdata=None)
client.on_connect = on_connect
client.on_message = on_message
client.on_log = on_log
client.username_pw_set(username="topwise-huifu", password="huifu12345")
#r2 = client.connect("101.201.235.32", 1883, 60)
#client.username_pw_set(username="admin", password="admin")
#r2 = client.connect("10.20.31.199", 1883, 60)
r2 = client.connect("183.61.172.25", 1883, 20)
print(r2)
client.enable_logger()
r = client.loop_for*r()