project-reactor 相关问题

Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。

使用WebClient和Reactor 3.0进行递归API调用

我终于用Reactor学习函数式编程了。所以我是新手。我想做的第一件事是使用WebClient调用外部API。这个调用需要作为响应递归...

java spring-webflux project-reactor

回答 1 投票 0

合并热通量源

在带有Reactor的Spring Boot 2中，我试图合并两个Flux热源。但是，合并似乎只会在合并中报告两个Flux参数中的第一个。我如何获得合并...

java spring-webflux project-reactor

回答 1 投票 0

Mono vs Flux in Reactive Stream

根据文档：Flux是一个可以发出0..N元素的流：Flux fl = Flux.just（“a”，“b”，“c”）; Mono是一个0..1元素的流：Mono mn = Mono.just（“......

spring-boot reactive-programming project-reactor reactive-streams

回答 3 投票 22

如何检查Mono是否为空？

我正在使用WebFlux框架开发一个使用Spring Boot 2.0和Kotlin的应用程序。我想在保存交易之前检查用户ID是否退出。我被困在一个简单的事情，如验证如果一个单声道......

spring kotlin project-reactor reactive

回答 2 投票 12

Mono vs CompletableFuture

CompletableFuture在单独的线程上执行任务（使用线程池）并提供回调函数。假设我在CompletableFuture中有一个API调用。那是一个API调用阻塞吗？将 ...

reactive-programming project-reactor

回答 1 投票 7

用于存储先前映射结果的语法

我想知道在spring web-flux中使用先前映射结果的好方法，例如Mono.just（request）... .flatMap（object0 - > createObject1（object0））。flatMap（object1 - > .. 。

project-reactor

回答 2 投票 1

Spring WebFlux：只允许一个连接接收用户

我正在用Spring 5 Webflux和Kotlin编写一个简单的应用程序。我试图以下列方式实现PUT端点：PUT（“/ confs / {id}”，{val id = it.pathVariable（“id”）ServerResponse.ok（）....

spring-boot kotlin project-reactor spring-webflux reactor-netty

回答 3 投票 2

使用Flux连续减少状态

假设我有两种事件类型（A和B）和以某种方式生成它们的Fluxes：Fluxinstanceof

java project-reactor

回答 1 投票 0

Spring Reactive kafka Receiver始终将引导服务器覆盖到localhost

我正在尝试使用@EnableKafka和@KafkaListener注释为Reactive Kafka使用者编写Spring启动应用程序。我已经配置我的kafka经纪人在不同的机器上。当我给...

spring-boot apache-kafka spring-data project-reactor spring-kafka

回答 1 投票 0

如何在Spring Webflux / Reactor Netty Web应用程序中执行阻塞调用

在我的用例中，我有一个带有Reactor Netty的Spring Webflux微服务，我有以下依赖项：org.springframework.boot.spring-boot-starter-webflux（2.0.1.RELEASE）org ....

spring-data-mongodb spring-webflux project-reactor reactor-netty

回答 1 投票 6

使HTTP端点返回Flux / Mono实例而不是DTO的好处[关闭]

我看过Spring Tips：使用Spring Framework 5.0的功能反应端点，并阅读了一些关于spring reactor的内容，但我无法理解它。拥有端点有什么好处......

spring netty reactive-programming spring-webflux project-reactor

回答 2 投票 16

反应式WebSocketClient数据发布

我试图使用ReactorNettyWebSocketClient从websocket读取数据，但我无法连接到它的api。问题是我收到的所有数据都可以在lambda -...的内部获得。

java spring-webflux project-reactor reactor-netty

回答 2 投票 0

Reactor - 使用Flux.publish（）可以防止StepVerifier.thenCancel（）工作？

如果我直接使用我的焊剂与StepVerifier工作正常，但如果我在焊剂上调用publish（）。autoConnect（）并使用StepVerifier的结果，那么verify（）步骤永远不会完成。例如。一世 ...

java project-reactor

回答 1 投票 1

Access post方法json请求webflux响应式编程中的Body参数

如何访问Mono类型的RequestBody参数。 Spring Boot Webflux反应灵敏。我想返回一个ResponseEntity而不是Mono。 @RequestMapping（value =“/ poststudentdata”，method = ...

spring-boot spring-webflux project-reactor reactive

回答 1 投票 0

如何在反应链中传递数据

每当我需要将数据传递到反应链时，我最终会做这样的事情：public Mono doFooAndPassDtoAsMono（Dto dto）{return Mono.just（dto）.flatMap（dtoMono -...

project-reactor

回答 2 投票 1

反应式编程如何对数据库更改做出反应？

我是主题反应式编程的新手，因此有一些问题。我正在开发一个小软件。我想借此机会更好地了解反应式编程。所以我 ...

reactive-programming project-reactor spring-data-r2dbc

回答 2 投票 0

有没有办法将Flux作为表单数据提供给WebClient的正文？

我想使用WebClient访问某些受限资源，因此需要提供登录名和密码并将其编码为表单数据。它像私人单声道一样好用 ...

java spring-webflux project-reactor

回答 1 投票 0

Spring Reactor：如何在发布者发出值时抛出异常？

我正在学习使用Reactor的反应式编程，我想实现注册场景，用户可以将多个帐户分配给同一个配置文件。但是分配给...的用户名

if-statement exception switch-statement project-reactor

回答 1 投票 0

需要帮助来理解所提到的代码示例的Flat Map执行

我试图通过使用Flux和Webclient来调用rest api和累积结果。我想了解下面代码执行flatMap运算符。 list - 包含50000个元素。 ...

spring-webflux project-reactor

回答 1 投票 0

同步弹簧webflux调用保持操作顺序

我有一个简单的用例，不知道该怎么做，因为我是新的春天webflux。我正在使用spring boot webflux启动器。我需要调用2个端点。让我们说Endpoint1和Endpoint2。每当......

spring-boot spring-webflux project-reactor reactor

回答 3 投票 0

project-reactor 相关问题

最新问题