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