WebFlux：如何在onErrorResume中避免用block()实现数据库存储？

要在不阻塞响应式流的前提下保存错误信息到数据库，你需要把block()替换成响应式链式调用，让保存操作成为流的一部分异步执行，而非强制阻塞等待结果。

修改后的代码 #

public Mono<Object> sendEmail(SendEmailRequest request)
        throws MailTemplateNotSupportedException, ExactTargetException {
    log.debug("Send email process started.");
    return validateRequestAndSendMail(request)
        .onErrorResume(error -> {
            if (error instanceof ExactTargetException ex) {
                MailFailure failure = MailFailure.builder()
                    .templateKey(request.getTemplateKey())
                    .templateParams(request.getTemplateParams() != null ? request.getTemplateParams().toString() : null)
                    .subscriberHash(request.getSubscriberHash())
                    .email(request.getEmail())
                    .responseStatus(ex.getStatus())
                    .responsePayload(ex.getBody())
                    .build();
                // 串联保存操作与错误返回，避免阻塞
                return mailFailureRepository.save(failure)
                    .then(Mono.error(error));
            }
            return Mono.error(error);
        });
}

关键说明 #

1. 移除block()：block()会强制阻塞当前线程等待数据库操作完成，完全违背响应式编程的非阻塞设计原则，替换为链式调用后，保存操作由Reactor框架异步调度执行。
2. 用then()串联流：then(Mono.error(error))表示等待保存操作完成后，再向上传递原始错误，既保证错误信息能正常返回调用方，又完成了数据库持久化。
3. 可选：处理保存操作自身的错误：如果需要捕获保存失败的情况（比如记录日志），可以在save()后添加错误处理，同时不影响原始错误的传递：

return mailFailureRepository.save(failure)
    .onErrorResume(saveError -> {
        log.error("保存邮件失败记录出错", saveError);
        return Mono.empty();
    })
    .then(Mono.error(error));

参考资源 #

• Reactor官方文档：重点学习错误处理操作符（onErrorResume、then等）的用法，理解响应式流的链式执行逻辑
• Spring Data响应式文档：掌握响应式Repository的设计原则，以及如何配合Mono/Flux实现非阻塞数据库操作
• Spring WebFlux官方指南：深入理解响应式Web应用的核心原则，牢记避免阻塞操作的最佳实践

内容的提问来源于stack exchange，提问作者Александр Хворостенко