spring webflux如何在反应式世界中管理顺序业务逻辑代码

Question

这种方法对反应友好吗？

我有一个反应式控制器“save”方法调用myService。保存（请求）。

服务层需要：

1. jdbc save（在另一个调度程序上，因为代码被阻塞），

我无法在一个管道中链接所有调用，或者我不知道如何实现这一点，因为我想尽快发送回（1）丢失的......

相反，我触发（1）中的子运算。

这是我应该如何处理这件事，还是有一个聪明的方法可以在一个管道中做到这一点？

下面的代码来支持这个问题。谢谢。

控制器层调用的服务

    public Mono<Prospect> save(final Prospect prospect) {

    return Mono.fromCallable(
            () -> {
                Prospect savedProspect = transactionTemplate.execute(status -> prospectRepository.save(prospect));

                templateService.generateProspectSubscription(savedProspect)
                        .map(t ->
                                EmailPostRequest.builder()
                                       ...
                                        .build())
                        .flatMap(emailService::send)
                        .subscribe();

                return savedProspect;
            })
            .subscribeOn(jdbcScheduler);

}

模板服务

public Mono<String> generateProspectSubscription(final Prospect prospect) {        
    return Mono.fromCallable(
            () -> {
                Map<String, Object> model = new HashMap<>();
               ...

                Template t = freemarkerConfig.getTemplate(WELCOME_EN_FTL);
                String html = FreeMarkerTemplateUtils.processTemplateIntoString(t, model);
                return html;
            }
    ).subscribeOn(freemarkerScheduler);
}

电子邮件服务

 public Mono<Void> send(final EmailPostRequest e) {

    return Mono.fromCallable(
            () -> {
                MimeMessage message = emailSender.createMimeMessage();
                MimeMessageHelper mimeHelper = new MimeMessageHelper(message,
                        MimeMessageHelper.MULTIPART_MODE_MIXED_RELATED,
                        StandardCharsets.UTF_8.name());


                mimeHelper.setTo(e.getTo());
                mimeHelper.setText(e.getText(), true);
                mimeHelper.setSubject(e.getSubject());
                mimeHelper.setFrom(new InternetAddress(e.getFrom(), e.getPersonal()));

                emailSender.send(message);

                return Mono.empty();
            }
    ).subscribeOn(emailScheduler).then();
}

编辑的服务我认为这个版本的服务层更干净，但任何意见都是赞赏的

    public Mono<Prospect> save(final Prospect prospect) {

    return Mono.fromCallable(
            () -> transactionTemplate.execute(status -> prospectRepository.save(prospect)))
            .subscribeOn(jdbcScheduler)
            .flatMap(savedProspect -> {
                        templateService.generateProspectSubscription(savedProspect)
                                .map(t ->
                                        EmailPostRequest.builder()
                                                ...
                                                .build())
                                .flatMap(emailService::send)
                                .subscribe();

                        return Mono.just(savedProspect);
                    }
            );
}

Answer 1

这种方法不是反应友好的，因为您正在百分之百地包装阻塞库。在这个用例中，您无法真正看到反应式运行时的好处，很可能应用程序的性能比阻塞式运行时差。

如果您的主要动机是性能，那么这可能会适得其反。将大量阻塞I/O工作转移到专门的Schedulers会在内存（创建更多线程）和CPU（上下文切换）方面产生运行时成本。如果性能和可扩展性是您主要关心的问题，那么切换到Spring MVC并利用Flux/Mono支持它，或者甚至调用block（）运算符可能更合适。

如果您的主要动机是使用特定的库，例如Spring Framework的WebClient和Spring MVC，那么您最好使用。block（）运算符，而不是包装和调度所有内容。