Spring Reactive使用异步flatMap时国际化功能失效问题咨询

在Spring Reactive框架中使用flatMap执行异步操作时，国际化（Internationalization）功能会出现无法正常工作的问题——这是因为Reactive环境下线程上下文不会自动跟随异步任务传递，导致后续异步方法无法获取到请求初始的Locale信息。

解决这个问题的核心方案是显式传递Locale字段到异步方法，以validateExistingShipments为例：

• 先在异步操作的上游获取当前请求的Locale：可以通过ServerRequest对象直接获取，或者使用ReactiveLocaleContextHolder.getLocaleContext().getLocale()获取上下文Locale
• 将Locale作为参数传入validateExistingShipments方法
• 在validateExistingShipments内部，使用传入的Locale进行国际化消息的解析，而不是依赖线程绑定的上下文

示例代码如下：

// 获取当前请求对应的Locale
Locale currentLocale = ReactiveLocaleContextHolder.getLocaleContext().getLocale();

// 在flatMap中发起异步调用时传入Locale
shipmentRepository.findShipments(data)
    .flatMap(shipments -> validateExistingShipments(shipments, currentLocale))
    .doOnNext(validationResult -> {
        // 处理验证结果
    });

// 异步验证方法，接收Locale参数
private Mono<ValidationResult> validateExistingShipments(List<Shipment> shipments, Locale locale) {
    if (shipments.isEmpty()) {
        // 使用传入的Locale获取国际化提示信息
        String emptyMsg = messageSource.getMessage("shipments.empty", null, locale);
        return Mono.error(new ValidationException(emptyMsg));
    }
    // 其他验证逻辑
    return Mono.just(ValidationResult.success());
}

内容的提问来源于stack exchange，提问作者Jagan Reddy