Spring Boot WebFlux：避免处理程序中的线程阻塞方法调用

沃梦达教程 Java问题

2022-01-01 16

spring boot webflux: avoid thread-blocking method calls in handler(Spring Boot WebFlux：避免处理程序中的线程阻塞方法调用)

本文介绍了Spring Boot WebFlux：避免处理程序中的线程阻塞方法调用的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

我才刚刚开始学习WebFlux和整个反应式范例，我被困在这一点上：

@Component
public class AbcHandler {

    private ObjectMapper objectMapper = new ObjectMapper();

    public Mono<ServerResponse> returnValue() throws IOException {

        Abc abc = objectMapper.readValue(new ClassPathResource("data/abc.json").getURL(), Abc.class);

        return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON)
                .body(BodyInserters.fromValue(abc));
    }
}

IntelliJ警告我readValue()和toURL()是线程阻塞方法调用。

我可以忽略这一点吗？否则我应该如何返回从文件系统读取并映射到域类的JSON结构？

我觉得这应该以一种异步的方式完成，或者至少应该更多地"反应"。

推荐答案

您应该将其包装在FromCallable中，并确保它在其自己的线程上运行。

Blocking calls in reactor

@Autowire
private ObjectMapper objectMapper;

public Mono<ServerResponse> fooBar() throws IOException {
    return Mono.fromCallable(() -> objectMapper.readValue(new ClassPathResource("data/Foo.json")
            .getURL(), Foo.class))
            .subscribeOn(Schedulers.boundedElastic())
            .flatMap(foo -> ServerResponse.ok().contentType(MediaType.APPLICATION_JSON)
            .bodyValue(foo));

}