labelFilter/req.go
@@ -61,7 +61,7 @@ if sock, err = req.NewSocket(); err != nil { Die("创建请求socket失败: %s", err.Error()) } errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024) errSize := sock.SetOption(mangos.OptionMaxRecvSize,30*1024*1024) if errSize != nil { fmt.Errorf("Failed set MaxRecvSize: %v", err) return @@ -85,7 +85,7 @@ if msg, err = sock.Recv(); err != nil { Die("接收响应失败: %s", err.Error()) } logger.Debug("数据推送成功!收到响应",string(msg)) logger.Debug("事件推送成功!收到响应",string(msg)) sock.Close() }