From fab99b43868f787663d7e5838c534e60cad2e98b Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sun, 20 Mar 2022 11:28:34 +0800 Subject: [PATCH] =?UTF-8?q?GRPC=E9=80=9A=E8=AE=AF=E6=94=AF=E6=8C=81gzip?= =?UTF-8?q?=E5=8E=8B=E7=BC=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/rpc/rpc_client.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/internal/rpc/rpc_client.go b/internal/rpc/rpc_client.go index c4933a1..c20ea60 100644 --- a/internal/rpc/rpc_client.go +++ b/internal/rpc/rpc_client.go @@ -16,6 +16,7 @@ import ( "google.golang.org/grpc/connectivity" "google.golang.org/grpc/credentials" "google.golang.org/grpc/credentials/insecure" + "google.golang.org/grpc/encoding/gzip" "google.golang.org/grpc/metadata" "net/url" "sync" @@ -219,12 +220,14 @@ func (this *RPCClient) init() error { return errors.New("parse endpoint failed: " + err.Error()) } var conn *grpc.ClientConn + var callOptions = grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(128*1024*1024), + grpc.UseCompressor(gzip.Name)) if u.Scheme == "http" { - conn, err = grpc.Dial(u.Host, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(128*1024*1024))) + conn, err = grpc.Dial(u.Host, grpc.WithTransportCredentials(insecure.NewCredentials())) } else if u.Scheme == "https" { conn, err = grpc.Dial(u.Host, grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{ InsecureSkipVerify: true, - })), grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(128*1024*1024))) + })), callOptions) } else { return errors.New("parse endpoint failed: invalid scheme '" + u.Scheme + "'") }