实例释放

udpfileocr/main.go

@@ -90,7 +90,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 		}
 		if qu.ObjToString(mapInfo["permission"]) != "ocr_task" {
 			log.Println("数据异常 :", string(data), ra.String())
-			if qu.ObjToString(mapInfo["permission"]) == "stop"{
+			if qu.ObjToString(mapInfo["permission"]) == "stop" {
 				log.Println(mapInfo)
 				panic("释放实例")
 			}
@@ -150,13 +150,10 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 		log.Println("接收成功", string(data))
 	case mu.OP_DELETE_DOWNLOADERCODES:
 		log.Println(string(data))
-		go func() {
-			time.Sleep(time.Minute * 1)
-			udpclient.WriteUdp([]byte(`{"permission":"stop"}`), mu.OP_TYPE_DATA, &net.UDPAddr{
-				IP:   net.ParseIP(Sysconfig["udpip"].(string)),
-				Port: qu.IntAll(Sysconfig["udpport"].(string)),
-			})
-		}()
+		udpclient.WriteUdp([]byte(`{"permission":"stop"}`), mu.OP_TYPE_DATA, &net.UDPAddr{
+			IP:   net.ParseIP(Sysconfig["udpip"].(string)),
+			Port: qu.IntAll(Sysconfig["udpport"].(string)),
+		})
 	}
 
 }