---

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,7 +72,9 @@
        if ruleGroup.Enable { // 大规则开关开启状态
            for _, url := range ruleGroup.Urls {
                // 为每个url建立一个chan
                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)
@@ -79,6 +82,7 @@
        }
    }
}
}

func GoPush(url string) {
    var err error