project-reactor 相关问题

我一直在使用 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

spring spring-boot project-reactor spring-webflux reactive-streams

回答 2 投票 0

Netty TCP 服务器仅从客户端接收 536 字节。剩余部分被截断

我使用项目reactor netty编写了一个TCP服务器应用程序。这是一个简单的应用程序，它从客户端接收字节数组请求消息，处理它，然后返回字节数组响应我...

java tcp project-reactor tcpserver reactor-netty

回答 1 投票 0

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

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

spring-webflux project-reactor spring-cloud-stream spring-cloud-stream-binder-kafka

回答 1 投票 0

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

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

java spring kotlin spring-webflux project-reactor

回答 1 投票 0

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

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

spring-boot spring-webflux project-reactor resilience4j

回答 1 投票 0

使用repeatWhen()和takeUntil()重复订阅Mono

我想了解重复订阅Mono并延迟1秒并根据某个条件停止订阅的效果，我有这行代码 Mono.just(UUID.rando...

java spring-webflux reactive-programming project-reactor

回答 1 投票 0

MYSQL R2DBC 的 Spring Data 多主机设置

我正在尝试从 Spring R2DBC 访问只读副本数据库。我的连接字符串如下所示春天： r2dbc: url: r2dbc:mysql://db-master-dev-pvt.xyz***.com:3306,db-replica-dev-pvt.x...

spring-boot spring-webflux project-reactor spring-data-r2dbc r2dbc

回答 3 投票 0

反应堆中的map与flatMap

我找到了很多关于RxJava的答案，但我想了解它在Reactor中是如何工作的。我目前的理解很模糊，我倾向于认为 map 是同步的，而 flatMap 是

java spring-webflux project-reactor

回答 3 投票 0

project-reactor 相关问题

最新问题