CommunicationClientFactoryBase<T> Classe

Pacote:

microsoft.servicefabric.services.communication.client

• java.lang.Object
• • CommunicationClientFactory<TCommunicationClient>
  • • microsoft.servicefabric.services.communication.client.CommunicationClientFactoryBase<T>

Parâmetros de tipo

T

O tipo de cliente de comunicação

public class CommunicationClientFactoryBase implements CommunicationClientFactory

Fornece a implementação base de CommunicationClientFactory para criar clientes de comunicação para conversar com os serviços do service fabric. Estenda a classe CommunicationClientFactoryBase para criar clientes de comunicação para implementações de transporte personalizadas. Essa classe mantém um cache de clientes de comunicação e tenta reutilizar os clientes para solicitações para o mesmo ponto de extremidade de serviço.

Resumo do Construtor

Construtor	Description
CommunicationClientFactoryBase()	Inicializa uma nova instância da fábrica de clientes de comunicação.
CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers)	Inicializa uma nova instância da fábrica de clientes de comunicação.
CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers, String traceId)	Inicializa uma nova instância da fábrica de clientes de comunicação.

Resumo do método

Modificador e tipo	Método e descrição
abstract void	abortClient(T client) Anula o cliente especificado
abstract CompletableFuture<T>	createClientAsync(String endpoint)
CompletableFuture<T>	getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings) Resolve uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}
CompletableFuture<T>	getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings) Resolve uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}
List<ExceptionHandler>	getExceptionHandlers() Obtém os manipuladores de exceção personalizados para lidar com exceções no canal de comunicação cliente a serviço.
ServicePartitionResolver	getServiceResolver() Obtém o ServicePartitionResolver usado pela fábrica de clientes para resolver o ponto de extremidade de serviço.
String	getTraceId() Obtém o identificador de rastreamento usado para identificar uma instância do CommunicationClientFactory. Isso é usado como um identificador de correlação para rastreamento/registro em log.
CompletableFuture<OperationRetryControl>	reportOperationExceptionAsync(T client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings) Manipula as exceções que ocorrem no CommunicationClient ao enviar uma mensagem para o Serviço
abstract boolean	validateClient(String endpoint, T client) Retornará true se o cliente ainda for válido e estiver conectado ao ponto de extremidade especificado no parâmetro .
abstract boolean	validateClient(T client) Retornará true se o cliente ainda for válido. Os transportes orientados para conexão podem usar esse método para indicar que o cliente não está mais conectado ao serviço.

Membros herdados

CommunicationClientFactory<TCommunicationClient>.reportOperationExceptionAsync(TCommunicationClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

Detalhes do construtor

CommunicationClientFactoryBase

protected CommunicationClientFactoryBase()

Inicializa uma nova instância da fábrica de clientes de comunicação.

CommunicationClientFactoryBase

protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List exceptionHandlers)

Inicializa uma nova instância da fábrica de clientes de comunicação.

Parâmetros:

servicePartitionResolver - ServicePartitionResolver opcional

exceptionHandlers - Manipuladores de exceção personalizados opcionais para as exceções no canal de comunicação Cliente para Serviço

CommunicationClientFactoryBase

protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List exceptionHandlers, String traceId)

Inicializa uma nova instância da fábrica de clientes de comunicação.

Parâmetros:

servicePartitionResolver - ServicePartitionResolver opcional

exceptionHandlers - Manipuladores de exceção personalizados opcionais para as exceções no canal de comunicação Cliente para Serviço

traceId - Id a ser usada em diagnóstico rastreamentos desse componente.

Detalhes do método

abortClient

protected abstract void abortClient(T client)

Anula o cliente especificado

Parâmetros:

client - Cliente de comunicação

createClientAsync

protected abstract CompletableFuture createClientAsync(String endpoint)

Parâmetros:

endpoint

getClientAsync

public CompletableFuture getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Resolve uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Parâmetros:

previousRsp - Anterior ResolvedServicePartition

targetReplicaSelector -

TargetReplicaSelector

listenerName - Nome do ouvinte

retrySettings - repetir configurações

Retornos:

Um CompleteableFuture que representa uma operação pendente. O resultado da Tarefa é o objeto CommunicationClient(CommunicationClient).

getClientAsync

public CompletableFuture getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Resolve uma partição do serviço especificado que contém um ou mais ouvintes de comunicação e retorna um cliente para se comunicar com o ponto de extremidade correspondente ao ouvinteName especificado. O ponto de extremidade do serviço é do formulário - {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Parâmetros:

serviceUri - Uri do serviço para resolve

partitionKey - Chave que identifica a partição para resolve

targetReplicaSelector -

TargetReplicaSelector

listenerName - Nome do ouvinte

retrySettings - repetir configurações

Retornos:

Um CompleteableFuture que representa uma operação pendente. O resultado da Tarefa é o objeto CommunicationClient(CommunicationClient).

getExceptionHandlers

public List getExceptionHandlers()

Obtém os manipuladores de exceção personalizados para lidar com exceções no canal de comunicação cliente a serviço.

Retornos:

Lista de manipuladores de exceção

getServiceResolver

public ServicePartitionResolver getServiceResolver()

Obtém o ServicePartitionResolver usado pela fábrica de clientes para resolver o ponto de extremidade de serviço.

Retornos:

ServicePartitionResolver

getTraceId

protected String getTraceId()

Obtém o identificador de rastreamento usado para identificar uma instância do CommunicationClientFactory. Isso é usado como um identificador de correlação para rastreamento/registro em log.

Retornos:

Identificador de rastreamento

reportOperationExceptionAsync

public CompletableFuture reportOperationExceptionAsync(T client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)

Manipula as exceções que ocorrem no CommunicationClient ao enviar uma mensagem para o Serviço

Parâmetros:

client - Cliente de comunicação

exceptionInformation - informações de exceção

retrySettings - repetir configurações

Retornos:

Um CompleteableFuture que representa uma operação pendente. O resultado da Tarefa é um OperationRetryControl objeto que determina como a política de repetição para essa exceção.

validateClient

protected abstract boolean validateClient(String endpoint, T client)

Retornará true se o cliente ainda for válido e estiver conectado ao ponto de extremidade especificado no parâmetro .

Parâmetros:

endpoint - o ponto de extremidade

client - o cliente de comunicação

Retornos:

true se o cliente for válido, caso contrário, false

validateClient

protected abstract boolean validateClient(T client)

Retornará true se o cliente ainda for válido. Os transportes orientados para conexão podem usar esse método para indicar que o cliente não está mais conectado ao serviço.

Parâmetros:

client - o cliente de comunicação

Retornos:

true se o cliente for válido, caso contrário, false