diff --git a/edu_coder/extur_edu.py b/edu_coder/extur_edu.py index e1617c4..b170876 100644 --- a/edu_coder/extur_edu.py +++ b/edu_coder/extur_edu.py @@ -34,11 +34,9 @@ def on_message(client, userdata, msg): f.write(msg.payload) print("图片已保存。") - client.loop_stop() - client.disconnect() - # global response_received - # response_received = True + global response_received + response_received = True try: @@ -63,8 +61,8 @@ client.loop_start() response_received = False while not response_received: print("等待响应...") - time.sleep(1) client.publish("request/{}".format(user_id), "image produce", qos=2) + time.sleep(3) # 停止网络循环并断开连接 client.loop_stop() diff --git a/smp_coder/extur_smp.py b/smp_coder/extur_smp.py index c980704..2094ada 100644 --- a/smp_coder/extur_smp.py +++ b/smp_coder/extur_smp.py @@ -35,9 +35,10 @@ def on_message(client, userdata, msg): if msg.payload.decode() == "exit": # 收到退出请求 client.publish("response/{}".format(user_id), "exit success!", qos=2) - client.loop_stop() - client.disconnect() # 全局变量,用于标记是否收到响应 + global response_received + response_received = True + # 创建客户端实例 client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2,)