send数据用协程

panlei

2019-11-04 516d94938f664e71dd323426221b535d5e92881b

send数据用协程

 labelFilter/req.go

@@ -135,24 +135,25 @@
        case data := <- urlPool[url]:
            //logger.Info("接收到数据",data.Cid)
            //bytes,err1 := proto.Marshal(data)
            logger.Info("数据长度为：",len(data))
            //if err1 != nil {
            //    logger.Info("序列化失败：",err1)
            //}
            start := time.Now()
            logger.Debug("groutine"+url+"推送数据")
            //bytes := []byte("ndfasojdfaidsos")
            if err = sock.Send(data); err != nil {
                Die("groutine"+url+"推送socket发送数据失败: ", err.Error())
            }
            pushTime := time.Since(start)
            msg, err = sock.Recv();
            if err != nil {
                Die("groutine"+url+"接收响应失败: ", err.Error(),pushTime,time.Since(start))
            } else {
                logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg),pushTime,time.Since(start))
            }

            go func(data []byte) {
                logger.Info("数据长度为：",len(data))
                //if err1 != nil {
                //    logger.Info("序列化失败：",err1)
                //}
                start := time.Now()
                logger.Debug("groutine"+url+"推送数据")
                //bytes := []byte("ndfasojdfaidsos")
                if err = sock.Send(data); err != nil {
                    Die("groutine"+url+"推送socket发送数据失败: ", err.Error())
                }
                pushTime := time.Since(start)
                msg, err = sock.Recv();
                if err != nil {
                    Die("groutine"+url+"接收响应失败: ", err.Error(),pushTime,time.Since(start))
                } else {
                    logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg),pushTime,time.Since(start))
                }
            }(data)
        default:

        }