public static interface RSocketRequester.Builder
RSocketRequester.Builder dataMimeType(@Nullable MimeType mimeType)
SETUP
フレームで指定するペイロードデータ MimeType を構成します。 設定されていない場合、これは最初の non-default
Decoder
の MimeType、または最初のデコーダーの MimeType に初期化されます。
RSocketRequester.Builder metadataMimeType(MimeType mimeType)
SETUP
フレームで指定します。 デフォルトでは、これは "message/x.rsocket.composite-metadata.v0"
に設定されています。この場合、ルートが指定されている場合、"message/x.rsocket.routing.v0"
複合メタデータエントリとしてエンコードされます。これが他の MimeType に設定されている場合、ルートの MimeType が提供されていると想定されます。
RSocketRequester.Builder setupData(ObjectSE data)
dataMimeType(MimeType)
に従ってエンコードされます。データは、具体的な値、または ReactiveAdapterRegistry
を介して Publisher
に適合できる単一の値の任意のプロデューサーです。デフォルトでは、これは設定されていません。
RSocketRequester.Builder setupRoute(StringSE route, ObjectSE... routeVars)
RSocketRequester.route(String, Object...)
で説明されているリクエストルートのルールと同じです。デフォルトでは、これは設定されていません。
RSocketRequester.Builder setupMetadata(ObjectSE value, @Nullable MimeType mimeType)
setupRoute(String, Object...)
に加えて呼び出される場合は、複合メタデータが使用されている必要があります。メタデータ値は、ReactiveAdapterRegistry
を介して Publisher
に適合させることができる具体的な値または単一の値の任意のプロデューサーです。RSocketRequester.Builder rsocketStrategies(@Nullable RSocketStrategies strategies)
RSocketStrategies
を提供します。 これはデフォルト設定を変更できますが、それでも rsocketStrategies(Consumer)
を介してさらにカスタマイズできます。設定しない場合、デフォルトは RSocketStrategies.builder()
から取得されます。
strategies
- 使用する戦略 RSocketRequester.Builder rsocketStrategies(ConsumerSE<RSocketStrategies.Builder> configurer)
RSocketStrategies
をカスタマイズします。RSocketStrategies
をさらにカスタマイズしたり、set
の場合は変更したり、RSocketStrategies.builder()
のデフォルトから開始したりできます。}。
RSocketRequester.Builder rsocketConnector(RSocketConnectorConfigurer configurer)
RSocketConnector
を直接構成するためのコールバック。RSocketConnector
で直接設定することはできず、オーバーライドされます。代わりに、このビルダーのショートカット dataMimeType(MimeType)
および metadataMimeType(MimeType)
を使用してください。DataBufferFactory
と一致するように設定されます。setupPayload
の場合、このビルダーのメソッドを使用して、ルート、その他のメタデータ、データをエンコードするオブジェクト値として指定することを検討してください。RSocketMessageHandler.responder(RSocketStrategies, Object...)
を参照してください。RSocketRequester.Builder apply(ConsumerSE<RSocketRequester.Builder> configurer)
Consumer
を介してこのビルダーを構成します。これにより、Spring Security などのライブラリは、関連する一連のカスタマイズを適用するためのショートカットを提供できます。configurer
- 適用するコンフィギュレーター RSocketRequester tcp(StringSE host, int port)
RSocketClient
を使用して RSocketRequester
を構築します。リクエスターを使用して、同時にリクエストを行うことができます。リクエストは共有接続を介して行われ、さらにリクエストが行われると、必要に応じて再確立されます。host
- 接続するホスト port
- 接続するポート RSocketRequester
RSocketRequester websocket(URISE uri)
RSocketClient
を使用して RSocketRequester
を構築します。リクエスターを使用して、同時にリクエストを行うことができます。リクエストは共有接続を介して行われ、さらにリクエストが行われると、必要に応じて再確立されます。uri
- 接続する URLRSocketRequester
RSocketRequester transport(ClientTransport transport)
transport
- 接続するトランスポート RSocketRequester
RSocketRequester transports(Publisher<ListSE<LoadbalanceTarget>> targetPublisher, LoadbalanceStrategy loadbalanceStrategy)
LoadbalanceRSocketClient
を介して選択された指定されたターゲットの 1 つに接続する LoadbalanceRSocketClient
を使用して RSocketRequester
を構築します。targetPublisher
- 負荷分散するターゲットトランスポートのリストを提供する Publisher
。指定されたリストは、Publisher
によって定期的に更新される場合があります。loadbalanceStrategy
- 負荷分散ターゲットのリストから選択するために使用する戦略。RSocketRequester
@DeprecatedSE reactor.core.publisher.Mono<RSocketRequester> connectTcp(StringSE host, int port)
tcp(String, int)
に変更 host
- サーバーホスト port
- サーバーポート RSocketRequester
TcpClientTransport
@DeprecatedSE reactor.core.publisher.Mono<RSocketRequester> connectWebSocket(URISE uri)
websocket(URI)
に変更 uri
- RSocket サーバーのエンドポイント URIRSocketRequester
WebsocketClientTransport
@DeprecatedSE reactor.core.publisher.Mono<RSocketRequester> connect(ClientTransport transport)
transport(ClientTransport)
に変更 ClientTransport
でサーバーに接続します。transport
- 使用するクライアントトランスポート RSocketRequester