备份...

sensitive/src/main.go

@@ -10,10 +10,9 @@ func init() {
 	ul.InitC()
 }
 func main() {
-	go ul.AddTaskSensitiveWordsData() //增量-新增
-	ul.SentiveUdp()                   //数据流程-增量
+	ul.SentiveUdp() //数据流程-增量
+	//go ul.AddTaskSensitiveWordsData() //词库增量-
 	//ul.TestData() //临时测试数据
-
 	lock := make(chan bool)
 	<-lock
 }

sensitive/src/util/udpdata.go

@@ -20,7 +20,7 @@ var udpclient mu.UdpClient //udp对象
 var nextNodes []map[string]interface{}
 var specReg *regexp.Regexp = regexp.MustCompile("(,|，)")
 
-//udp通知抽取
+// udp通知抽取
 func SentiveUdp() {
 	nextNodes = qu.ObjArrToMapArr(Sysconfig["nextNode"].([]interface{}))
 	updport := Sysconfig["udpport"].(string)
@@ -32,7 +32,7 @@ func SentiveUdp() {
 
 var syc sync.WaitGroup
 
-//udp接收
+// udp接收
 func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 	task <- struct{}{}
 	defer func() {
@@ -62,14 +62,13 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 			log.Println("Udp回应上节点~id段")
 			QuerySensitiveWords(sid, eid)
 			log.Println("...计划发送udp~统计下一节点...")
-			//
 		}
 	case mu.OP_NOOP: //下个节点回应
 		log.Println(string(data))
 	}
 }
 
-//处理方法
+// 处理方法
 func QuerySensitiveWords(sid, eid string) {
 	log.Println("开始处理敏感词匹配:", sid, "~", eid)
 	q := map[string]interface{}{