spring-webflux

0熱

1答えて

"spring-boot-starter-parent"を使用しているときにMavenでlower Elastic検索バージョンを使用する方法

Webfluxのバージョンが "2.0.0.BUILD-SNAPSHOT"の "spring-boot-starter-parent"を使用しています。私はデータソースとしてElasticsearchを使用しています。だから、私は "spring-boot-starter-data-elasticsearch"をpom.xmlに含めました。これはデフォルトで5.4.0のESバージョンを含みます。し

2熱

1答えて

郵便配達でのSpring 5 Reactive APIからの返答を表示するには？

私は自分のアプリケーション内の次のエンドポイントがあります。 @GetMapping(value = "/users") public Mono<ServerResponse> users() { Flux<User> flux = Flux.just(new User("id")); return ServerResponse.ok() .contentTyp

1熱

1答えて

スプリングブート2.0.0.M1でSNAKE_CASEを「グローバルに」使用するようにジャクソンを設定してください。

私はスプリングブート2.0.0.M1（したがって、スプリング5.0.0.RC1）を使用しています。 PropertyNamingStrategy.SnakeCaseStrategy.SNAKE_CASEを使用するように設定しようとしていますが、これまでのところ動作しません。私が試した：とapplication.ymlファイル：：ObjectMapper豆の設定 @Bean @Primary

1熱

1答えて

WebClientの使用を確認/テストする方法

WebClientを使用するクラスを単体テストする必要があります。 WebClientを扱う良い方法はありますか？ RestTemplateで私は簡単にMockitoを使うことができました。 public class MyOperations { private final WebClient webClient; public MyOperations(WebClient

1熱

1答えて

Project Reactor composing Flux.zip（）

私はこの小さなアプリケーションでProject Reactor 3.0を学ぼうとしていました。私はFlux.zip（）関数を構成して、変数をMovieオブジェクトに結合するのに苦労しています。 Reactorでは戻り値の型がFlux<Tuple5<>>のようです。 RxJava2では、Function5<>を返します。 RxJava2 Single<Movie> movie = Single.zi

2熱

2答えて

Spring Boot 2.0.0.M2の@BeanメソッドでRouterFunctionを登録するには？

私はSpring 5の機能を使いこなしていますが、RouterFunctionという登録に問題がありますが、読み込まれますがマッピングされません。（メソッドで例外をスローすることによってしようとしました。） @Configuration @RequestMapping("/routes") public class Routes { @Bean public Router

2熱

1答えて

WebTestClientとControllerAdviceを使用したユニットテストスプリングコントローラ

私のコントローラと、特定のケースをユニットテストしようとしています。私のサービスはMono.Emptyを返します。私はNotFoundExceptionをスローします。 @ControllerAdvice public class RestResponseEntityExceptionHandler { @ExceptionHandler(value = { NotFoundExce

5熱

1答えて

spring-webfluxで現在のリクエストのコンテキストを取得する方法

古典的なspring-mvcでは、リクエストスコープ属性をRequestContextHolderに設定することができます。それに基づいて、HandlerInterceptorAdapterで着信要求を解析し、現在ログインしているユーザー、一意の要求ID（ログ相関）などの要求パラメータを設定できます。これらのリクエスト属性は、リクエストの有効期間中に（コントローラだけでなく）サービスから静的に取

0熱

2答えて

Spring Web-Flux：要求に応じてFluxをWebクライアントに戻す方法は？

私たちはスプリングブート2.0.0.BUILD_SNAPSHOTとスプリングブートwebflux 5.0.0で作業しています。現在、要求に応じてクライアントにフラックスを転送することはできません。現在、私はイテレータからの磁束を作成しています： public Flux<ItemIgnite> getAllFlux() { Iterator<Cache.Entry<String, Ite

3熱

1答えて

WebClientを使用してReactive Spring Rest APIを使用する方法

バックエンドジョブ（実行可能なjar）にreactive rel API（spring webfluxで構築）を使用する必要があります。私はSpring WebClientについて読んだことがありますが、私はいくつかの点を理解していません。例えば：最後の行で WebClient webClient = WebClient.create("http://localhost:8080"); M