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

类 GrpcClient

java.lang.Object

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

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

所有已实现的接口:

Closeable

直接已知子类:

GrpcClusterClient, GrpcSdkClient

public abstract class GrpcClient
extends RpcClient

gRPC Client.

版本:

$Id: GrpcClient.java, v 0.1 2020年07月13日 9:16 PM 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

构造器概要

构造器

构造器	说明
GrpcClient(GrpcClientConfig clientConfig)	constructor.
GrpcClient(GrpcClientConfig clientConfig, ServerListFactory serverListFactory)	constructor.
GrpcClient(String name)	constructor.
GrpcClient(String name, Integer threadPoolCoreSize, Integer threadPoolMaxSize, Map<String,String> labels)	constructor.
GrpcClient(String name, Integer threadPoolCoreSize, Integer threadPoolMaxSize, Map<String,String> labels, RpcClientTlsConfig tlsConfig)

方法概要

修饰符和类型	方法	说明
protected abstract com.alibaba.nacos.api.ability.constant.AbilityMode	abilityMode()	ability mode: sdk client or cluster client.
protected void	afterReset(com.alibaba.nacos.api.remote.request.ConnectResetRequest request)	. invoke after receiving reset request
Connection	connectToServer(RpcClient.ServerInfo serverInfo)	connect to server.
protected ThreadPoolExecutor	createGrpcExecutor(String serverIp)
protected com.alibaba.nacos.api.grpc.auto.RequestGrpc.RequestFutureStub	createNewChannelStub(io.grpc.ManagedChannel managedChannelTemp)	Create a stub using a channel.
protected String	getClientVersion()
ConnectionType	getConnectionType()	get connection type of this client.
void	shutdown()	Shutdown the Resources, such as Thread Pool.

从类继承的方法 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, rpcPortOffset, serverListFactory, setTenant, start, switchServerAsync, switchServerAsync, switchServerAsyncOnRequestFail

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

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

构造器详细资料

GrpcClient

public GrpcClient(String name)

constructor.

参数:

name - .

GrpcClient

public GrpcClient(GrpcClientConfig clientConfig)

constructor.

参数:

clientConfig - .

GrpcClient

public GrpcClient(GrpcClientConfig clientConfig,
 ServerListFactory serverListFactory)

constructor.

参数:

clientConfig - .

serverListFactory - .

GrpcClient

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

constructor.

参数:

name - .

threadPoolCoreSize - .

threadPoolMaxSize - .

labels - .

GrpcClient

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

方法详细资料

getConnectionType

public ConnectionType getConnectionType()

从类复制的说明: RpcClient

get connection type of this client.

指定者:

getConnectionType 在类中 RpcClient

返回:

ConnectionType.

createGrpcExecutor

protected ThreadPoolExecutor createGrpcExecutor(String serverIp)

shutdown

public void shutdown()
              throws com.alibaba.nacos.api.exception.NacosException

从接口复制的说明: Closeable

Shutdown the Resources, such as Thread Pool.

指定者:

shutdown 在接口中 Closeable

覆盖:

shutdown 在类中 RpcClient

抛出:

com.alibaba.nacos.api.exception.NacosException - exception.

createNewChannelStub

protected com.alibaba.nacos.api.grpc.auto.RequestGrpc.RequestFutureStub createNewChannelStub(io.grpc.ManagedChannel managedChannelTemp)

Create a stub using a channel.

参数:

managedChannelTemp - channel.

返回:

if server check success,return a non-null stub.

connectToServer

public Connection connectToServer(RpcClient.ServerInfo serverInfo)

从类复制的说明: RpcClient

connect to server.

指定者:

connectToServer 在类中 RpcClient

参数:

serverInfo - server address to connect.

返回:

return connection when successfully connect to server, or null if failed.

getClientVersion

protected String getClientVersion()

abilityMode

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

ability mode: sdk client or cluster client.

返回:

mode

afterReset

protected void afterReset(com.alibaba.nacos.api.remote.request.ConnectResetRequest request)

从类复制的说明: RpcClient

. invoke after receiving reset request

覆盖:

afterReset 在类中 RpcClient

参数:

request - request for resetting