msg MQTT message

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()

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,)