クラス AbstractReactorHttpExchangeAdapter
java.lang.ObjectSE
org.springframework.web.service.invoker.AbstractReactorHttpExchangeAdapter
- 実装されているすべてのインターフェース:
HttpClientAdapter、HttpExchangeAdapter、ReactorHttpExchangeAdapter
- 既知の直属サブクラス
WebClientAdapter
public abstract class AbstractReactorHttpExchangeAdapter
extends ObjectSE
implements ReactorHttpExchangeAdapter, HttpClientAdapter
同期
HttpExchangeAdapter 契約に適応する ReactorHttpExchangeAdapter 実装の便利な基本クラス。- 導入:
- 6.1
- 作成者:
- Rossen Stoyanchev
コンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明voidexchange(HttpRequestValues requestValues) 指定されたリクエストを実行し、レスポンスコンテンツがある場合はそれを解放します。exchangeForBodilessEntity(HttpRequestValues requestValues) レスポンスステータスとヘッダーへの追加アクセスを備えたHttpExchangeAdapter.exchange(HttpRequestValues)のバリアント。<T> TexchangeForBody(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) 指定されたリクエストを実行し、レスポンスのコンテンツを指定された型にデコードします。<T> ResponseEntity<T>exchangeForEntity(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) レスポンスステータスとヘッダーへの追加アクセスを備えたHttpExchangeAdapter.exchangeForBody(HttpRequestValues, ParameterizedTypeReference)のバリアント。exchangeForHeaders(HttpRequestValues requestValues) 指定されたリクエストを実行し、レスポンスコンテンツを解放し、レスポンスヘッダーを返します。同期 (ブロッキング) メソッド署名を使用して、HTTP サービスメソッドからのレスポンスをブロックする設定された時間を返します。設定されたReactiveAdapterRegistryを返します。reactor.core.publisher.Mono<ResponseEntity<VoidSE>>requestToBodilessEntity(HttpRequestValues requestValues) レスポンスステータスとヘッダーへの追加アクセスを備えたHttpClientAdapter.requestToVoid(HttpRequestValues)のバリアント。<T> reactor.core.publisher.Mono<T>requestToBody(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) 指定されたリクエストを実行し、レスポンスのコンテンツを指定された型にデコードします。<T> reactor.core.publisher.Flux<T>requestToBodyFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) 指定されたリクエストを実行し、レスポンスの内容を指定された型の要素を持つストリームにデコードします。<T> reactor.core.publisher.Mono<ResponseEntity<T>>requestToEntity(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) レスポンスステータスとヘッダーへの追加アクセスを備えたHttpClientAdapter.requestToBody(HttpRequestValues, ParameterizedTypeReference)のバリアント。<T> reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>requestToEntityFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) レスポンスステータスとヘッダーへの追加アクセスを備えたHttpClientAdapter.requestToBodyFlux(HttpRequestValues, ParameterizedTypeReference)のバリアント。reactor.core.publisher.Mono<HttpHeaders>requestToHeaders(HttpRequestValues requestValues) 指定されたリクエストを実行し、レスポンスコンテンツを解放し、レスポンスヘッダーを返します。reactor.core.publisher.Mono<VoidSE>requestToVoid(HttpRequestValues requestValues) 指定されたリクエストを実行し、レスポンスコンテンツがある場合はそれを解放します。voidsetBlockTimeout(DurationSE blockTimeout) getBlockTimeout()の説明に従って、HTTP サービスメソッドのレスポンスをブロックする時間を構成します。voidsetReactiveAdapterRegistry(ReactiveAdapterRegistry reactiveAdapterRegistry) 使用するReactiveAdapterRegistryを構成します。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.web.service.invoker.HttpClientAdapter から継承されたメソッド
asReactorExchangeAdapterインターフェース org.springframework.web.service.invoker.HttpExchangeAdapter から継承されたメソッド
supportsRequestAttributesインターフェース org.springframework.web.service.invoker.ReactorHttpExchangeAdapter から継承されたメソッド
exchangeForBodilessEntityMono, exchangeForBodyFlux, exchangeForBodyMono, exchangeForEntityFlux, exchangeForEntityMono, exchangeForHeadersMono, exchangeForMono
コンストラクターの詳細
AbstractReactorHttpExchangeAdapter
protected AbstractReactorHttpExchangeAdapter()サブクラスの protected コンストラクター。
メソッドの詳細
setReactiveAdapterRegistry
使用するReactiveAdapterRegistryを構成します。デフォルトでは、これは
ReactiveAdapterRegistry.getSharedInstance()です。getReactiveAdapterRegistry
インターフェースからコピーされた説明:ReactorHttpExchangeAdapter設定されたReactiveAdapterRegistryを返します。- 次で指定:
- インターフェース
ReactorHttpExchangeAdapterのgetReactiveAdapterRegistry
setBlockTimeout
getBlockTimeout()の説明に従って、HTTP サービスメソッドのレスポンスをブロックする時間を構成します。getBlockTimeout
インターフェースからコピーされた説明:ReactorHttpExchangeAdapter同期 (ブロッキング) メソッド署名を使用して、HTTP サービスメソッドからのレスポンスをブロックする設定された時間を返します。デフォルトでは設定されていません。この場合の動作は、基礎となる HTTP クライアントの接続およびリクエストのタイムアウト設定に依存します。基礎となる HTTP クライアントでタイムアウト値を直接構成することをお勧めします。これにより、そのような設定をより詳細に制御できるようになります。
- 次で指定:
- インターフェース
ReactorHttpExchangeAdapterのgetBlockTimeout
exchange
インターフェースからコピーされた説明:HttpExchangeAdapter指定されたリクエストを実行し、レスポンスコンテンツがある場合はそれを解放します。- 次で指定:
- インターフェース
HttpExchangeAdapterのexchange - パラメーター:
requestValues- 実行するリクエスト
exchangeForHeaders
インターフェースからコピーされた説明:HttpExchangeAdapter指定されたリクエストを実行し、レスポンスコンテンツを解放し、レスポンスヘッダーを返します。- 次で指定:
- インターフェース
HttpExchangeAdapterのexchangeForHeaders - パラメーター:
requestValues- 実行するリクエスト- 戻り値:
- レスポンスヘッダー
exchangeForBody
public <T> T exchangeForBody(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) インターフェースからコピーされた説明:HttpExchangeAdapter指定されたリクエストを実行し、レスポンスのコンテンツを指定された型にデコードします。- 次で指定:
- インターフェース
HttpExchangeAdapterのexchangeForBody - 型パラメーター:
T- レスポンスがデコードされる型- パラメーター:
requestValues- 実行するリクエストbodyType- デコードする対象の型- 戻り値:
- デコードされたレスポンス本文。
exchangeForBodilessEntity
インターフェースからコピーされた説明:HttpExchangeAdapterレスポンスステータスとヘッダーへの追加アクセスを備えたHttpExchangeAdapter.exchange(HttpRequestValues)のバリアント。- 次で指定:
- インターフェース
HttpExchangeAdapterのexchangeForBodilessEntity - 戻り値:
- ステータスとヘッダーを含むレスポンスエンティティ。
exchangeForEntity
public <T> ResponseEntity<T> exchangeForEntity(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) インターフェースからコピーされた説明:HttpExchangeAdapterレスポンスステータスとヘッダーへの追加アクセスを備えたHttpExchangeAdapter.exchangeForBody(HttpRequestValues, ParameterizedTypeReference)のバリアント。- 次で指定:
- インターフェース
HttpExchangeAdapterのexchangeForEntity - 戻り値:
- ステータス、ヘッダー、本文を含むレスポンスエンティティ。
requestToVoid
インターフェースからコピーされた説明:HttpClientAdapter指定されたリクエストを実行し、レスポンスコンテンツがある場合はそれを解放します。- 次で指定:
- インターフェース
HttpClientAdapterのrequestToVoid - パラメーター:
requestValues- 実行するリクエスト- 戻り値:
- リクエストが完全に実行され、レスポンスの内容が解放されると完了する
Mono。
requestToHeaders
インターフェースからコピーされた説明:HttpClientAdapter指定されたリクエストを実行し、レスポンスコンテンツを解放し、レスポンスヘッダーを返します。- 次で指定:
- インターフェース
HttpClientAdapterのrequestToHeaders - パラメーター:
requestValues- 実行するリクエスト- 戻り値:
- レスポンスヘッダーを返す
Monoは、リクエストが完全に実行され、レスポンスコンテンツが解放されます。
requestToBody
public <T> reactor.core.publisher.Mono<T> requestToBody(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) インターフェースからコピーされた説明:HttpClientAdapter指定されたリクエストを実行し、レスポンスのコンテンツを指定された型にデコードします。- 次で指定:
- インターフェース
HttpClientAdapterのrequestToBody - 型パラメーター:
T- レスポンスがデコードされる型- パラメーター:
requestValues- 実行するリクエストbodyType- デコードする対象の型- 戻り値:
- デコードされたレスポンスを返す
Mono。
requestToBodyFlux
public <T> reactor.core.publisher.Flux<T> requestToBodyFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) インターフェースからコピーされた説明:HttpClientAdapter指定されたリクエストを実行し、レスポンスの内容を指定された型の要素を持つストリームにデコードします。- 次で指定:
- インターフェース
HttpClientAdapterのrequestToBodyFlux - 型パラメーター:
T- レスポンスがデコードされる型- パラメーター:
requestValues- 実行するリクエストbodyType- デコード先のターゲットストリーム要素の型- 戻り値:
- デコードされたストリーム要素を持つ
Flux。
requestToBodilessEntity
public reactor.core.publisher.Mono<ResponseEntity<VoidSE>> requestToBodilessEntity(HttpRequestValues requestValues) インターフェースからコピーされた説明:HttpClientAdapterレスポンスステータスとヘッダーへの追加アクセスを備えたHttpClientAdapter.requestToVoid(HttpRequestValues)のバリアント。- 次で指定:
- インターフェース
HttpClientAdapterのrequestToBodilessEntity
requestToEntity
public <T> reactor.core.publisher.Mono<ResponseEntity<T>> requestToEntity(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) インターフェースからコピーされた説明:HttpClientAdapterレスポンスステータスとヘッダーへの追加アクセスを備えたHttpClientAdapter.requestToBody(HttpRequestValues, ParameterizedTypeReference)のバリアント。- 次で指定:
- インターフェース
HttpClientAdapterのrequestToEntity
requestToEntityFlux
public <T> reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>> requestToEntityFlux(HttpRequestValues requestValues, ParameterizedTypeReference<T> bodyType) インターフェースからコピーされた説明:HttpClientAdapterレスポンスステータスとヘッダーへの追加アクセスを備えたHttpClientAdapter.requestToBodyFlux(HttpRequestValues, ParameterizedTypeReference)のバリアント。- 次で指定:
- インターフェース
HttpClientAdapterのrequestToEntityFlux