インターフェース RSocketRequester.Builder

メソッドの詳細

• dataMimeType

  RSocketRequester.Builder dataMimeType(@Nullable MimeType mimeType)

  接続全体に適用される SETUP フレームで指定するペイロードデータ MimeType を構成します。

  設定されていない場合、これは最初の non-default Decoder の MimeType、または最初のデコーダーの MimeType に初期化されます。

• metadataMimeType

  RSocketRequester.Builder metadataMimeType(MimeType mimeType)

  ペイロードメタデータ MimeType を構成して、接続全体に適用される SETUP フレームで指定します。

  デフォルトでは、これは "message/x.rsocket.composite-metadata.v0" に設定されています。この場合、ルートが指定されている場合、"message/x.rsocket.routing.v0" 複合メタデータエントリとしてエンコードされます。これが他の MimeType に設定されている場合、ルートの MimeType が提供されていると想定されます。

• setupData

  RSocketRequester.Builder setupData(ObjectSE data)

  セットアップペイロードのデータを設定します。データは、構成された dataMimeType(MimeType) に従ってエンコードされます。データは、具体的な値、または ReactiveAdapterRegistry を介して Publisher に適合できる単一の値の任意のプロデューサーです。

  デフォルトでは、これは設定されていません。

• setupRoute

  RSocketRequester.Builder setupRoute(StringSE route, ObjectSE... routeVars)

  セットアップペイロードのルートを設定します。ルートのフォーマットとエンコードのルールは、RSocketRequester.route(String, Object...) で説明されているリクエストルートのルールと同じです。

  デフォルトでは、これは設定されていません。

• setupMetadata

  RSocketRequester.Builder setupMetadata(ObjectSE value, @Nullable MimeType mimeType)

  セットアップペイロードにメタデータエントリを追加します。これが複数回呼び出される場合、または setupRoute(String, Object...) に加えて呼び出される場合は、複合メタデータが使用されている必要があります。メタデータ値は、ReactiveAdapterRegistry を介して Publisher に適合させることができる具体的な値または単一の値の任意のプロデューサーです。

• rsocketStrategies

  RSocketRequester.Builder rsocketStrategies(@Nullable RSocketStrategies strategies)

  使用する RSocketStrategies を提供します。

  これはデフォルト設定を変更できますが、それでも rsocketStrategies(Consumer) を介してさらにカスタマイズできます。設定しない場合、デフォルトは RSocketStrategies.builder() から取得されます。

  パラメーター:

  strategies - 使用する戦略

• rsocketStrategies

  RSocketRequester.Builder rsocketStrategies(ConsumerSE<RSocketStrategies.Builder> configurer)

  RSocketStrategies をカスタマイズします。

  RSocketStrategies をさらにカスタマイズしたり、set の場合は変更したり、RSocketStrategies.builder() のデフォルトから開始したりできます。}。

• rsocketConnector

  RSocketRequester.Builder rsocketConnector(RSocketConnectorConfigurer configurer)

  RSocketConnector を直接構成するためのコールバック。

  • データとメタデータの MIME 型は、RSocketConnector で直接設定することはできず、オーバーライドされます。代わりに、このビルダーのショートカット dataMimeType(MimeType) および metadataMimeType(MimeType) を使用してください。
  • また、フレームデコーダーを直接設定することはできず、構成された DataBufferFactory と一致するように設定されます。
  • setupPayload の場合、このビルダーのメソッドを使用して、ルート、その他のメタデータ、データをエンコードするオブジェクト値として指定することを検討してください。
  • クライアント側の応答を構成するには、RSocketMessageHandler.responder(RSocketStrategies, Object...) を参照してください。

  導入:

  5.2.6

• apply

  RSocketRequester.Builder apply(ConsumerSE<RSocketRequester.Builder> configurer)

  Consumer を介してこのビルダーを構成します。これにより、Spring Security などのライブラリは、関連する一連のカスタマイズを適用するためのショートカットを提供できます。

  パラメーター:

  configurer - 適用するコンフィギュレーター

• tcp

  RSocketRequester tcp(StringSE host, int port)

  TCP を介して特定のホストとポートに接続する RSocketClient を使用して RSocketRequester を構築します。リクエスターを使用して、同時にリクエストを行うことができます。リクエストは共有接続を介して行われ、さらにリクエストが行われると、必要に応じて再確立されます。

  パラメーター:

  host - 接続するホスト

  port - 接続するポート

  戻り値:

  作成された RSocketRequester

  導入:

  5.3

• websocket

  RSocketRequester websocket(URISE uri)

  WebSocket を介して指定された URL に接続する RSocketClient を使用して RSocketRequester を構築します。リクエスターを使用して、同時にリクエストを行うことができます。リクエストは共有接続を介して行われ、さらにリクエストが行われると、必要に応じて再確立されます。

  パラメーター:

  uri - 接続する URL

  戻り値:

  作成された RSocketRequester

  導入:

  5.3

• transport

  RSocketRequester transport(io.rsocket.transport.ClientTransport transport)

  ClientTransport がすでに初期化されている tcp(String, int) および websocket(URI) のバリアント。

  パラメーター:

  transport - 接続するトランスポート

  戻り値:

  作成された RSocketRequester

  導入:

  5.3

• transports

  RSocketRequester transports(Publisher<ListSE<io.rsocket.loadbalance.LoadbalanceTarget>> targetPublisher, io.rsocket.loadbalance.LoadbalanceStrategy loadbalanceStrategy)

  指定された LoadbalanceRSocketClient を介して選択された指定されたターゲットの 1 つに接続する LoadbalanceRSocketClient を使用して RSocketRequester を構築します。

  パラメーター:

  targetPublisher - 負荷分散するターゲットトランスポートのリストを提供する Publisher。指定されたリストは、Publisher によって定期的に更新される場合があります。

  loadbalanceStrategy - 負荷分散ターゲットのリストから選択するために使用する戦略。

  戻り値:

  作成された RSocketRequester

  導入:

  5.3

• connectTcp

  @DeprecatedSE reactor.core.publisher.Mono<RSocketRequester> connectTcp(StringSE host, int port)

  使用すべきではありません。

  5.3 現在、tcp(String, int) を推奨

  TCP 経由でサーバーに接続します。

  パラメーター:

  host - サーバーホスト

  port - サーバーポート

  戻り値:

  接続用の RSocketRequester 

  関連事項:

  • TcpClientTransport

• connectWebSocket

  @DeprecatedSE reactor.core.publisher.Mono<RSocketRequester> connectWebSocket(URISE uri)

  使用すべきではありません。

  5.3 現在、websocket(URI) を推奨

  WebSocket 経由でサーバーに接続します。

  パラメーター:

  uri - RSocket サーバーのエンドポイント URI

  戻り値:

  接続用の RSocketRequester 

  関連事項:

  • WebsocketClientTransport

• connect

  @DeprecatedSE reactor.core.publisher.Mono<RSocketRequester> connect(io.rsocket.transport.ClientTransport transport)

  使用すべきではありません。

  5.3 現在、transport(ClientTransport) を推奨

  指定された ClientTransport でサーバーに接続します。

  パラメーター:

  transport - 使用するクライアントトランスポート

  戻り値:

  接続用の RSocketRequester