project-reactor 相关问题

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

如何在Spring React中从ServerHttpRequest获取inputStream作为返回值？

我正在为第三方 SPI 编写一个基于传统 servlet 的 Spring Reactive 实现。一种方法需要请求中的 InputStream 作为返回值： /** * 返回请求...

java spring spring-webflux project-reactor spring-cloud-gateway

回答 1 投票 0

如果消息处理失败，Kafka-reactor 会再次读取相同的 kafka 消息

从 kafka 读取时，我希望保证在处理来自 kafka 的下一条消息之前，我的 kafka 消息已成功存储在数据库中。我使用java-spring kafka-reactor。这是一个简单的

java spring-kafka project-reactor reactor-kafka

回答 1 投票 0

特定 GroupedFlux 上的延迟元素等

我有一个与此类似的代码： @测试无效shouldSlowdownOnlyEvens() { 最终 Flux globalFlux = Flux.range(1, 20000) .groupBy(数字 -> 数字 % 2 == 0) ...

spring-webflux project-reactor backpressure

回答 1 投票 0

发送高流量时Web客户端超时异常

我正在使用reactor-netty中的WebClient来调用下游，下游延迟为 15 秒才响应。我正在尝试使用 Jmetter 每秒发送 20 个请求，其中一半返回 50 个...

spring-webflux project-reactor reactor-netty

回答 1 投票 0

Java 响应式编程 - 逐个获取页面并并行处理每个页面

我想迭代分页的数据库查询结果并处理每个页面。每个页面的处理应该是并行的，直到处理完 c...

java pagination reactive-programming project-reactor

回答 1 投票 0

Spring Boot 的服务器端事件消费者

鉴于我有此服务-A，此端点返回 contentType(MediaType.TEXT_EVENT_STREAM) @豆公共 RouterFunction 通知路由（CustomHandler

spring-boot spring-webflux project-reactor reactive spring-resttemplate

回答 1 投票 0

Context contextWrite / deferContextual 的 Reactor 用法

我不明白为什么这个简单的代码不起作用。我正在尝试保存我的反应器 Mono 的初始值并在以后重用它。 Mono.just(“蒂蒂卡卡”) .fla...

java project-reactor

回答 1 投票 0

有条件地取消（）通量并保留导致取消的值

我在Java中有以下Reactive Flux流， Flux.just(e1, e2, e3, e4, e5) .flatMapSequentially(/* 处理元素 */) .scan（新累加器（null，0），（元素，总计）->新累加器（

java rxjs spring-webflux reactive-programming project-reactor

回答 1 投票 0

Reactor Kafka receiveAutoAck 和至少一次语义

在Reactor Kafka中，当使用receiveAutoAck时，如果框架在用户代码处理并返回事件后确认事件，那不是尊重“至少一次”sem...

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

回答 1 投票 0

如何监听reactor netty触发doOnError的原因？

定位问题，发现是webflux的Mono触发了doOnCancel。好像是浏览器链接中断导致的，导致执行了doOnCancel。现在我想知道如何...

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

回答 2 投票 0

Reactor Netty：在使用 WebClient 进行响应之前连接过早关闭

当尝试在随机时间点处理从 WebClient 检索的数据时，我收到“连接在响应之前提前关闭”错误。这些页面包含相当多的数据...

java spring-boot spring-webflux project-reactor reactor-netty

回答 1 投票 0

如何在反应链中发生致命异常（例如 OutOfMemory）时关闭 Spring 上下文

在 Spring 应用程序内部，我们使用 ServiceBusReceiverAsyncClient 来使用来自 Azure ServiceBus 的消息并在反应链中处理它们。就像是：公开课

spring-boot reactive-programming azureservicebus project-reactor

回答 1 投票 0

Spring Webclient .toFuture().get() 永远不会在另一个 Mono 中执行

有人能告诉我为什么 Mono.toFuture().get() 不在另一个 Mono 执行线程中执行吗？导入java.io.IOException；导入 java.util.concurrent.CompletableFuture; 导入java.util.

java spring-webflux reactive-programming project-reactor spring-webclient

回答 1 投票 0

分布式跟踪不适用于 Spring WebFlux + Reactor Kafka

我使用Spring WebFlux，Spring boot版本是3.2.0。我使用原生 Reactor Kafka。 Spring boot Sleuth 已移至 Micrometer Tracing 您可以从这里阅读： Spring Cloud Sleuth 的最后一个小版本...

spring-boot apache-kafka spring-webflux project-reactor micrometer-tracing

回答 1 投票 0

inteliji idea 调试器中的 Reactor 框架是什么意思

我目前正在开发一个Java Reactor项目（在intelij Idea中），并且在调试器中遇到了一些被标记为“反应器框架”的东西（如图所示）。我有

java spring-webflux project-reactor

回答 1 投票 0

Spring Boot 的 R2DBC 错误：无法对“io.r2dbc.spi.Parameters$InParameter”类型的值进行编码

我正在使用 Spring Boot 3 和 R2DBC 开发一项服务，将数据上传到 MySQL 8.0 数据库。这样做时，我在尝试绑定参数时遇到以下错误： reactor.core.Exce...

java spring-boot spring-webflux project-reactor r2dbc

回答 1 投票 0

Spring Webclient 将 Mono 交给 CompletableFuture

我的问题与下面的代码非常相似，在另一个 webclient 调用中进行 webclient 调用。 String r = Mono.just(Mono.just("你好，世界！").toFuture().get()).toFuture().get();...

java spring-webflux reactive-programming project-reactor spring-webclient

回答 1 投票 0

通过错误处理信息增强单声道

我们使用 Mono 来处理调用 REST 服务，我想通过添加一些额外的信息来增强异常处理，以便在必须抛出异常的情况下使用。粗略地说，...

java spring-webflux reactive-programming project-reactor

回答 1 投票 0

如何执行并发 void 方法调用

我正在使用数据库并试图弄清楚如何同时执行具有 void 返回类型的写入。我已经按照文档包装了阻塞调用。我想要：得到...

spring-webflux project-reactor

回答 1 投票 0

如何在Spring WebClient中捕获超时异常？

目前我正在编写一个使用WebClient向另一个服务发送POST请求的方法。私有 Mono callApplication(GameEntity gameEntity) 抛出 URISyntaxException {

java spring spring-webflux reactive-programming project-reactor

回答 1 投票 0

project-reactor 相关问题

最新问题