public static interface RSocketRequester.BuilderRSocketRequester.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 - 接続するポート RSocketRequesterRSocketRequester websocket(URISE uri)
RSocketClient を使用して RSocketRequester を構築します。リクエスターを使用して、同時にリクエストを行うことができます。リクエストは共有接続を介して行われ、さらにリクエストが行われると、必要に応じて再確立されます。uri - 接続する URLRSocketRequesterRSocketRequester transport(ClientTransport transport)
transport - 接続するトランスポート RSocketRequesterRSocketRequester 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