クラス ReactorClientHttpConnector
java.lang.ObjectSE
org.springframework.http.client.reactive.ReactorClientHttpConnector
- 実装されたすべてのインターフェース:
ClientHttpConnector
ClientHttpConnector
の Reactor-Netty 実装。- 導入:
- 5.0
- 作成者:
- Brian Clozel, Rossen Stoyanchev
- 関連事項:
HttpClient
コンストラクターのサマリー
コンストラクター説明デフォルトコンストラクター。ReactorClientHttpConnector
(ReactorResourceFactory factory, FunctionSE<reactor.netty.http.client.HttpClient, reactor.netty.http.client.HttpClient> mapper) イベントループスレッド用のLoopResources
や接続プール用のConnectionProvider
を含む、外部で管理される Reactor Netty リソースを持つコンストラクター。ReactorClientHttpConnector
(reactor.netty.http.client.HttpClient httpClient) 事前構成されたHttpClient
インスタンスを持つコンストラクター。メソッドのサマリー
修飾子と型メソッド説明reactor.core.publisher.Mono<ClientHttpResponse>
connect
(HttpMethod method, URISE uri, FunctionSE<? super ClientHttpRequest, reactor.core.publisher.Mono<VoidSE>> requestCallback) 指定されたHttpMethod
とURI
を使用してオリジンサーバーに接続し、基になる API の HTTP リクエストを初期化して書き込むことができるときに指定されたrequestCallback
を適用します。
コンストラクターの詳細
ReactorClientHttpConnector
public ReactorClientHttpConnector()デフォルトのコンストラクター。HttpClient
を初期化します。HttpClient.create().compress()
ReactorClientHttpConnector
public ReactorClientHttpConnector(ReactorResourceFactory factory, FunctionSE<reactor.netty.http.client.HttpClient, reactor.netty.http.client.HttpClient> mapper) イベントループスレッド用のLoopResources
や接続プール用のConnectionProvider
を含む、外部で管理される Reactor Netty リソースを持つコンストラクター。このコンストラクターは、クライアントを Reactor Netty グローバルリソースに参加させたくない場合にのみ使用してください。デフォルトでは、クライアントは
HttpResources
に保持されている Reactor Netty グローバルリソースに参加します。これは、固定された共有リソースがイベントループの同時実行に適しているため推奨されます。ただし、Spring ApplicationContext が閉じているときに Reactor Netty グローバルリソースが確実にシャットダウンされるように、globalResources=true
を使用してReactorResourceFactory
Bean を宣言することを検討してください。- パラメーター:
factory
- リソースを取得するリソースファクトリmapper
- 作成されたクライアントをさらに初期化するためのマッパー- 導入:
- 5.1
ReactorClientHttpConnector
public ReactorClientHttpConnector(reactor.netty.http.client.HttpClient httpClient) 事前構成されたHttpClient
インスタンスを持つコンストラクター。- パラメーター:
httpClient
- 使用するクライアント- 導入:
- 5.1
メソッドの詳細
connect
public reactor.core.publisher.Mono<ClientHttpResponse> connect(HttpMethod method, URISE uri, FunctionSE<? super ClientHttpRequest, reactor.core.publisher.Mono<VoidSE>> requestCallback) インターフェースからコピーされた説明:ClientHttpConnector
指定されたHttpMethod
とURI
を使用してオリジンサーバーに接続し、基になる API の HTTP リクエストを初期化して書き込むことができるときに指定されたrequestCallback
を適用します。- 次で指定:
- インターフェース
ClientHttpConnector
のconnect
- パラメーター:
method
- HTTP リクエストメソッドuri
- HTTP リクエスト URIrequestCallback
- リクエストの準備と書き込みを行い、書き込みが完了したことを通知するパブリッシャーを返す関数。実装は、ReactiveHttpOutputMessage.writeWith(org.reactivestreams.Publisher<? extends org.springframework.core.io.buffer.DataBuffer>)
またはReactiveHttpOutputMessage.setComplete()
を呼び出すことによってMono<Void>
を返すことができます。- 戻り値:
ClientHttpResponse
のパブリッシャー