project-reactor 相关问题

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

反应堆中 vavr Either 的意外返回类型

使用 vavr 的 Either 有两种简单的方法。公共要么 testEither(int s) { 如果（s==0） return Either.left("错误"); 返回 Either.right(s);...

java spring-webflux project-reactor vavr

回答 2 投票 0

如何在spring-webflux WebFilter中正确使用slf4j MDC

我参考了博客文章《使用 Reactor Context 和 MDC 进行上下文日志记录》，但我不知道如何在 WebFilter 中访问 Reactor 上下文。 @成分公共类 RequestIdFilter 实现 WebF...

java spring-webflux project-reactor

回答 6 投票 0

如何检查 Mono<Void> 是否真的被调用了？

我是反应式编程的新手（并且我读过很多类似的问题）。在我当前的宠物项目中，我遇到了以下问题（我正在为任务中的场景提供伪代码......

java functional-programming spring-webflux project-reactor

回答 1 投票 0

在异步上下文中调用 subscribe 是否正确？

我将加密密钥存储在 Redis 数据库中。我想实现一个后备机制来生成密钥，除非它们已经存在。让我困惑的是我提出的解决方案是我打电话给

java redis spring-webflux project-reactor

回答 1 投票 0

Kafka消费者偏移提交问题

对于使用 Reactor Kafka 的 Spring WebFlux，我为我的消费者提供了以下代码：公共EventConsumer（KafkaReceiverinputEventReceiver，消息助手

spring-webflux spring-kafka project-reactor

回答 1 投票 0

如何定时执行任务并响应外部信号？

想象一个重复执行的任务，每次执行之间最多有 10 秒的延迟。还有一个外部信号会导致任务立即执行。（外部

project-reactor

回答 2 投票 0

如何拆分事件在每个组上应用不同的地图，然后将它们合并回来

我有一个项目列表，其中有 2 种类型的 id。我需要将它们分成 2 组，然后为一组调用另一种方法，该方法将丰富 id 并提供不同的 id，而对于另一组...

java grouping spring-webflux project-reactor flux

回答 1 投票 0

Spring Reactor：以非阻塞方式添加延迟

关于如何在方法中添加延迟但以非阻塞方式的小问题。模拟长进程的一种非常流行的方法是使用 Thread.sleep(); 然而，对于 Reactor 项目来说，这是一个块......

java spring spring-webflux reactive-programming project-reactor

回答 1 投票 0

Mono.block() 抛出 InspirationTargetException

我正在执行一个返回 Mono 的 WebClient get 调用，该调用成功了。但我试图通过在 Mono 上执行 block() 来获取字符串。结果，我得到了异常抛出。这是我的代码

kotlin webclient project-reactor spring-webclient

回答 1 投票 0

WebClient 未成功调用“POST”操作

我正在玩Spring的WebClient。 REST 端点的主要实现（在 DemoPOJORouter 和 DemoPOJOHandler 中）似乎可以工作。此外，DemoClientRouter 中的 http.Get 端点和

spring-boot spring-webflux project-reactor

回答 1 投票 0

ReactDeserializationException发生时如何移动到下一个偏移量reactor-kafka接收器？

当将 spring-webflux 与reactor-kafka接收器一起使用时，当发生 RecordDeserializationException 时，如何手动移动/提交偏移量？从 RecordDeserializationException 我可以获取分区并......

java spring-webflux spring-kafka project-reactor reactor-kafka

回答 1 投票 0

反应式变换函数的行为不符合预期

当我提取各个步骤并单独执行它们时，我创建的反应器变换函数不会给出相同的结果。我有包含价格类型列表的 DTO 记录。公众反...

java reactive-programming project-reactor

回答 1 投票 0

如何泛化Reactor函数？

我有以下静态函数来在调用另一个通量之前记录一些信息。公共静态 Flux> logBefore(Consumer&...

java spring-boot project-reactor

回答 1 投票 0

Spring Data R2DBC - 未考虑背压？

此线程是 Github 问题的延续：https://github.com/spring-projects/spring-data-r2dbc/issues/194 语境：你好，我只是尝试了一个非常简单的示例，基于两个反应性存储库......

spring-data project-reactor r2dbc spring-data-r2dbc

回答 1 投票 0

将 Flux<DataBuffer> 转换为 Flux<ByteBuffer>

我正在研究 spring webflux 文件上传。我想从控制器将文件上传到亚马逊 S3 存储桶上。所以在控制器中我收到了以下对象 org.springframework.http.codec.multip...

java spring spring-boot spring-webflux project-reactor

回答 2 投票 0

如何更改Reactor中的执行线程

@RequestMapping(值 = "/try", 方法 = RequestMethod.GET) @ResponseBody 公共字符串演示（）{ Listdata=new ArrayList<>(); 数据.add("A1"); 数据.add("A2"); 数据...

reactive-programming project-reactor

回答 2 投票 0

Spring Webflux 在返回响应之前等待所有 Flux.fromIterable

我有一个反应式服务并且运行良好公共 Mono getCasesList(@RequestBody GetCasesListRequest 请求) { 返回 caseService.getCasesList(

spring-boot spring-webflux project-reactor

回答 1 投票 0

Project Reactor：如何定期执行任务并响应外部信号？

想象一个重复执行的任务，每次执行之间最多有 10 秒的延迟。还有一个外部信号会导致任务立即执行。（外部

project-reactor

回答 2 投票 0

Spring Reactor Context到底是什么？

在非响应式java中我们使用ThreadLocal来传递Context数据，但是对于Reactor，Spring团队建议使用Reactor Context来将数据传播到线程。在 spring 文档中它说：项目重新...

spring spring-webflux project-reactor

回答 1 投票 0

如何将 if-else 语句包含到反应流中

我有一个 Spring Webflux 反应式服务，它接收 DTO 并将其插入到多个表中。有时我们可能需要根据传入的 DTO 跳过插入某些表。这些是

java spring-webflux project-reactor

回答 3 投票 0

project-reactor 相关问题

最新问题