spring-webflux

1熱

1答えて

WebFluxウェブとwebfluxスターター

私はwebflux starterとSpring boot 2.0.0.M7プロジェクトを作成しました。 私はserver.servlet.context-pathを追加しましたが、Webスターターも追加しないと機能しません。 両方のスターターを追加すると、ノンブロッキング機能に問題はありますか？ 私はGatlingでいくつかのストレステストを実行しましたが、Webスターターを外したり追加したりす

spring-webflux 2017-12-15

---

4熱

1答えて

サブスクリプションの仕事とブロックがSpring反応Mongoにないのはなぜですか？

Kotlin,Gradle,M7およびWeb-reactiveを選択して、Spring Initializrから新しいプロジェクトを作成しました。私はデータベースに三人を保存しよう data class Person (val id: String) @Component class PersonHandler(val template: ReactiveMongoTemplate) {

mongodb spring-boot spring-data-mongodb project-reactor spring-webflux 2017-12-21

---

4熱

1答えて

Spring Security Webflux/Reactive Exception Handling

私はspring webfluxにアプリケーションをビルドしています。スプリングセキュリティwebflux（v.M5）は例外処理の際にSpring 4のように振る舞いませんでした。私たちは、例外がServerSecurityContextRepository.loadで、春には500と、この例外を操作するために私ができることは何にHTTPヘッダを更新するとしましょう投げる場合 Spring web

spring-security spring-webflux 2017-12-24

---

0熱

1答えて

春はwebflux：このドキュメントは言うボディサーター

で応答本体にモノラル を送信する方法： https://docs.spring.io/spring/docs/current/spring-framework-reference/web-reactive.html ServerResponseは、HTTPレスポンスへのアクセスを提供します。それは不変なので、Builderを使用してServerResponseを作成します。ビルダを使用すると、応答

spring spring-boot spring-webflux 2017-12-24

---

1熱

1答えて

SpringクラウドストリームバインダーkafkaがNettyで実行されない

HTTP上で継続的な状態変更を提供するために、Kafka SteamsとSpring WebfluxをNetty上で使用してストリーミングエンジンを構築したいと考えています。私は私のGradleファイル春のブートアプリで compile('org.springframework.cloud:spring-cloud-stream-binder-kafka') 依存関係を持っている場合、私は気づ

spring-cloud-stream spring-webflux 2017-12-24

---

3熱

2答えて

モノ

ドキュメントあたりとおり Flux<String> fl = Flux.just("a", "b", "c"); モノが0のストリームである： フラックス0..N要素を発することができるストリームであります..1要素： Mono<String> mn = Mono.just("hello"); 両方とも、リアクティブストリーム内のPublisherインターフェイスの実装です。 ほとんどの場

spring-boot reactive-programming spring-webflux reactive-streams 2017-12-27

---

1熱

1答えて

将来のイベントのために有限ソース上のリアクティブストリームが残っています

私は、非ブロッキングI/O（Spring Boot 2.0.0.M7）にSpring Webflux、Spring Data、およびProject Reactorを使用しています。 私の目標は、クライアントがいくつかの基準に基づいてエンドポイントからすべてのリソースを要求できるように株式ティッカーのようなAPIを作成し、最初のリクエスト後に作成される新しいリソースを受け取ることです。 Reacti

spring-data reactive-programming project-reactor spring-webflux 2017-12-27

---

1熱

1答えて

2つのFluxをzipWithを組み合わせて使用​​するとエラーが発生する

反応性のあるストリームを学習し、次のように2つのFluxを組み合わせようとしています。 List<Integer> elems = new ArrayList<>(); Flux.just(10,20,30,40) .log() .map(x -> x * 2) .zipWith(Flux.range(0, Integer.MAX_VALUE

publish-subscribe spring-webflux reactive-streams 2017-12-28

---

1熱

1答えて

Fluxはnull値を受け入れませんか？

Fluxのセットがあるとします。これは、二重機能と一緒に圧縮したいと考えています。オブジェクトが特定の制約を満たしている場合 Flux<String> flux1 = Flux.just("A", "B", "C"); Flux<String> flux2 = Flux.just("D", "E", "F"); Flux.zip(flux1, flux2, this::zipString).s

java spring project-reactor spring-webflux 2017-12-29

---

3熱

1答えて

Flux <DataBuffer>を解凍するにはどうすればいいですか？

私は中間記憶装置なしで圧縮された（GZIP）ストリームを読み書きする必要があります。現在、私は執筆のためにSpring RestTemplateを使用していますが、Apache HTTPクライアントは読み込みを行います（大きなストリームの読み込みにRestTemplateを使用できない理由については、私の答えhereを参照してください）。実装はかなり簡単です。ここでを応答InputStreamで叩

java spring spring-integration netty spring-webflux 2017-12-31

---