TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-07 18:50:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加GRPC最大能接收的消息尺寸为128M

Browse Source
This commit is contained in:
GoEdgeLab
2021-12-04 19:02:12 +08:00
parent 42d3b82f23
commit c4e46c50a1
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/nodes/api_node.go
View File

@@ -207,10 +207,10 @@ func (this *APINode) listenRPC(listener net.Listener, tlsConfig *tls.Config) err
var rpcServer *grpc.Server var rpcServer *grpc.Server
if tlsConfig == nil { if tlsConfig == nil {
remotelogs.Println("API_NODE", "listening GRPC http://"+listener.Addr().String()+" ...") remotelogs.Println("API_NODE", "listening GRPC http://"+listener.Addr().String()+" ...")
rpcServer = grpc.NewServer() rpcServer = grpc.NewServer(grpc.MaxRecvMsgSize(128 * 1024 * 1024))
} else { } else {
logs.Println("[API_NODE]listening GRPC https://" + listener.Addr().String() + " ...") logs.Println("[API_NODE]listening GRPC https://" + listener.Addr().String() + " ...")
rpcServer = grpc.NewServer(grpc.Creds(credentials.NewTLS(tlsConfig))) rpcServer = grpc.NewServer(grpc.Creds(credentials.NewTLS(tlsConfig)), grpc.MaxRecvMsgSize(128*1024*1024))
} }
this.registerServices(rpcServer) this.registerServices(rpcServer)
err := rpcServer.Serve(listener) err := rpcServer.Serve(listener)