ServiceProxyBase Klasse

Paket:

microsoft.servicefabric.services.remoting.client

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

public class ServiceProxyBase extends ProxyBase implements ServiceProxy

Stellt die Basisimplementierung für den Proxy für die IService-Remoteschnittstellen bereit.

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
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) Erstellt einen Proxy für die Kommunikation mit dem angegebenen Dienst mithilfe der Remoteschnittstelle TServiceInterface, die der Dienst implementiert.
Object	createRequestMessageBody(Object requestMessageBodyValue)
Object	deserializeMessage(byte[] msgBodyValue)
Object	getResponseMessageBodyValue(Object responseMessageBody)
Class<?>	getServiceInterfaceType() Der Schnittstellentyp, der remoteisiert wird.
ServiceRemotingPartitionClient	getServicePartitionClient() Der Dienstpartitionsclient, der zum Senden von Anforderungen an den Dienst verwendet wird.
void	initialize(ServiceProxyGenerator serviceProxyGenerator, FabricServiceRemotingPartitionClient remotingPartitionClient) Methode zum Initialisieren des Dienstproxys instance. Dies ist für den internen Gebrauch vorgesehen.
void	invoke(int interfaceId, int methodId, byte[] requestMsgBodyBytes)
CompletableFuture<byte[]>	invokeAsync(int interfaceId, int methodId, byte[] requestMsgBodyBytes, CancellationToken cancellationToken)
byte []	serializeMessage(Object msgBodyValue)

Geerbte Elemente

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

Details zur Methode

create

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

Parameter:

serviceInterfaceType

serviceUri

create

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

Erstellt einen Proxy für die Kommunikation mit dem angegebenen Dienst mithilfe der Remoteschnittstelle TServiceInterface, die der Dienst implementiert.

Parameter:

serviceInterfaceType - Schnittstellentyp, der remoteisiert wird

serviceUri - URI des Diensts.

partitionKey - Der Partitionsschlüssel, der bestimmt, welche Dienstpartition für die Verarbeitung von Anforderungen von diesem Dienstproxy verantwortlich ist

targetReplicaSelector - Bestimmt, mit welchem Replikat oder instance der Dienstpartition der Client eine Verbindung herstellen soll.

listenerName - Dieser Parameter ist Optional, wenn der Dienst über einen einzelnen Kommunikationslistener verfügt. Die Endpunkte des Diensts haben die Form {"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}. Wenn der Dienst mehrere Endpunkte verfügbar macht, identifiziert dieser Parameter, welcher dieser Endpunkte für die Remotingkommunikation verwendet werden soll.

Gibt zurück:

Der Proxy, der die Schnittstelle implementiert, die remotediert wird. Das zurückgegebene Objekt implementiert ServiceProxy auch eine Schnittstelle.

createRequestMessageBody

protected Object createRequestMessageBody(Object requestMessageBodyValue)

Parameter:

requestMessageBodyValue

deserializeMessage

protected Object deserializeMessage(byte[] msgBodyValue)

Parameter:

msgBodyValue

getResponseMessageBodyValue

protected Object getResponseMessageBodyValue(Object responseMessageBody)

Parameter:

responseMessageBody

getServiceInterfaceType

public Class getServiceInterfaceType()

Der Schnittstellentyp, der remoteisiert wird.

Überschreibt:

ServiceProxyBase.getServiceInterfaceType()

Gibt zurück:

Dienstschnittstellentyp.

getServicePartitionClient

public ServiceRemotingPartitionClient getServicePartitionClient()

Der Dienstpartitionsclient, der zum Senden von Anforderungen an den Dienst verwendet wird.

Überschreibt:

ServiceProxyBase.getServicePartitionClient()

Gibt zurück:

ServicePartitionClient, der vom ServiceProxy verwendet wird.

initialize

public void initialize(ServiceProxyGenerator serviceProxyGenerator, FabricServiceRemotingPartitionClient remotingPartitionClient)

Methode zum Initialisieren des Dienstproxys instance. Dies ist für den internen Gebrauch vorgesehen.

Parameter:

serviceProxyGenerator - instance des serviceProxyGenerator

remotingPartitionClient - RemotingPartitionClient, der vom Dienstproxy verwendet wird.

invoke

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

Parameter:

interfaceId

methodId

requestMsgBodyBytes

invokeAsync

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

Parameter:

interfaceId

methodId

requestMsgBodyBytes

cancellationToken

serializeMessage

protected byte [] serializeMessage(Object msgBodyValue)

Parameter:

msgBodyValue