labelFilter/req.go
@@ -73,9 +73,8 @@ // 为每个url建立一个chan if strings.Contains(url.Url,"114") { ch := make(chan []byte,10) urlPool[url.Url] = ch logger.Info("初始化信息:",ch,urlPool) 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():