FabricTransportServiceRemotingClientFactory Classe

Pacote:

microsoft.servicefabric.services.remoting.fabrictransport.client

• java.lang.Object
• • CommunicationClientFactory<TCommunicationClient>
  • • ServiceRemotingClientFactory
    • • microsoft.servicefabric.services.remoting.fabrictransport.client.FabricTransportServiceRemotingClientFactory

public class FabricTransportServiceRemotingClientFactory implements ServiceRemotingClientFactory

Um ServiceRemotingClientFactory que usa o transporte TCP do Fabric para criar ServiceRemotingClient que se comunica com serviços sem estado e com estado em interfaces remotas por meio de FabricTransportServiceRemotingListener.

Resumo do Construtor

Construtor	Description
FabricTransportServiceRemotingClientFactory(FabricTransportRemotingSettings fabricTransportSettings, ServiceRemotingCallbackClient callbackClient, ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers, String traceId)	Constrói uma fábrica de clientes de comunicação remota baseada em transporte de malha. Observações:Essa fábrica usa um manipulador de exceção de transporte de malha interno para lidar com exceções no nível de transporte TCP de malha e um ServiceRemotingExceptionHandler, além dos manipuladores de exceção fornecidos ao construtor.

Resumo do método

Modificador e tipo	Método e descrição
CompletableFuture<ServiceRemotingClient>	getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings) Resolve novamente 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<ServiceRemotingClient>	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" ...}}
CompletableFuture<OperationRetryControl>	reportOperationExceptionAsync(ServiceRemotingClient client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings) Manipula as exceções que ocorrem no CommunicationClient ao enviar uma mensagem para o Serviço

Membros herdados

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

Detalhes do construtor

FabricTransportServiceRemotingClientFactory

public FabricTransportServiceRemotingClientFactory(FabricTransportRemotingSettings fabricTransportSettings, ServiceRemotingCallbackClient callbackClient, ServicePartitionResolver servicePartitionResolver, List exceptionHandlers, String traceId)

Constrói uma fábrica de clientes de comunicação remota baseada em transporte de malha.

Observações:Essa fábrica usa um manipulador de exceção de transporte de malha interno para lidar com exceções no nível de transporte TCP de malha e um ServiceRemotingExceptionHandler, além dos manipuladores de exceção fornecidos ao construtor.

Parâmetros:

fabricTransportSettings - As configurações para o transporte de malha. Se as configurações não forem fornecidas ou nulas, configurações padrão sem segurança.

callbackClient - O cliente de retorno de chamada que recebe os retornos de chamada do serviço.

servicePartitionResolver - Resolvedor de partição de serviço para resolve os pontos de extremidade de serviço. Se não for especificado, um resolvedor de partição de serviço padrão retornado por getDefault() será usado.

exceptionHandlers - Manipuladores de exceção para lidar com as exceções encontradas na comunicação com o serviço.

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

Detalhes do método

getClientAsync

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

Resolve novamente 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" ...}}

Substituições:

FabricTransportServiceRemotingClientFactory.getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Parâmetros:

previousRsp - Valor de ResolvedServicePartition anterior

targetReplicaSelector - Especifica a qual réplica na partição identificada pela chave de partição, ao qual o cliente deve se conectar

listenerName - Especifica a qual ouvinte no ponto de extremidade do réplica escolhido, ao qual o cliente deve se conectar

retrySettings - Especifica a política de repetição que deve ser usada para exceções que ocorrem ao criar o cliente.

Retornos:

Um CompletableFuture 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" ...}}

Substituições:

FabricTransportServiceRemotingClientFactory.getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

Parâmetros:

serviceUri - Uri do serviço para resolve

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

targetReplicaSelector - Especifica a qual réplica na partição identificada pela chave de partição, ao qual o cliente deve se conectar

listenerName - Especifica a qual ouvinte no ponto de extremidade do réplica escolhido, ao qual o cliente deve se conectar

retrySettings - Especifica a política de repetição que deve ser usada para exceções que ocorrem ao criar o cliente.

Retornos:

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

reportOperationExceptionAsync

public CompletableFuture reportOperationExceptionAsync(ServiceRemotingClient 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 sobre a exceção que ocorreu durante a comunicação com o serviço.

retrySettings - Especifica a política de repetição que deve ser usada para lidar com a exceção relatada.

Retornos:

Um CompletableFuture que representa uma operação pendente. O resultado da Tarefa é um OperationRetryControl objeto que fornece informações sobre a política de repetição para essa exceção.