| | |
| | | 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 |
| | | } |
| | | errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 500) |
| | | if errTimeOut != nil { |
| | | fmt.Errorf("Failed set MaxRecvSize: %v", err) |
| | | return |
| | | } |
| | |
| | | if msg, err = sock.Recv(); err != nil { |
| | | Die("接收响应失败: %s", err.Error()) |
| | | } |
| | | logger.Debug("数据推送成功!收到响应",string(msg)) |
| | | logger.Debug("事件推送成功!收到响应",string(msg)) |
| | | sock.Close() |
| | | } |
| | | |