---

panlei

2019-11-01 04fd16bc831ce3a247d92ad3529d20abd5ac4f46

---

 labelFilter/req.go

@@ -79,7 +79,7 @@

func GoPush(url string) {
    var err error
    var msg []byte
    //var msg []byte
    var sock mangos.Socket
    if sock, err = req.NewSocket(); err != nil {
        Die("创建请求socket失败: %s", err.Error())
@@ -121,17 +121,17 @@
            if err1 != nil {
                logger.Info("序列化失败：",err1)
            }
            logger.Debug("groutine"+url+"推送数据")
            //bytes := []byte("ndfasojdfaidsos")
            if err = sock.Send(bytes); err != nil {
                Die("groutine"+url+"推送socket发送数据失败: ", err.Error())
            }
            msg, err = sock.Recv();
            if err != nil {
                Die("groutine"+url+"接收响应失败: ", err.Error())
            } else {
                logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg))
            }
            //logger.Debug("groutine"+url+"推送数据")
            ////bytes := []byte("ndfasojdfaidsos")
            //if err = sock.Send(bytes); err != nil {
            //    Die("groutine"+url+"推送socket发送数据失败: ", err.Error())
            //}
            //msg, err = sock.Recv();
            //if err != nil {
            //    Die("groutine"+url+"接收响应失败: ", err.Error())
            //} else {
            //    logger.Debug("事件推送成功！groutine"+url+"收到响应",string(msg))
            //}

        default: