---

panlei

2019-11-01 5411f87f32c95adea29ca0b3763d8dd3857b96f0

---

 labelFilter/req.go

@@ -4,7 +4,6 @@
    "basic.com/dbapi.git"
    "basic.com/valib/logger.git"
    "fmt"
    "github.com/golang/protobuf/proto"
    "nanomsg.org/go-mangos"
    "nanomsg.org/go-mangos/protocol/rep"
    "nanomsg.org/go-mangos/protocol/req"
@@ -115,12 +114,12 @@
        // case <-ctx.Done():
        //     return
        case data := <- urlPool[url]:

            bytes,err1 := proto.Marshal(data)
            logger.Info("数据长度为：",len(bytes))
            if err1 != nil {
                logger.Info("序列化失败：",err1)
            }
            logger.Info("接收到数据",data.Cid)
            //bytes,err1 := proto.Marshal(data)
            //logger.Info("数据长度为：",len(bytes))
            //if err1 != nil {
            //    logger.Info("序列化失败：",err1)
            //}
            //logger.Debug("groutine"+url+"推送数据")
            ////bytes := []byte("ndfasojdfaidsos")
            //if err = sock.Send(bytes); err != nil {

 labelFilter/ruleForLabel.go

@@ -320,7 +320,7 @@
func pushData(urls []*protomsg.PushUrl, data structure.ResultMsg) {
    for _, url := range urls {
        logger.Debug("看看推送地址：",url.Url)
        //urlPool[url.Url] <- data
        urlPool[url.Url] <- data
    }
}