程序包 com.alibaba.nacos.common.remote.client.grpc

类 GrpcSdkClient

java.lang.Object

com.alibaba.nacos.common.remote.client.RpcClient

com.alibaba.nacos.common.remote.client.grpc.GrpcClient

com.alibaba.nacos.common.remote.client.grpc.GrpcSdkClient

所有已实现的接口:

Closeable

public class GrpcSdkClient
extends GrpcClient

gRPC client for sdk.

版本:

$Id: GrpcSdkClient.java, v 0.1 2020年09月07日 11:05 AM liuzunfei Exp $

作者:

liuzunfei

嵌套类概要

从类继承的嵌套类/接口 com.alibaba.nacos.common.remote.client.RpcClient

RpcClient.ConnectionEvent, RpcClient.ServerInfo

字段概要

从类继承的字段 com.alibaba.nacos.common.remote.client.RpcClient

clientEventExecutor, connectionEventListeners, currentConnection, eventLinkedBlockingQueue, resourceLoader, rpcClientConfig, rpcClientStatus, serverRequestHandlers

构造器概要

构造器

构造器	说明
GrpcSdkClient(GrpcClientConfig config)	constructor.
GrpcSdkClient(String name)	Constructor.
GrpcSdkClient(String name, Integer threadPoolCoreSize, Integer threadPoolMaxSize, Map<String,String> labels)	Constructor.
GrpcSdkClient(String name, Integer threadPoolCoreSize, Integer threadPoolMaxSize, Map<String,String> labels, RpcClientTlsConfig tlsConfig)

方法概要

修饰符和类型	方法	说明
protected com.alibaba.nacos.api.ability.constant.AbilityMode	abilityMode()	ability mode: sdk client or cluster client.
int	rpcPortOffset()	increase offset of the nacos server port for the rpc server port.

从类继承的方法 com.alibaba.nacos.common.remote.client.grpc.GrpcClient

afterReset, connectToServer, createGrpcExecutor, createNewChannelStub, getClientVersion, getConnectionType, shutdown

从类继承的方法 com.alibaba.nacos.common.remote.client.RpcClient

asyncRequest, currentRpcServer, getConnectionAbility, getCurrentServer, getLabels, getName, getServerListFactory, getTenant, handleServerRequest, init, isRunning, isShutdown, isWaitInitiated, nextRpcServer, notifyConnected, notifyDisConnected, onServerListChange, reconnect, registerConnectionListener, registerServerRequestHandler, request, request, requestFuture, serverListFactory, setTenant, start, switchServerAsync, switchServerAsync, switchServerAsyncOnRequestFail

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

GrpcSdkClient

public GrpcSdkClient(String name)

Constructor.

参数:

name - name of client.

GrpcSdkClient

public GrpcSdkClient(String name,
 Integer threadPoolCoreSize,
 Integer threadPoolMaxSize,
 Map<String,String> labels)

Constructor.

参数:

name - name of client.

threadPoolCoreSize - .

threadPoolMaxSize - .

labels - .

GrpcSdkClient

public GrpcSdkClient(String name,
 Integer threadPoolCoreSize,
 Integer threadPoolMaxSize,
 Map<String,String> labels,
 RpcClientTlsConfig tlsConfig)

GrpcSdkClient

public GrpcSdkClient(GrpcClientConfig config)

constructor.

参数:

config - of GrpcClientConfig.

方法详细资料

abilityMode

protected com.alibaba.nacos.api.ability.constant.AbilityMode abilityMode()

从类复制的说明: GrpcClient

ability mode: sdk client or cluster client.

指定者:

abilityMode 在类中 GrpcClient

返回:

mode

rpcPortOffset

public int rpcPortOffset()

从类复制的说明: RpcClient

increase offset of the nacos server port for the rpc server port.

指定者:

rpcPortOffset 在类中 RpcClient

返回:

rpc port offset