labelFilter/req.go
@@ -61,6 +61,11 @@ if sock, err = req.NewSocket(); err != nil { Die("创建请求socket失败: %s", err.Error()) } errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024) if errSize != nil { fmt.Errorf("Failed set MaxRecvSize: %v", err) return } //sock.AddTransport(ipc.NewTransport()) sock.AddTransport(tcp.NewTransport()) if err = sock.Dial(url); err != nil {