优化

udp_ocr_conter/config.json

@@ -1,5 +1,5 @@
 {
-  "udpip": "127.0.0.1",
+  "udpip": "192.168.20.238",
   "udpport": "1990",
   "dbsize": "5",
   "mongodb_ip": "192.168.3.207:27081",
@@ -9,5 +9,8 @@
   "json_sidfiled": "gtid",
   "json_eidfiled": "lteid",
   "toudpip": "127.0.0.1",
-  "toudpport": "1481"
+  "toudpport": "1481",
+  "broadcast": false,
+  "broadcast_ips": "127.0.0.1;192.168.1.2;192.168.1.3;192.168.1.4",
+  "broadcast_port": 1490
 }

udp_ocr_conter/main.go

@@ -38,6 +38,16 @@ func main() {
 	udpclient = mu.UdpClient{Local: Sysconfig["udpip"].(string) + ":" + Sysconfig["udpport"].(string), BufSize: 1024}
 	udpclient.Listen(processUdpMsg)
 	log.Printf("Udp listening port: %s:%s\n", Sysconfig["udpip"], Sysconfig["udpport"])
+	if Sysconfig["broadcast"].(bool){//重启的话通知分布式节点
+		ips := qu.ObjToString(Sysconfig["broadcast_ips"])
+		ipsArr := strings.Split(ips, ";")
+		for _,v := range ipsArr{
+			udpclient.WriteUdp([]byte{},mu.OP_NOOP,&net.UDPAddr{
+				IP:   net.ParseIP(v),
+				Port: qu.IntAll(Sysconfig["broadcast_port"]),
+			})
+		}
+	}
 	b := make(chan bool, 1)
 	<-b
 }