ServiceProxyBase Classe

Pacote:

microsoft.servicefabric.services.remoting.client

• java.lang.Object
• • ProxyBase
  • • microsoft.servicefabric.services.remoting.client.ServiceProxyBase

public class ServiceProxyBase extends ProxyBase implements ServiceProxy

Fornece a implementação base para o proxy para as interfaces IService remotas.

Resumo do método

Modificador e tipo	Método e descrição
static<T extends Service> T	create(Class<T> serviceInterfaceType, URI serviceUri)
static<T extends Service> T	create(Class<T> serviceInterfaceType, URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName) Cria um proxy para se comunicar com o serviço especificado usando a interface remota TServiceInterface que o serviço implementa.
Object	createRequestMessageBody(Object requestMessageBodyValue)
Object	deserializeMessage(byte[] msgBodyValue)
Object	getResponseMessageBodyValue(Object responseMessageBody)
Class<?>	getServiceInterfaceType() O tipo de interface que está sendo remoto.
ServiceRemotingPartitionClient	getServicePartitionClient() O cliente de partição de serviço usado para enviar solicitações para o serviço.
void	initialize(ServiceProxyGenerator serviceProxyGenerator, FabricServiceRemotingPartitionClient remotingPartitionClient) Método para Inicializar a instância de proxy de serviço. Isso é para uso interno.
void	invoke(int interfaceId, int methodId, byte[] requestMsgBodyBytes)
CompletableFuture<byte[]>	invokeAsync(int interfaceId, int methodId, byte[] requestMsgBodyBytes, CancellationToken cancellationToken)
byte []	serializeMessage(Object msgBodyValue)

Membros herdados

ProxyBase.continueWith(CompletableFuture<Object> future) ProxyBase.getReturnValue(int interfaceId, int methodId, Object responseBody) ProxyBase.invoke(int interfaceId, int methodId, Object requestMsgBodyValue) ProxyBase.invokeAsync(int interfaceId, int methodId, Object requestMsgBodyValue, CancellationToken cancellationToken) ProxyBase.ProxyBase()

Detalhes do método

create

public static static T create(Class serviceInterfaceType, URI serviceUri)

Parâmetros:

serviceInterfaceType

serviceUri

create

public static static T create(Class serviceInterfaceType, URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName)

Cria um proxy para se comunicar com o serviço especificado usando a interface remota TServiceInterface que o serviço implementa.

Parâmetros:

serviceInterfaceType - Tipo de interface que está sendo remoto

serviceUri - URI do Serviço.

partitionKey - A chave de partição que determina qual partição de serviço é responsável por lidar com solicitações desse proxy de serviço

targetReplicaSelector - Determina a qual réplica ou instância da partição de serviço à qual o cliente deve se conectar.

listenerName - Esse parâmetro será Opcional se o serviço tiver um único ouvinte de comunicação. Os pontos de extremidade do serviço são do formato {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}. Quando o serviço expõe vários pontos de extremidade, esse parâmetro identifica quais desses pontos de extremidade usar para a comunicação remota.

Retornos:

O proxy que implementa a interface que está sendo remota. O objeto retornado também implementa ServiceProxy a interface .

createRequestMessageBody

protected Object createRequestMessageBody(Object requestMessageBodyValue)

Parâmetros:

requestMessageBodyValue

deserializeMessage

protected Object deserializeMessage(byte[] msgBodyValue)

Parâmetros:

msgBodyValue

getResponseMessageBodyValue

protected Object getResponseMessageBodyValue(Object responseMessageBody)

Parâmetros:

responseMessageBody

getServiceInterfaceType

public Class getServiceInterfaceType()

O tipo de interface que está sendo remoto.

Substituições:

ServiceProxyBase.getServiceInterfaceType()

Retornos:

Tipo de interface de serviço.

getServicePartitionClient

public ServiceRemotingPartitionClient getServicePartitionClient()

O cliente de partição de serviço usado para enviar solicitações para o serviço.

Substituições:

ServiceProxyBase.getServicePartitionClient()

Retornos:

ServicePartitionClient usado pelo ServiceProxy.

initialize

public void initialize(ServiceProxyGenerator serviceProxyGenerator, FabricServiceRemotingPartitionClient remotingPartitionClient)

Método para Inicializar a instância de proxy de serviço. Isso é para uso interno.

Parâmetros:

serviceProxyGenerator - instância do serviceProxyGenerator

remotingPartitionClient - remotingPartitionClient usado pelo proxy de serviço.

invoke

protected void invoke(int interfaceId, int methodId, byte[] requestMsgBodyBytes)

Parâmetros:

interfaceId

methodId

requestMsgBodyBytes

invokeAsync

protected CompletableFuture invokeAsync(int interfaceId, int methodId, byte[] requestMsgBodyBytes, CancellationToken cancellationToken)

Parâmetros:

interfaceId

methodId

requestMsgBodyBytes

cancellationToken

serializeMessage

protected byte [] serializeMessage(Object msgBodyValue)

Parâmetros:

msgBodyValue