Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。
我有以下代码 Mono fileInfoMono = getFileInfo(fileName, filelocation); 返回 fileInfoMono.map（信息 -> fileReader.read（信息） .doOnNext(这个::日志) ...
问题不是针对数据库的，而是用数据库的例子描述的 我使用反应式驱动程序从数据库中获取一些实体 使用 itemMapper 在 Item 实体中转换它们。 保存...
ProjectReactor，在开始使用 Flux 元素之前调用一个方法
如何在 api 管道中调用非 Reactive 阻塞方法，但仅当 Flux 中存在至少一项时才调用它 比如这里调用itemsRepo.saveItem之前，我想调用
在Spring webflux的doAfterRetry方法中有没有办法知道重试是否成功？
RetrySignal 的失败属性似乎保留了原始异常，并且在成功重试时不会被清除。用这种方法完全可以检测到成功还是有其他方法？
更新Quarkus版本后出现java.lang.NoSuchMethodError: reactor.core.publisher.MonoSink.contextView()错误
我已将项目的 quarkus 版本从 2.13.final 更新到 2.16.4 final。然后它给出如下错误。 java.lang.NoSuchMethodError：reactor.core.publisher.MonoSink.contextView()
Reactor Flux 间隔有问题。 我有功能 private void startPooling(final XYZ xyz, final Context 上下文) { final Disposable disposable = Flux.interval(Duration.ofMillis(...
execute 2 Mono sequentialy 不支持阻塞
我有两个波纹管功能 Mono messageEvent(MessageEvent messageEvent); Mono getPersonById(String personId); 我想在执行函数 messageEvent 时
我想写一段代码来反应性地遍历数据库（下一个查询取决于上一个查询的结果）。 我的问题可以简化如下： 可以说我们有...
我正在尝试返回对将异步填充（通过 MQ）的 http GET 调用的响应。 IE 用户调用 /hello url，该 url 异步触发对某些后端系统的请求，...
Reactor Netty IdleStateHandler 作为保活机制中断 http2 连接
我正在使用 Netty 的 IdleStateHandler 来保持长期存在的 SSE 连接： 公共最终类 NettyKeepAliveCustomizer 实现 WebServerFactoryCustomizer {...
我构建了以下函数来执行 CardTerminal 以读取 SIM 卡的 ICCID。 目标： 终端轮询并等待 CardTerminal 连接 卡轮询并等待卡连接...
我构建了以下函数来执行 CardTerminal 以读取 SIM 卡的 ICCID。 目标： 终端轮询并等待 CardTerminal 连接 卡轮询并等待卡连接...
OnBackpreasure如何与java reactor一起工作
我从 Java 反应堆开始，并试图了解背压的工作原理。 我写了以下示例代码： Flux publisher=Flux.interval(Duration.ofMillis(1)); 酒吧...
Project Reactor 中的“exhaustMap”？
RxJs 的 exhaustMap 在 Reactor 中是否有等效的运算符？ 我找到了 swtichMap、flatMap/mergeMap、concatMap，但据我所知，Reactor 中没有 exhaustMap 运算符。有没有...
我有一个 Flux，我想洗牌它的发射。 所以对于排放： 1, 2, 3, ... 我想拥有： 32, 5, 9, ... 在 Reactor 中有可能吗？
将 Spring Boot 版本从 2.6.6 升级到 2.6.7 后，我在执行 Web 客户端 rest 调用时出现以下错误。任何想法？ 示例代码 公共无效执行（BiConsumer 将 Spring Boot 版本从 2.6.6 升级到 2.6.7 后，我在执行 Web 客户端 rest 调用时出现以下错误。有什么想法吗？ 示例代码 public void execute(BiConsumer<ResponseEntity<JsonNode>, Throwable> responseConsumer) { WebClient.RequestBodyUriSpec uriSpec = getUriSpec(); Mono<ResponseEntity<JsonNode>> responseEntityMono = uriSpec .uri(this::buildUri)//"localhost:1234")// .headers(this::setHeaders) .body(insertBody()) .retrieve().onRawStatus(i -> i == 599, response -> response.bodyToMono(String.class) .map(body -> new ExternalException(599, body))) .toEntity(JsonNode.class); CompletableFuture<ResponseEntity<JsonNode>> completableFuture = responseEntityMono.toFuture(); completableFuture.whenCompleteAsync(responseConsumer); } 找不到的方法在类MonoSink中（在reactor-core项目中）：https://github.com/reactor/reactor-core/blob/main/reactor-core/src/main/java /reactor/core/publisher/MonoSink.java 由于这是从spring boot 2.6.6版本升级后出现的异常，我猜找不到它的类是HttpClientConnect（在项目reactor-netty-http中）。不过，最好有整个堆栈异常。 @jiangjianbo 说的没错，你需要更新reactor-core来解决这个问题，但不是3.4.3版本。它至少应该是 3.4.17 版本（也就是说我会采用最新版本，在撰写本文时是 3.4.19）。正如您在版本 3.4.16 中看到的，contextView() 尚未创建：https://github.com/reactor/reactor-core/blob/v3.4.16/reactor-core/src/main/java/reactor/核心/发布者/MonoSink.java 升级你的pom.xml <dependency> <groupId>io.projectreactor</groupId> <artifactId>reactor-core</artifactId> <version>3.4.3</version> </dependency> 升级pom.xml <dependency> <groupId>io.projectreactor</groupId> <artifactId>reactor-core</artifactId> <version>3.5.3</version> </dependency> 您已重新加载 Maven 项目。 右键单击 Maven -> 重新加载项目。之后重新运行你的应用程序。
我对反应世界和使用 Spring Webflux + reactor Kafka 很陌生。 kafka接收器 。收到（） // .publishOn(Schedulers.boundedElastic()) ...
如何用reacty-netty构建分布式服务，获取分布在不同服务中的userInfo和连接？
使用reactor-netty构建消息代理服务器时，我遇到了一个困惑，我不知道如何在使用分布式服务时解决用户信息可能被不同机器捕获的问题。 我
使用 reactor-netty http 客户端的顺序调用似乎释放了第一个响应的 ByteBuf
我有一个要求，要么按顺序进行两个 http 调用，一个依赖另一个，在另一种情况下进行两个并行调用并组合它们的结果。 对于案例 1：顺序 ca ...
数据依赖包括： 实现（“io.micronaut.data：micronaut-data-mongodb”） 实现（“io.micronaut.mongodb：micronaut-mongo-reactive”） 实施（“io.