---

panlei

2019-11-02 25e009c1e80bb1b3b69b83501dcbffd117e3e7e4

---

 labelFilter/req.go

@@ -11,6 +11,7 @@
    "nanomsg.org/go-mangos/transport/ipc"
    "nanomsg.org/go-mangos/transport/tcp"
    "ruleprocess/structure"
    "strings"
    "time"
)

@@ -71,10 +72,13 @@
        if ruleGroup.Enable { // 大规则开关开启状态
            for _, url := range ruleGroup.Urls {
                // 为每个url建立一个chan
                ch := make(chan *structure.ResultMsg,10)
                var urlCh = urlChan{url.Url,ch}
                urlChans = append(urlChans,urlCh)
                go GoPush(url.Url)
                if strings.Contains(url.Url,"114") {
                    ch := make(chan *structure.ResultMsg,10)
                    logger.Info("初始化信息：",ch)
                    var urlCh = urlChan{url.Url,ch}
                    urlChans = append(urlChans,urlCh)
                    go GoPush(url.Url)
                }
            }
        }
    }