spring-webflux 相关问题

Spring Framework 5包含一个新的spring-webflux模块。该模块包含对被动HTTP和WebSocket客户端以及被动服务器Web应用程序的支持，包括REST，HTML浏览器和WebSocket样式交互.WebFlux可以在Servlet容器上运行，支持Servlet 3.1非阻塞IO API以及其他异步运行时，如Netty和Undertow。

Spring Webflux取消管道并返回flux

我将解释我不知道如何在不使用异常的情况下解决的情况。情况如下，我将通过测试来解释它，但想象一下有一个返回 Flux 的控制器......

exception spring-webflux flux flow-control

回答 1 投票 0

所有测试替代方案中的千分尺@AutoConfigureObservability

我想知道 Spring Boot 测试是否有替代方案，不必在所有测试中添加注释“”。我必须添加此注释，因为在我的控制器建议中我已经注入了...

spring-boot spring-webflux spring-boot-test micrometer spring-autoconfiguration

回答 1 投票 0

finishConnect（..）失败：连接被拒绝：localhost/127.0.0.1，错误：Webflux，Webclient，Spring boot，java

我在本地主机中使用 webclient 时遇到此错误，你们能帮助我吗？错误 org.springframework.boot.autoconfigure.web.reactive.error.AbstractErrorWebExceptionHandler - [

java spring-boot netty webclient spring-webflux

回答 4 投票 0

Spring Webclient 总是给出超时错误

我目前正在尝试构建一个 API，该 API 从 url 提供图像（以字节数组的形式）。这是我的代码： @RestController @SpringBootApplication 公共类 ReturnApplicat...

spring-boot httprequest spring-webflux spring-webclient

回答 1 投票 0

如何压缩超过 8 种不同类型的单声道

我正在尝试同时进行 9 个 api 调用。所有这些调用都会返回不同的响应对象。在此之前我们有 8 个 api 调用，由于这些 mono 是不同的类型，我使用 Mono.zip

java spring spring-webflux project-reactor

回答 3 投票 0

如何将Flux<T>包装在ResponseEntity中（ResponseEntity<Flux<T>）

首先，我知道还有一些其他问题本质上问同样的事情（How to Wrap Flux in a ResponseEntity、How to mix Flux and ResponseEntity in Spring Webflux controlle...

java spring-boot spring-webflux flux reactor

回答 2 投票 0

使用Netty调试Spring Cloud Gateway性能

我有 Spring Cloud Gateway (Greenwich) 与 Netty 一起运行。该应用程序接收请求，然后根据路由配置向下游应用程序发送请求。随机很少的请求

spring-webflux spring-cloud-gateway reactor-netty

回答 2 投票 0

Spring 反应式大图像文件给出 nosuchfileException 并且不使用 Webclient 发送

我正在写一段代码，从前端收到后发送多张大小为10MB的大图。目标是在后台处理图像并立即发送响应...

spring-boot file spring-webflux spring-webclient

回答 1 投票 0

如何避免Spring WebFlux过滤器被调用两次？

经过长时间的详尽搜索，寻求帮助。我正在 Spring WebFlux 和 Spring Security 中编写一个 JwtTokenFilter 。问题是这个过滤器在一次请求中被调用两次...

spring spring-boot spring-mvc spring-security spring-webflux

回答 1 投票 0

在 Exchange() 之后调用 bodyToMono 时，block()/blockFirst()/blockLast() 会出现阻塞错误

我正在尝试使用 Webflux 将生成的文件流式传输到另一个位置，但是，如果文件的生成遇到错误，API 将返回成功，但会使用 DTO 详细说明错误，同时

java reactive-programming spring-webflux project-reactor

回答 6 投票 0

@Transaction(timeout = 2) 不适用于 R2DBC

我有连接到 Postgres DB 的 Spring Boot 应用程序 3.2.5 应用程序，我正在使用 Spring Reactor 和 R2DBCRepository。我有一个扩展 R2dbcRepository 的 Dao 类 ListDao 接口扩展...

spring-webflux spring-transactions r2dbc

回答 1 投票 0

WebClient 调用抛出 401 状态，但收到 500 状态响应

我正在尝试实现一个AuthorizationHandlerAdapter（实现org.springframework.web.reactive.HandlerAdapter接口）。它调用外部端点来获取用户的权限。 ...

spring-boot spring-webflux

回答 1 投票 0

Webflux 集成测试中出现 UnsupportedOperationException

我正在为我的 Webflux 服务中的以下端点编写集成测试 @GetMapping 公共 Mono>> getUsers() { 助焊剂使用...

java spring spring-boot spring-webflux

回答 1 投票 0

Spring WebFlux 检测客户端断开连接

假设以下@RestController： @GetMapping(“听”) 公共 Flux 听（）{ return Flux.create(sink -> process(sink)); } 还有某处下一个（新对象（））；这... 假设以下@RestController： @GetMapping("listen") public Flux<Object> listen() { return Flux.create(sink -> process(sink)); } 还有某个地方 sink.next(new Object()); 此代码没有有关接收器状态或完成的信息尝试使用isCanceled，每次都返回 false。是否可以检测到FluxSink是否仍在被客户端使用？在 spring-webflux 中，如果客户端关闭连接，订阅将被取消并处置。如果在 process 方法中添加回调 onCancel 和 onDispose 你会看到这一点。 private <T> void process(final FluxSink<T> sink) { sink.onCancel(new Disposable() { @Override public void dispose() { System.out.println("Flux Canceled"); } }); sink.onDispose(new Disposable() { @Override public void dispose() { System.out.println("Flux dispose"); } }); } 然后向您的端点发送一个 http 请求，并在 Flux 完成之前取消它。您将看到两个回调都被触发。接受的答案仅与“服务器发送事件”结合使用，服务器定期向客户端发送事件，当客户端断开连接时订阅将被取消。正如文档所述https://docs.spring.io/spring-framework/docs/current/reference/html/web-reactive.html#webflux-codecs-streaming 你可以尝试部署到另一台服务器上测试一下，我在本地部署调试的时候也遇到过这个问题。

spring spring-webflux flux server-sent-events

回答 3 投票 0

如何在Spring应用程序中定义基于URI/包/控制器的WebFlux配置

我有一个 Spring 应用程序，其中有不同的休息控制器。我想为不同的控制器使用不同的 WebFluxConfigurations。例如，对于“configureHttpMessageCodecs”我...

java spring rest spring-webflux uri

回答 1 投票 0

Mono：flatMap 加载另一个项目然后返回原始项目

我刚刚开始使用 Spring Webflux，我想知道以下调用是否是在反应流中加载其他项目的好方法，以及是否有另一个运算符可以简化...

spring spring-webflux

回答 2 投票 0

从`@WebFluxTest`迁移到`@SpringBootTest`后，连接在集成测试中被拒绝

我从 MVC 迁移到 Spring Boot Reactive，迁移了控制器，现在正在尝试迁移集成测试。控制器测试的注释如下；如果我运行测试，它就会起作用。 @RunWith(