labelFilter/req.go
@@ -11,6 +11,7 @@ "nanomsg.org/go-mangos/transport/ipc" "nanomsg.org/go-mangos/transport/tcp" "ruleprocess/structure" "strings" "time" ) @@ -67,12 +68,14 @@ if ruleGroup.Enable { // 大规则开关开启状态 for _, url := range ruleGroup.Urls { // 为每个url建立一个chan if strings.Contains(url.Url,"114") { urlPool[url.Url] = make(chan structure.ResultMsg) go GoPush(url.Url) } } } } } func GoPush(url string) { var err error