Spring Framework 5包含一个新的spring-webflux模块。该模块包含对被动HTTP和WebSocket客户端以及被动服务器Web应用程序的支持，包括REST，HTML浏览器和WebSocket样式交互.WebFlux可以在Servlet容器上运行，支持Servlet 3.1非阻塞IO API以及其他异步运行时，如Netty和Undertow。
Spring Boot 3.x 与 spring-cloud-gateway 的微米跟踪问题
我们正在尝试将 Spring Cloud Gateway 从带有 Sleuth 和 Brave 的 Spring Boot 2.7.18 升级到 3.1.5。与微米追踪和勇敢。 到目前为止，一切都很好。 在 Spring Boot (Webflux) 之前 3 中我们可以...
下沉。在订阅者数量第一次达到 0 后，许多默默地变得毫无用处
如果我创建一个 Sinks.Many 实例： Sinks.Many sink = Sinks.many().multicast().onBackPressureBuffer(); 然后在另一个线程（T1）中，我订阅它的 Flux： 新线程(() -> { ...
如何为 Spring Cloud Reactive API Gateway 的自定义过滤器编写单元测试来测试它是否允许对公共端点的请求通过？
我正在尝试为微服务架构中的 Spring Cloud Reactive API Gateway 的 authAccountFilter 编写单元测试。网关使用 WebFlux，authAccountFilter 负责
我知道 Spring 5 webflux 如何在 Webclient 上设置超时，但这会为所有请求全局配置超时。我正在寻找一种根据每个请求配置超时的方法。 IE。
Spring Boot Reactive：向控制器添加 @Validate 注解会导致相关测试失败
我目前正在 Sprig Boot(2) 反应式项目中工作。所有 CRUD 端点和测试都工作正常。然后我决定在创建待办事项时添加验证，为此我添加了注释...
我有一个使用 R2dbcEntityTemplate 的类，如下所示 r2dbc模板 .getDatabaseClient() .sql("") 。拿来（） 。全部（）; 我是
从JpaRepository获取数据时没有从WebTestClient收到数据
我有一个简单的集成测试用例，我想在其中找到特定的数据。 首先，我使用 .save() 插入数据。虽然它工作成功（正如我调试它以及 this.dataRepository.findAl...
向 WebFlux 中的 PropaatedSpan 添加自定义属性
我有一个 SpringBoot 应用程序： 设置 SpringBoot 3.0.8 WebFlux 千分尺+OTL 启用上下文传播 库： io.micrometer.context-propagation io.micrometer.micrometer-tracing-bridge-o...
cosmos db 无法使用 IN、Spring Data 原生查询和数组或集合（Java）进行查询
我正在尝试为反应式存储库 spring data cosmo DB 创建（使用 spring 本机查询）findAllId。 由于 ReactiveCosmosRepository 尚未实现。 @Query(值 = " SEL...
如何在Spring Boot中支持不同的Bearer token类型？
我们需要构建一个支持传统定制（非 JWT）承载令牌身份验证标头的服务： 授权：定制.... 和 JWT 承载令牌 Auth 标头： 授权：不记名...... 什么...
在我运行Mono的awaitSingle之后MDCContext变空（带有kotlin挂起协程的Spring webflux）
我想问一下为什么MDCContext在调用Mono的awaitSingle后变空了 这是代码片段 暂停有趣的 getTemplates(请求: GetPaginatedTemplateServiceRequest): PaginationTemplates ...
Spring Boot webclient 多次 post api 调用：打开文件太多
我的 spring boot 应用程序处理预定的批处理作业，其中涉及在一个批处理作业中对配置的 api 进行数千次 post api 调用。这些调用在线程池中同时处理。 ...
如何限制Spring webflux（netty webserver）中可以处理的请求数量
我想要相当于在tomcat中设置此属性的东西。这会将线程池中的线程数设置为 100，因此可以并发处理的最大请求数为 100
如何使用Spring Reactive WebSocket并将其转换为Flux流？
Spring 文档中有一些 WebSocketClient 示例： WebSocketClient 客户端 = new ReactorNettyWebSocketClient(); client.execute("ws://localhost:8080/echo"), session -> {...}).blockMil...
HttpClient.create().tcpConfiguration 在 Spring boot 3 中已弃用
我想将 Spring boot 2 迁移到 Spring boot 3，我发现 httpClient.create.tcpConfiguration 已弃用。 我怎样才能重写这段代码 HttpClient httpcl = HttpClient.create().tcpConfiguration(
在一个项目中使用 Hibernate-Reactive 和 R2DBC
我目前正在开发一个使用 Spring-Webflux 和 R2DBC 的项目。我正在使用 OracleDB 19c 和 R2DBC 的相应驱动程序。由于 Hibernate 变得响应式，我想在现有的项目中尝试一下...
在反应流运算符（项目反应器）中使用“try catch”是错误的吗？
我正在使用项目reactor探索反应流，并且我有一个用例，如果在处理当前事件期间发生错误（例如，deseriali...
我正在尝试创建一个 spring webflux 应用程序（java 17），预计：- 监听sqs事件并做一些处理。 （工作正常） 响应一些配置的api。 （不工作）。 神父...
我正在尝试使用 WebClient 来调用我的restServices。之前在 RestTemplate 上，我们定义了 ClientHttpRequestInterceptor 并将其附加到 RestTemplate 来拦截和修改请求...
替换 software.amazon.awssdk.auth.signer 中的 AwsSignerExecutionAttribute？
我有对来自 Spring WebFlux 的响应式 ClientRequest 请求进行签名的逻辑。 导入 org.springframework.util.MultiValueMapAdapter 导入 org.springframework.web.reactive.function.client.ClientRequest