labelFilter/req.go
@@ -72,10 +72,9 @@ for _, url := range ruleGroup.Urls { // 为每个url建立一个chan if !strings.Contains(url.Url,"116") { ch := make(chan []byte,10) urlPool[url.Url] = ch logger.Info("初始化信息:",ch,urlPool) if strings.Contains(url.Url,"102") { urlPool[url.Url] = make(chan []byte,10) logger.Info("初始化信息:",urlPool) go GoPush(url.Url) } } @@ -125,7 +124,7 @@ // ch = v.ch // } //} //logger.Info("chan信息:",ch) logger.Info("chan信息:",urlPool[url]) for { select { // case <-ctx.Done():