send数据用协程

panlei

2019-11-04 516d94938f664e71dd323426221b535d5e92881b

send数据用协程

 labelFilter/req.go

@@ -135,6 +135,7 @@
        case data := <- urlPool[url]:
            //logger.Info("接收到数据",data.Cid)
            //bytes,err1 := proto.Marshal(data)
            go func(data []byte) {
            logger.Info("数据长度为：",len(data))
            //if err1 != nil {
            //    logger.Info("序列化失败：",err1)
@@ -152,7 +153,7 @@
            } else {
                logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg),pushTime,time.Since(start))
            }

            }(data)
        default:

        }