节点通知

udp_ocr_conter/config.json

@@ -8,13 +8,13 @@
   "mongodb_filefiled": "projectinfo",
   "json_sidfiled": "gtid",
   "json_eidfiled": "lteid",
-  "toudpip": "127.0.0.1",
-  "toudpport": "1481",
+  "toudpip": "172.17.146.148",
+  "toudpport": "1581",
   "broadcast": false,
   "broadcast_ips": "127.0.0.1;192.168.1.2;192.168.1.3;192.168.1.4",
   "broadcast_port": 1490,
   "http_port": "12345",
-  "cornstr": "* * * * * ?",
+  "cornstr": "0 0 0 1 1 ? ",
   "corntime_consuming": 300,
   "pernum": 5,
   "time_consuming_limit": 60,

udp_ocr_conter/main.go

@@ -231,8 +231,9 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 			go config.Udpclient.WriteUdp([]byte(`{"id":"`+qu.ObjToString(tmp["start"])+`","permission":"ocr_task","is_start":"true"}`), mu.OP_TYPE_DATA, ra) //起始位置
 			go config.Udpclient.WriteUdp([]byte(`{"id":"`+newId.(bson.ObjectId).Hex()+`","permission":"ocr_task"}`), mu.OP_TYPE_DATA, ra)                    //分发任务
 			totmp := make(map[string]string)
-			totmp["sid"] = qu.ObjToString(tmp[qu.ObjToString("start")])
-			totmp["eid"] = qu.ObjToString(tmp[qu.ObjToString(config.EidField)])
+			totmp["gtid"] = qu.ObjToString(tmp[qu.ObjToString("start")])
+			totmp["lteid"] = qu.ObjToString(tmp[qu.ObjToString(config.EidField)])
+			totmp["stype"] = "fujian"
 			tobyte, _ := json.Marshal(totmp)
 			go config.Udpclient.WriteUdp(tobyte, mu.OP_TYPE_DATA, &net.UDPAddr{
 				IP:   net.ParseIP(qu.ObjToString(config.Sysconfig["toudpip"])),

udp_ocr_conter/src/corntask/task_corn.go

@@ -49,16 +49,16 @@ var Auto = func() {
 			for tmpIid, _ := range cluster.CID {
 				ttt := mongodb.FindOne("ocr_ecs", bson.M{"InstanceId": tmpIid})
 				log.Println("5分钟后释放实例", tmpIid)
-				config.Udpclient.WriteUdp([]byte("5分钟后释放实例"), mu.OP_DELETE_DOWNLOADERCODES, &net.UDPAddr{
-					IP:   net.ParseIP(util.ObjToString((*ttt)["ip_nw"])),
-					Port: util.IntAll(config.Sysconfig["broadcast_port"]),
-				})
-				go func(tmpIid string) {
+				go func(tmpIid string,ttt *map[string]interface{}) {
 					time.Sleep(time.Minute * 5)
+					config.Udpclient.WriteUdp([]byte("5分钟后释放实例"), mu.OP_DELETE_DOWNLOADERCODES, &net.UDPAddr{
+						IP:   net.ParseIP(util.ObjToString((*ttt)["ip_nw"])),
+						Port: util.IntAll(config.Sysconfig["broadcast_port"]),
+					})
 					mongodb.Del("ocr_ecs", bson.M{"InstanceId": tmpIid})
 					cluster.DeleteInstance(tmpIid)
 					log.Println("5分钟后释放实例完成", tmpIid)
-				}(tmpIid)
+				}(tmpIid,ttt)
 			}
 		} else {
 			var tmpnum int
@@ -69,16 +69,16 @@ var Auto = func() {
 				tmpIid := k
 				ttt := mongodb.FindOne("ocr_ecs", bson.M{"InstanceId": tmpIid})
 				log.Println("5分钟后释放实例", tmpIid)
-				config.Udpclient.WriteUdp([]byte("5分钟后释放实例"), mu.OP_DELETE_DOWNLOADERCODES, &net.UDPAddr{
-					IP:   net.ParseIP(util.ObjToString((*ttt)["ip_nw"])),
-					Port: util.IntAll(config.Sysconfig["broadcast_port"]),
-				})
-				go func(tmpIid string) {
+				go func(tmpIid string,ttt *map[string]interface{}) {
 					time.Sleep(time.Minute * 5)
+					config.Udpclient.WriteUdp([]byte("5分钟后释放实例"), mu.OP_DELETE_DOWNLOADERCODES, &net.UDPAddr{
+						IP:   net.ParseIP(util.ObjToString((*ttt)["ip_nw"])),
+						Port: util.IntAll(config.Sysconfig["broadcast_port"]),
+					})
 					mongodb.Del("ocr_ecs", bson.M{"InstanceId": tmpIid})
 					cluster.DeleteInstance(tmpIid)
 					log.Println("5分钟后释放实例完成", tmpIid)
-				}(tmpIid)
+				}(tmpIid,ttt)
 				tmpnum--
 			}
 		}