public class ReactorClientHttpConnector extends ObjectSE implements ClientHttpConnector
ClientHttpConnector
の Reactor-Netty 実装。HttpClient
コンストラクターと説明 |
---|
ReactorClientHttpConnector() デフォルトコンストラクター。 |
ReactorClientHttpConnector(reactor.netty.http.client.HttpClient httpClient) 事前構成された HttpClient インスタンスを持つコンストラクター。 |
ReactorClientHttpConnector(ReactorResourceFactory factory, FunctionSE<reactor.netty.http.client.HttpClient,reactor.netty.http.client.HttpClient> mapper) イベントループスレッド用の LoopResources や接続プール用の ConnectionProvider を含む、外部で管理される Reactor Netty リソースを持つコンストラクター。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Mono<ClientHttpResponse> | connect(HttpMethod method, URISE uri, FunctionSE<? super ClientHttpRequest,reactor.core.publisher.Mono<VoidSE>> requestCallback) 指定された HttpMethod と URI を使用してオリジンサーバーに接続し、基になる API の HTTP リクエストを初期化して書き込むことができるときに指定された requestCallback を適用します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public ReactorClientHttpConnector()
HttpClient
を初期化します。HttpClient.create().compress()
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
- 作成されたクライアントをさらに初期化するためのマッパー public ReactorClientHttpConnector(reactor.netty.http.client.HttpClient httpClient)
HttpClient
インスタンスを持つコンストラクター。httpClient
- 使用するクライアント 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
のパブリッシャー