@异步APIendpointSpring Webflux

Question

我有一个要求编写Spring的网络流量endpoint（路由器功能）来发送邮件到邮件收件人列表。UI将选择邮件收件人列表并将列表发送到我将编写的API。我希望在收到请求后立即以这种方式引入endpoint，我应该向UI发送响应，说正在发送电子邮件。发送响应后，我应该异步继续邮件发送工作。我不能像我们在Spring MVC中使用的那样使用@async注释，因为它是反应式世界中的反模式。

既然我在使用SpringWebFlux开发API，我该如何发送报告呢。

我的代码中有一个下面的结构。

路由器。JAVA

@Bean
public RouterFunction<ServerResponse> sendEmail() {
 return route(POST("/email").and(accept(APPLICATION_JSON)), handler::sendEmail);
}

处理程序。JAVA

@Autowired
EmailService emailService;

public Mono<ServerResponse> sendEmail(ServerRequest request) {
    Mono<PojoA> pojoAMono = request.bodyToMono(PojoA.class);
    return pojoAMono.flatMap(pojoA -> {
       return emailService.sendEmail(pojoA).flatMap(mailSent -> {
         return  ServerResponse
        .status(HttpStatus.OK)
        .contentType(MediaType.APPLICATION_JSON)
        .body("Mails are being sent", String.class));
       });
    });
    
}

Answer 1

您应该构建响应，然后处理数据（发送电子邮件）。

像这样的东西：

@Bean
public RouterFunction<ServerResponse> sendEmail() {
    return route(POST("/test").and(accept(APPLICATION_JSON)), this::someMethod);
}

Mono<ServerResponse> someMethod(ServerRequest serverRequest) {
    return ServerResponse.ok().build()
            .doOnNext(r -> Mono.just("data") //doing some process like send email
                    .delayElement(Duration.ofSeconds(2))
                    .subscribeOn(Schedulers.parallel())
                    .log()
                    .subscribe());
}

出于测试目的，我把一个延迟给你看数据处理后的响应发送。

Answer 2

您可以直接将响应返回给调用者，并在该流完成后运行电子邮件发送作为副作用。这可以使用流完成后执行的doFinal来完成。

因此，您的代码可能如下所示：

public Mono<ServerResponse> sendEmail(ServerRequest request) {
    return request.bodyToMono(PojoA.class)
            .map(this::sendEmailSideEffect)
            .flatMap(pojoA -> ServerResponse
                    .status(HttpStatus.OK)
                    .contentType(MediaType.APPLICATION_JSON)
                    .body("Mails are being sent", String.class));
}

private Mono<PojoA> sendEmailSideEffect(PojoA pojoA) {
    return Mono.just(pojoA)
            .doFinally(signalType -> emailService.sendEmails(pojoA));
}