CommunicationClientFactoryBase<T> クラス
- java.
lang. Object - CommunicationClientFactory<TCommunicationClient>
- microsoft.
servicefabric. services. communication. client. CommunicationClientFactoryBase<T>
- microsoft.
型パラメーター
- T
通信クライアントの種類
public class CommunicationClientFactoryBase implements CommunicationClientFactory
Service Fabric サービスと通信する通信クライアントを作成するための CommunicationClientFactory の基本実装を提供します。 CommunicationClientFactoryBase クラスを拡張して、カスタム トランスポート実装用の通信クライアントを作成します。 このクラスは、通信クライアントのキャッシュを保持し、同じサービス エンドポイントへの要求に対してクライアントの再利用を試みます。
コンストラクターの概要
| コンストラクター | 説明 |
|---|---|
| CommunicationClientFactoryBase() |
通信クライアント ファクトリの新しいインスタンスを初期化します。 |
| CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers) |
通信クライアント ファクトリの新しいインスタンスを初期化します。 |
| CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List<ExceptionHandler> exceptionHandlers, String traceId) |
通信クライアント ファクトリの新しいインスタンスを初期化します。 |
メソッドの概要
| 修飾子と型 | メソッドと説明 |
|---|---|
| abstract void |
abortClient(T client)
指定されたクライアントを中止します |
| abstract CompletableFuture<T> | createClientAsync(String endpoint) |
| CompletableFuture<T> |
getClientAsync(ResolvedServicePartition previousRsp, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)
1 つ以上の通信リスナーを含む指定されたサービスのパーティションを解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。 |
| CompletableFuture<T> |
getClientAsync(URI serviceUri, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)
1 つ以上の通信リスナーを含む指定されたサービスのパーティションを解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。 |
|
List<Exception |
getExceptionHandlers()
クライアントからサービスへの通信チャネルで例外を処理するためのカスタム例外ハンドラーを取得します。 |
|
Service |
getServiceResolver()
サービス エンドポイントを解決するためにクライアント ファクトリによって使用される ServicePartitionResolver を取得します。 |
| String |
getTraceId()
CommunicationClientFactory のインスタンスを識別するために使用されるトレース識別子を取得します。 これは、トレース/ログ記録の関連付け識別子として使用されます。 |
|
CompletableFuture<Operation |
reportOperationExceptionAsync(T client, ExceptionInformation exceptionInformation, OperationRetrySettings retrySettings)
サービスにメッセージを送信するときに CommunicationClient で発生する例外を処理します |
| abstract boolean |
validateClient(String endpoint, T client)
クライアントがまだ有効で、 パラメーターで指定されたエンドポイントに接続されている場合は true を返します。 |
| abstract boolean |
validateClient(T client)
クライアントがまだ有効な場合は true を返します。 接続指向トランスポートでは、このメソッドを使用して、クライアントがサービスに接続されなくなったことを示すことができます。 |
継承メンバー
コンストラクターの詳細
CommunicationClientFactoryBase
protected CommunicationClientFactoryBase()
通信クライアント ファクトリの新しいインスタンスを初期化します。
CommunicationClientFactoryBase
protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List
通信クライアント ファクトリの新しいインスタンスを初期化します。
パラメーター:
CommunicationClientFactoryBase
protected CommunicationClientFactoryBase(ServicePartitionResolver servicePartitionResolver, List
通信クライアント ファクトリの新しいインスタンスを初期化します。
パラメーター:
メソッドの詳細
abortClient
protected abstract void abortClient(T client)
指定されたクライアントを中止します
パラメーター:
createClientAsync
protected abstract CompletableFuture
パラメーター:
getClientAsync
public CompletableFuture
1 つ以上の通信リスナーを含む指定されたサービスのパーティションを解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。
パラメーター:
戻り値:
getClientAsync
public CompletableFuture
1 つ以上の通信リスナーを含む指定されたサービスのパーティションを解決し、指定された listenerName に対応するエンドポイントと通信するクライアントを返します。 サービスのエンドポイントは、{"Endpoints":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}} の形式です。
パラメーター:
戻り値:
getExceptionHandlers
public List
クライアントからサービスへの通信チャネルで例外を処理するためのカスタム例外ハンドラーを取得します。
戻り値:
getServiceResolver
public ServicePartitionResolver getServiceResolver()
サービス エンドポイントを解決するためにクライアント ファクトリによって使用される ServicePartitionResolver を取得します。
戻り値:
getTraceId
protected String getTraceId()
CommunicationClientFactory のインスタンスを識別するために使用されるトレース識別子を取得します。 これは、トレース/ログ記録の関連付け識別子として使用されます。
戻り値:
reportOperationExceptionAsync
public CompletableFuture
サービスにメッセージを送信するときに CommunicationClient で発生する例外を処理します
パラメーター:
戻り値:
validateClient
protected abstract boolean validateClient(String endpoint, T client)
クライアントがまだ有効で、 パラメーターで指定されたエンドポイントに接続されている場合は true を返します。
パラメーター:
戻り値:
validateClient
protected abstract boolean validateClient(T client)
クライアントがまだ有効な場合は true を返します。 接続指向トランスポートでは、このメソッドを使用して、クライアントがサービスに接続されなくなったことを示すことができます。
パラメーター:
戻り値:
適用対象
Azure SDK for Java