ServiceProxyBase Classe

Paquet:

microsoft.servicefabric.services.remoting.client

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

public class ServiceProxyBase extends ProxyBase implements ServiceProxy

Fournit l’implémentation de base pour le proxy vers les interfaces IService distantes.

Résumé de la méthode

Modificateur et type	Méthode et description
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) Crée un proxy pour communiquer avec le service spécifié à l’aide de l’interface distante TServiceInterface que le service implémente.
Object	createRequestMessageBody(Object requestMessageBodyValue)
Object	deserializeMessage(byte[] msgBodyValue)
Object	getResponseMessageBodyValue(Object responseMessageBody)
Class<?>	getServiceInterfaceType() Type d’interface en cours de remote.
ServiceRemotingPartitionClient	getServicePartitionClient() Client de partition de service utilisé pour envoyer des demandes au service.
void	initialize(ServiceProxyGenerator serviceProxyGenerator, FabricServiceRemotingPartitionClient remotingPartitionClient) Méthode pour initialiser le proxy de service instance. Il s’agit d’un usage interne.
void	invoke(int interfaceId, int methodId, byte[] requestMsgBodyBytes)
CompletableFuture<byte[]>	invokeAsync(int interfaceId, int methodId, byte[] requestMsgBodyBytes, CancellationToken cancellationToken)
byte []	serializeMessage(Object msgBodyValue)

Membres hérités

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()

Détails de la méthode

create

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

Paramètres:

serviceInterfaceType

serviceUri

create

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

Crée un proxy pour communiquer avec le service spécifié à l’aide de l’interface distante TServiceInterface que le service implémente.

Paramètres:

serviceInterfaceType - Type d’interface en cours de remote

serviceUri - URI du service.

partitionKey - Clé de partition qui détermine quelle partition de service est responsable de la gestion des demandes provenant de ce proxy de service

targetReplicaSelector - Détermine les réplica ou instance de la partition de service auxquelles le client doit se connecter.

listenerName - Ce paramètre est Facultatif si le service a un seul écouteur de communication. Les points de terminaison du service sont de la forme {"Endpoints »:{"Listener1 »:"Endpoint1 »,"Listener2 »:"Endpoint2 » ...}}. Lorsque le service expose plusieurs points de terminaison, ce paramètre identifie les points de terminaison à utiliser pour la communication à distance.

Retours:

Proxy qui implémente l’interface distante. L’objet retourné implémente ServiceProxy également l’interface.

createRequestMessageBody

protected Object createRequestMessageBody(Object requestMessageBodyValue)

Paramètres:

requestMessageBodyValue

deserializeMessage

protected Object deserializeMessage(byte[] msgBodyValue)

Paramètres:

msgBodyValue

getResponseMessageBodyValue

protected Object getResponseMessageBodyValue(Object responseMessageBody)

Paramètres:

responseMessageBody

getServiceInterfaceType

public Class getServiceInterfaceType()

Type d’interface en cours de remote.

Remplacements:

ServiceProxyBase.getServiceInterfaceType()

Retours:

Type d’interface de service.

getServicePartitionClient

public ServiceRemotingPartitionClient getServicePartitionClient()

Client de partition de service utilisé pour envoyer des demandes au service.

Remplacements:

ServiceProxyBase.getServicePartitionClient()

Retours:

ServicePartitionClient utilisé par ServiceProxy.

initialize

public void initialize(ServiceProxyGenerator serviceProxyGenerator, FabricServiceRemotingPartitionClient remotingPartitionClient)

Méthode pour initialiser le proxy de service instance. Il s’agit d’un usage interne.

Paramètres:

serviceProxyGenerator - instance du serviceProxyGenerator

remotingPartitionClient - remotingPartitionClient utilisé par le proxy de service.

invoke

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

Paramètres:

interfaceId

methodId

requestMsgBodyBytes

invokeAsync

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

Paramètres:

interfaceId

methodId

requestMsgBodyBytes

cancellationToken

serializeMessage

protected byte [] serializeMessage(Object msgBodyValue)

Paramètres:

msgBodyValue