msg MQTT message

smp_coder/extur_smp.py

@@ -27,12 +27,16 @@ def on_message(client, userdata, msg):
 
 	if msg.payload.decode() == "image produce": # 收到拍照请求
 		# 打开相机，拍照，保存图片，发送图片
-		if not os.path.exists("/tmp/image.jpg"):
-			os.system("bash smp_coder/camera.sh")
+		os.system("bash smp_coder/camera.sh")
 
-		else:
-			client.publish("response/{}".format(user_id), "image produce success!", qos=2)
-			client.publish("image/{}".format(user_id), open("/tmp/image.jpg", "rb").read(), qos=2)
+
+		client.publish("response/{}".format(user_id), "image produce success!", qos=2)
+		client.publish("image/{}".format(user_id), open("/tmp/image.jpg", "rb").read(), qos=2)
+
+	if msg.payload.decode() == "exit": # 收到退出请求
+		client.publish("response/{}".format(user_id), "exit success!", qos=2)
+		client.loop_stop()
+		client.disconnect()
 		# 全局变量，用于标记是否收到响应
 
 # 创建客户端实例