labelFilter/req.go
@@ -9,7 +9,7 @@ "nanomsg.org/go-mangos/transport/tcp" "os" "github.com/golang/protobuf/proto" "ruleprocess/logger" "basic.com/valib/logger.git" "ruleprocess/ruleserver" "time" ) @@ -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 {