spring-webflux

1熱

1答えて

私のアプリケーションでは、サーバーとユーザーがあり、各ユーザーは複数のサーバーを持つことができます。 User内のサーバーのリストです@DBref：私はその後、私は、ユーザーのサーバーリストにサーバーを追加し、ユーザーを保存し、私が最初に作成し、サーバーを保存し、サーバーを作成したいコントローラで @DBRef private List<Server> servers; ： @PostMap

1熱

1答えて

Spring WebFlux Broken Streamエラー処理

Spring WebFluxでエラー処理を実装する方法に関する良い例を見つけるのに苦労しています。処理したいユースケースは、ストリームが予期せず終了したことをHTTPクライアントに通知することです。私が何を発見したのは、ストリーム処理が終了したとき、例えばx項目が処理された後にRuntimeExceptionを発生させるなどの処理が、あまりにも上手く処理されるということです。例外が発生して接続が

0熱

1答えて

特定のレコードを文書内に埋め込んで更新

これは初めてのMongoDBとSpring-data-mongoです。 Companyオブジェクトが、私は与えられたplateNumber Obviouslと車両用currentLocationフィールドを更新したいと思います @Document public class Company { @Id private String id; private String

3熱

1答えて

Reactor Mono対CompletableFuture

原子炉プロジェクトを探求し始めたばかりで、MonoとFluxの抽象概念であり、java 8ベアボーンCompletableFutureとの基本的な違いを理解したいと思います。 CompletableFutureと public static void main(String[] args) throws Exception { Mono.fromCallable(() -> getDa

1熱

1答えて

Spring 5 Reactive - WebExceptionHandlerが呼び出されない

what is the right way to handle errors in spring-webfluxに提案されている3つのソリューションをすべて試しましたが、は呼び出されません。私はSpring Boot 2.0.0.M7を使用しています。 GitHubのレポhere @Configuration class RoutesConfiguration { @Autowire

1熱

1答えて

BubblingExceptionを処理する方法

私はWebリクエストを行っているMonoを2人持っており、Mono.zipを使用して結果をマージします。要求の1つにエラーがある場合は、onErrorMapでエラーを処理して、カスタムWebExceptionHandlerで処理が遅れる例外を変換してみてください。しかし、私は、原子炉で処理されないこの例外を取得することを実行して： private fun <T> createMono(client

1熱

1答えて

Spring 5のmongodbにユーザーを保存できませんWebFlux

Spring WebFluxと反応的なスタイルでMongoデータベースにユーザーを保存しようとしましたが、データが保存されないため、Java 8、Spring 5、mongodbがあります。これは私の設定です：マイエンティティ： @Document public class User { @Id private String id; private String

1熱

1答えて

なぜ春webfluxがデフォルトで桟橋を選んでいて失敗したのですか？

私はSpringブート2.0.0.M7ベースのアプリケーションを実行しようとしています。ここでは、私は私のbuild.gradleに持って春に関連する依存関係です：自動レポートに基づいて compile "org.springframework.boot:spring-boot-starter-webflux:2.0.0.M7" compile "org.springframework.boo

1熱

1答えて

Spring Boot：ReactiveCrudRepositoryがBeanによって実装されていません。

データを反応的に保存するためにCassandraを使用する予定です。これを行うには、私は次のインターフェイスを書いた： @Repository public interface ContributorStatRepository extends ReactiveCrudRepository<ContributorStat, Long> { Flux<ContributorStat> f

1熱

1答えて

Fluxの代わりにMonoをいつ使用する必要がありますか？

Monoは、要素を放出することによって正常に完了する基本的なrx演算子を持つReactive Streams Publisherとして定義され、Fluxは0〜N要素の同じ形式です。 FluxではなくMonoを1つの要素ストリームにのみ使用する理由とその理由を教えてください。