spring-webflux 相关问题

Https 调用无法与具有自签名 p12 证书的 Web 客户端一起使用

我通过使用 keytool 创建自签名证书，为我的 Springboot Webflux（使用 Netty 服务器）微服务启用了 HTTPS keytool -genkeypair -alias mycert -keyalg RSA -keysize 2048 -

doOnNext 的副作用可以被跳过吗？

我目前正在编写一个方法，需要在继续下游之前将每个元素添加到并发HashMap中。例如。 公共 Flux methodOne(final Flux foos) { 地图<...

当 io.netty.channel.ExtendedClosedChannelException] for...但 ServerHttpResponse 已提交（200 OK）时，可能会发生吗？

我们使用 spring-webflux 开发了团队的新服务。它一直运作良好。只有一件事我们无法弄清楚是下面的日志 错误 [reactor.netty.ReactorNetty$InternalNettyException: io.

如何在Mono上调用阻塞IO调用

我有类似这样的实用方法。 公共静态WebClient.ResponseSpec检索（最终字符串baseUrl，最终持续时间responseTimeout）{ // ... } 公共静态 佛罗里达...

关于一般反应式编程的问题（不受编程语言限制）

我想验证我对反应式编程的理解总体上是否正确，它与任何特定的编程语言无关，但我使用Java（使用Reactor项目）来说明......

Spring WebTestClient 请求和响应验证

基于 Atlassian 根据 OpenAPI 规范验证请求和响应所做的工作，我想将此逻辑调整为 WebTestClient。 我的方法是配置 WebTestC...

如何在Spring Webflux控制器中结合Flux和ResponseEntity

我在 Webflux 控制器中使用 Monos 和 ResponseEntitys 来操作标头和其他响应信息。例如： @GetMapping("/{userId}") 有趣的 getOneUser(@PathVariable userId: UserId):

Spring Boot Webflux - 设置 UTF-8 编码

我一直在使用 Spring Boot 2.0.0.RC1 并使用 spring-boot-starter-webflux 来构建返回文本数据流的 REST 控制器。 @GetMapping(值=“/”) 公共通量 我一直在使用 Spring Boot 2.0.0.RC1 并使用 spring-boot-starter-webflux 来构建一个返回大量文本数据的 REST 控制器。 @GetMapping(value = "/") public Flux<String> getData(){ return Flux.interval(Duration.ofSeconds(2)) .map(l -> "Some text with umlauts (e.g. ä, ö, ü)..."); } 由于文本数据包含一些变音符号（例如 ä、ö、ü），我想将响应的 Content-Type 标头从 text/event-stream 更改为 text/event-stream;charset=UTF-8。因此，我尝试将 Flux 包装成 ResponseEntity。像这样： @GetMapping(value = "/") public ResponseEntity<Flux<String>> getData(){ return ResponseEntity .ok() .contentType(MediaType.parseMediaType("text/event-stream;charset=UTF-8")) .body(Flux.interval(Duration.ofSeconds(2)) .map(l -> "Some text with umlauts (e.g. ä, ö, ü)...")); } 现在，向端点发出curl请求显示Content-Type保持不变： < HTTP/1.1 200 OK < transfer-encoding: chunked < Content-Type: text/event-stream < data:Some text with umlauts (e.g. ├ñ, ├Â, ├╝)... 我怀疑 MediaType.parseMediaType() 方法是问题所在，但媒体类型已正确解析（如此屏幕截图所示）： 但是，参数charset似乎被忽略了。 如何将编码更改为 UTF-8 以便浏览器正确解释元音变音字符？ 编辑： 在 GetMapping 注释中设置 produces 字段也不起作用。 @GetMapping(value = "/", produces = "text/event-stream;charset=UTF-8") public ResponseEntity<Flux<String>> getData(){ return ResponseEntity .accepted() .contentType(MediaType.parseMediaType("text/event-stream;charset=UTF-8")) .body(Flux.interval(Duration.ofSeconds(2)) .map(l -> "Some text with umlauts (e.g. ä, ö, ü)...")); } 您可以在返回浏览器之前创建一个过滤器并处理响应 import java.io.IOException; import javax.servlet.Filter; import javax.servlet.FilterChain; import javax.servlet.ServletException; import javax.servlet.ServletRequest; import javax.servlet.ServletResponse; import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; import org.springframework.core.Ordered; // esse filtro foi criado pra converter para UTF-8 o response do Flux<ServerSentEvent<String>> // this filter was created to convert all responses to UTF8, including Flux<ServerSentEvent<String>> @Component @Order(Ordered.HIGHEST_PRECEDENCE) public class FluxPreProcessorFilter implements Filter { @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { response.setCharacterEncoding("UTF-8"); chain.doFilter(request, response); } } 这里的问题是 Spring 使用 StringHttpMessageConverter 将 Flux<String> 转换为 http 响应正文。此转换器默认为 ISO-8859-1 字符集，即使在使用 UTF-8 时规范需要 produces = "text/event-stream" in org/springframework/http/converter/StringHttpMessageConverter.java:51 ... public static final Charset DEFAULT_CHARSET = StandardCharsets.ISO_8859_1; ... 您可以通过两种方式解决此问题。 将StringHttpMessageConverter的默认编码更改为UTF-8： @Configuration @EnableWebMvc public class WebConfig implements WebMvcConfigurer { @Override public void extendMessageConverters(List<HttpMessageConverter<?>> converters) { converters.stream() .filter(converter -> converter instanceof StringHttpMessageConverter) .forEach(converter -> ((StringHttpMessageConverter) converter) .setDefaultCharset(StandardCharsets.UTF_8)); } } 或从您的方法返回一个 JSON（又名自定义对象）而不是 String。这样，Spring 使用 MappingJackson2HttpMessageConverter 来书写 UTF-8。 更改java.lang.String的返回类型 @GetMapping(value = "/", produces = "text/event-stream") public Flux<String> getData(){ return Flux.interval(Duration.ofSeconds(2)) .map(l -> "Some text with umlauts (e.g. ä, ö, ü)..."); } 您选择的对象 @GetMapping(value = "/", produces = "text/event-stream") public Flux<MyStringData> getData(){ return Flux.interval(Duration.ofSeconds(2)) .map(l -> new MyStringData("Some text with umlauts (e.g. ä, ö, ü)...")); } public record MyStringData(String data) {} 您的回复将采用 UTF-8 格式（但也采用 JSON 格式） 另请参阅这里的这个问题：How to overwrite StringHttpMessageConverter DEFAULT_CHARSET to use UTF8 in spring 4

在 AuthenticationFilter 中使用 WebClient（Spring-boot、spring-security 6.3）

我是反应式编程的新手，我很难理解为什么 Mono 的链接在这种情况下不起作用。我尝试了各种方法但没有运气。最新的方法是

使用 Spring WebClient 将文件作为输入流上传

我正在使用 webflux springboot 应用程序。我有一个 API，它接受 FilePart 作为输入，然后将其转换为输入流，因为我使用 Tika 库进行文件类型检查，然后上传此

如何在Spring WebFlux中的反应链中异步运行方法？

我正在尝试在基于 Project Reactor 的应用程序中的现有反应链中异步执行方法。 doUpdateLayoutInAsync 方法旨在执行繁重的后台操作...

如何通过支持 OAuth 2.0 的多个 IdP 设置身份验证？

如果我有一个基于 Spring Boot 3 的应用程序，该应用程序利用 Spring Security 和 Spring WebFlux，并且已设置为通过 IdP1 对用户进行身份验证和授权，那么我如何增强此应用程序...

Spring中如何等待WebClient超时响应？

我有一个 WebClient，我想在一定的超时后停止并提供回退值。 webClient.post() .uri(路径) .bodyValue(正文) 。取回（） .bodyToMono(类型) .超时(

`ReactiveOAuth2AuthorizedClientManager` 未仅通过客户端凭据注册自动配置？

我使用 OAuth2 客户端启动器以及提供程序和注册应用程序属性创建了一个非常简单的反应式（webflux）应用程序，但是 ReactiveOAuth2AuthorizedClientManager 不是自动的

如何将传入的kafka消息轮询到Flux中

目前正在开发一个使用 Spring Boot 3.2.7 和 Web Spring Cloud 流绑定器的项目。我有一个基于提供程序实现的数据层，它将一些数据流式传输到我的服务中。索梅特...

Reactor doOnError - 如何在方法参数中包含多个异常类型

我想在响应式 Spring Boot API 的控制器中以相同的方式处理多个异常。 这个想法是发送 HttpStatus.BAD_REQUEST 作为不止一种类型的错误响应

使用 .then(Mono{}) 理解执行顺序

我试图理解 spring webflux 中 .then(Mono(x)) 的行为。 我有以下代码： 有趣的 storeIfValid(x): Mono = doSomeChecksThatMightFail().then(repo.save(x)) 重新...

Spring Reactive Oauth2 Webclient 不使用配置的代理

我有一个 Oauth2 身份验证服务，必须使用代理来调用 OAuth 提供程序以在用户身份验证后获取令牌。这里使用的服务器是 netty，而我有一个用于网关的反应式服务器

WebClient 代理配置不适用于 oAuth2

我已经实现了带有授予类型客户端凭据的 webclient 和 oAuth2。我必须使用代理才能访问局。但 webclient 没有使用我配置的主机。 HttpClient httpClient =

Resilience4j 和 Reactor Retry 不一起工作时以每秒 10 个请求分发 100 个请求

我正在调用远程服务，并且不想超过 10 RPS，因此我配置了 Resilience4j Rate Limiter 并添加了 retryWhen 来处理 RequestNotPermission 错误并在允许时重试。 该项目...