From c11cbcc5cada466d00e2d65b646bfe141d801ee3 Mon Sep 17 00:00:00 2001 From: "binbin.zhang" Date: Thu, 23 Mar 2023 19:11:31 +0800 Subject: [PATCH] grpc default port init (#598) * grpc default port init * update version --- clients/client_factory.go | 7 ++++++- common/constant/const.go | 3 ++- common/remote/rpc/grpc_client.go | 2 +- 3 files changed, 9 insertions(+), 3 deletions(-) diff --git a/clients/client_factory.go b/clients/client_factory.go index 67fafe65..b68d8de0 100644 --- a/clients/client_factory.go +++ b/clients/client_factory.go @@ -34,7 +34,7 @@ func CreateConfigClient(properties map[string]interface{}) (iClient config_clien return NewConfigClient(param) } -//CreateNamingClient use to create a nacos naming client +// CreateNamingClient use to create a nacos naming client func CreateNamingClient(properties map[string]interface{}) (iClient naming_client.INamingClient, err error) { param := getConfigParam(properties) return NewNamingClient(param) @@ -104,6 +104,11 @@ func setConfig(param vo.NacosClientParam) (iClient nacos_client.INacosClient, er } _ = client.SetServerConfig(nil) } else { + for i := range param.ServerConfigs { + if param.ServerConfigs[i].GrpcPort == 0 { + param.ServerConfigs[i].GrpcPort = param.ServerConfigs[i].Port + constant.RpcPortOffset + } + } err = client.SetServerConfig(param.ServerConfigs) if err != nil { return nil, err diff --git a/common/constant/const.go b/common/constant/const.go index 936ce3c7..390fc62d 100644 --- a/common/constant/const.go +++ b/common/constant/const.go @@ -68,7 +68,7 @@ const ( KEY_BEAT = "beat" KEY_DOM = "dom" DEFAULT_CONTEXT_PATH = "/nacos" - CLIENT_VERSION = "Nacos-Go-Client:v2.2.0" + CLIENT_VERSION = "Nacos-Go-Client:v2.2.1" REQUEST_DOMAIN_RETRY_TIME = 3 SERVICE_INFO_SPLITER = "@@" CONFIG_INFO_SPLITER = "@@" @@ -98,4 +98,5 @@ const ( HTTPS_SERVER_PORT = 443 GRPC = "grpc" FAILOVER_FILE_SUFFIX = "_failover" + RpcPortOffset = 1000 ) diff --git a/common/remote/rpc/grpc_client.go b/common/remote/rpc/grpc_client.go index a4a72459..a5373227 100644 --- a/common/remote/rpc/grpc_client.go +++ b/common/remote/rpc/grpc_client.go @@ -172,7 +172,7 @@ func (c *GrpcClient) getConnectionType() ConnectionType { } func (c *GrpcClient) rpcPortOffset() uint64 { - return 1000 + return constant.RpcPortOffset } func (c *GrpcClient) bindBiRequestStream(streamClient nacos_grpc_service.BiRequestStream_RequestBiStreamClient, grpcConn *GrpcConnection) {