project-reactor 相关问题

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

我有两个对象 CarParts { String id WorkItem workItem } WorkItemResponse { List 资源。

spring webclient spring-webflux project-reactor

回答 1 投票 0

我有这样的Mono代码： return Mono.just(operation) .map(this::validate) .then(execute(operation)) .doOnError(ValidationException.class, this::handleValidationException) ...

spring-boot spring-webflux project-reactor

回答 1 投票 1

使用flatMapMany(Flux::fromIterable)时，Kotlin类型推理的反应器失败了。

试图将一个内部有iterable的Mono对象转换为Flux，我得到了这个错误(kotlinc console)：>>> Mono.just(listOf(1,2,3,4,5)).flatMapMany(Flux::fromIterable) 错误：类型 ...

kotlin project-reactor

回答 1 投票 0

当之前的发行商失败或坏掉时，如何切换到新的发行商？

假设有三个实体。单体的供应商 - ValuesSource的供应商--发布者 ValuesSource--发布者的值（它们的性质并不重要，即String）......

java spring-webflux project-reactor

回答 1 投票 0

如何根据反应器的上下文来改变webClient的网址？

基于一个已经添加在webfilter上的国家，我需要修改发送到不同服务器的请求。我已经在链上添加了webfilter的上下文，我可以在这里看到它，但我没有找到......

spring-webflux project-reactor spring-webclient spring-reactor

回答 1 投票 -1

结合非阻塞和阻塞调用，并在Spring Webflux中返回结果。

我在使用Spring Webflux和Spring boot 2，我的方案是这样的。Controller @GetMapping(path="products") public List getProducts(){ return serviceObj.getProducts()...。

spring-boot spring-webflux project-reactor nonblocking spring-reactive

回答 0 投票 0

正在寻找retryWhen的替代品，现在不推荐使用

我面临WebClient和Reactor-Extra的问题。实际上，我有以下方法：public Employee getEmployee（String employeeId）{return webClient.get（）....

spring-boot reactive-programming project-reactor spring-webclient reactor-netty

回答 1 投票 1

如何合并两个执行两个反应堆通量以返回列表并合并结果

我有一个LegacyAccountDto，我需要从两个单独的来源构建一个列表。一个是本地JPA存储库，另一个是Web服务调用。 Web服务版本具有accountStatus ...

java spring-boot project-reactor

回答 2 投票 2

将对象写入流量

我想向通量添加一个对象，以便触发订阅者。到目前为止，这是我得到的，但是写不是函数：@Controller类LobbyRSocketController（）{数据类...

java spring spring-boot kotlin project-reactor

回答 1 投票 0

流量数据流计算

以下代码说明了我在Spring Reactive项目中需要的逻辑：输入：var period = 3; int [] inArr = {2，4，6，7，9，11，13，13，16，17，18，20，22};计算：var upbond = inArr [0] + ...

project-reactor

回答 1 投票 0

将ReactiveMongoTemplate与Kotlin协程一起使用

我正在使用Spring Boot 2.3.0，MongoDB和Kotlin开发响应式应用程序。不太可能，我需要使用ReactiveMongoTemplate对象来开发自定义存储库。由于所有应用程序...

mongodb spring-boot kotlin project-reactor kotlin-coroutines

回答 1 投票 0

如何在对象内部使用Flux作为JSON响应？

在我的Spring Webflux API网关中，我通过REST从微服务收到通量：public Flux getMyObjects（String id）{Flux myObjects = webClient.get（）。uri（... ]] >

spring reactive-programming spring-webflux project-reactor reactive

回答 1 投票 0

Project Reactor中的onErrorContinue值触发了错误为空

我在使用项目反应堆编写的代码时遇到一些问题： io.projectreactor reactor-core ...

java project-reactor

回答 1 投票 0

使用反应式api阅读kafka主题到底

我们正在使用压缩的kafka主题来存储状态更改，并且在重新启动或重新平衡期间，需要通过将主题读到末尾并为每个键获取最后一个条目来恢复状态。对于非反应性...

java apache-kafka project-reactor

回答 1 投票 1

将一个websocket客户端的输出作为输入发送给另一个

对SO的快速搜索未能找到我类似的问题，所以我们基本上要使用Webflux的RSocket的requestChannel语法，以便能够在...之外处理接收到的Flux ...] >>

java spring-webflux project-reactor

回答 1 投票 1

使用Reactor Publisher避免GC压力

我正在寻找一种方法，通过实例化每个调用的整个管道，从而在Project Reactor中正确使用发布者，而不会产生无用的GC压力。在我们的代码中，典型的句柄函数...

java reactive-programming spring-webflux project-reactor

回答 2 投票 1

CacheFlux：如何同步查找/ onCacheMissResume？

[在Spring Boot应用程序中使用Spring Cache时，可以使用syncattribute确保一次仅一个线程/请求更新缓存：@Cacheable（value =“ myCacheName”，key =“ ...

java caching spring-webflux project-reactor

回答 1 投票 0

使用RSocket和Project Reactor实现202 ACCEPTED-重试行为

我正在实现一个典型的用例，其中客户端请求将异步生成的资源。因此，将立即生成并返回一个resourceID：1.客户端---（（POST / request -...

spring-webflux project-reactor rsocket rsocket-java

回答 1 投票 0

Project Reactor + flatMap + Multiple onErrorComplete-无法正常工作

[将多个onErrorContinue添加到管道中以处理从flatMap抛出的特定类型的异常时，异常处理无法按预期方式工作。我希望下面的代码是...

project-reactor spring-reactor

回答 1 投票 1

repeatWhenEmpty运算符在RSocket websocket请求的上下文中不起作用，但在HTTP调用中起作用

我遇到了repeatWhenEmpty运算符的奇怪行为，这对我没有任何意义。我在Github上上传了一个可复制样本最少的存储库：https：//github.com / ...

spring-boot spring-webflux project-reactor rsocket spring-rsocket

回答 1 投票 1

project-reactor 相关问题

最新问题