project-reactor 相关问题

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

FluxProcessor：检索类似rx的Subject的订阅上的最后发出的值

当前，FluxProcessor订阅仅检索那些在订阅后发出的值。但是我想在订阅时检索Flux中的最后一个值，例如，像RX的...

java spring spring-webflux project-reactor reactive

回答 1 投票 0

为什么从WebClient访问REST终结点的处理程序两次？

java rest reactive-programming spring-webflux project-reactor

回答 1 投票 0

Mono.fromCallable默认在调用线程上执行？

我正在尝试使用Project Reactor的Mono.fromCallable（Callable）执行异步操作，并且在我的测试案例中，我注意到它似乎正在调用线程上运行。是...

java project-reactor

回答 1 投票 0

使用WebClient Spring WebFlux的多个请求

我正在尝试使用WebClient并行发出请求，但是我不知道如何执行该操作，因为无论我做什么，代码都不会等待请求完成。如果我只执行一个...

spring kotlin spring-webflux project-reactor reactor-netty

回答 1 投票 0

使用生菜反应式命令订阅redis频道（pubsub）

我正在使用io.lettuce.core库，但在使用RedisPubSubReactiveCommands接口订阅频道时遇到问题。我有一个StatefulRedisPubSubConnection和一个活动的Redis ...

java redis project-reactor lettuce

回答 1 投票 0

onErrorResume和doOnError之间的区别

在Spring Reactor项目中，onErrorResume和doOnError有什么区别？而当我应该每个人？

spring project-reactor

回答 1 投票 0

从Spring调试服务器发送的事件

根据Spring文档，当返回Flux时，Spring应该为订阅返回的每个元素发出一个服务器发送的事件。这是一个典型的REST控制器：package ...

java spring spring-webflux project-reactor

回答 1 投票 4

如何以被动方式使用InputStream和OutputStream

我正在尝试读取Excel文件以对其进行操作或向其中添加新数据并写回。我也正在尝试使用Flux和Mono完成一个完整的反应过程。这个想法是返回...

spring-boot spring-webflux project-reactor

回答 1 投票 1

使用Web Flux和Mongo DB保存多个记录

我正在一个使用Spring web Flux和mongo DB的项目中工作，我对反应式编程和WebFlux还是很陌生。我有使用一种服务保存到3个集合中的方案。对于每个...

spring mongodb spring-webflux project-reactor reactive

回答 1 投票 0

Flux：过滤异常

我正在尝试使用onErrorContinue过滤来自Flux / Mono的异常，但是永远不会触发它。导入org.junit.jupiter.api.Test;导入reactor.core.publisher.Flux;进口反应堆....

java spring-webflux project-reactor

回答 1 投票 0

Reactor重试不调用要重试的方法

我有一个总是返回Mono.error的方法private Mono doSomething（）{System.out.println（“ doSomething”）;返回Mono.error（new Error（））; }我试图重试...

java project-reactor

回答 2 投票 1

flatMap vs map，基本的解释还可以，但是当我的转换函数本身不同步时会发生什么？

[我喜欢整个网络中反应堆中复杂概念的基本解释，它们在生产代码中并不是特别有用，因此，我编写的下面一段代码使用...]向kafka发送了一条消息，

project-reactor

回答 1 投票 0

如何处理异常和春季webflux返回正确的HTTP代码？

我有使用Mono.fromfuture（结果），并且抛出CustomException 400作为状态其给出响应的方法。现在在我的服务类，当我调用该方法，错误和代码，我...

spring-boot exception-handling reactive-programming spring-webflux project-reactor

回答 1 投票 1

使用工程反应堆时，需要resilience4j？

工程反应堆有超时功能，重试，回退功能WRT异常，背压。当我在微服务世界春云使用Spring WebFlux与工程反应堆，做...

spring-cloud spring-webflux project-reactor spring-cloud-netflix resilience4j

回答 1 投票 1

电抗器：展开一个ParallelFlux

我有一个项目的集合，需要自扩展需要IO操作进行扩展，所以我选择了反应器的反应能力。这里是一块工作代码：公共助焊剂

java reactive-programming project-reactor

回答 1 投票 1

与反应堆抛出异常的正确方法

我是新来的工程反应堆和反应式编程一般。我目前正在在一张类似下面的代码：Mono.just（用户ID）.MAP（回购:: findById）.MAP（用户> {如果（...

java reactive-programming project-reactor reactor

回答 1 投票 9

下一个（）与单（）哪一个是有效的？

我想从投光通量为单声道。但是，我不能决定何时使用单（）或next（），不知道哪一个更有效？助焊剂 optionalIdsFlux =磁通.fromIterable（结果....

java spring spring-webflux project-reactor reactive

回答 2 投票 0

.transform / .compose复制单声道执行使用Spring Security

尽管实现基于Spring的安全反应的身份认证解决方案，我面临着在生产链的操作在某些时候得到重复的问题。从这一点，一切都来了两次....

spring-boot spring-webflux project-reactor

回答 2 投票 0

获取无功流置换

我有两个应该异步工作流反应。因此，我应该调用foo（）函数将两个参数，并会与元素的所有可能的排列被称为...

java spring asynchronous spring-webflux project-reactor

回答 1 投票 1

如何使用flatMap（）在反应堆语境？

我有一个问题的理解上下文。所以单证说，上下文是：A键/值存储在组件之间传输诸如经由上下文协议的运营商。上下文是...

java project-reactor

回答 1 投票 2

project-reactor 相关问题

最新问题