Spring WebFlux中Mono管道使用外部变量是否存在线程安全问题？

用法合规性结论 #

这种用法不合规，存在明确的线程安全隐患，直接导致并发请求间的id串用。

问题根源 #

Spring WebFlux控制器默认是单例Bean，所有请求会复用同一个控制器实例。如果你的代码将从MyRequest提取的id赋值给了控制器的成员变量/静态变量，再在Mono.fromCallable或map操作中引用这个共享变量，就会出现串扰：

• 当请求A将id=123写入共享变量后，事件循环线程尚未完成A的响应式处理，请求B就将id=abc覆盖了该变量
• 后续A的响应式链执行时，读取到的是被B覆盖后的id，最终返回错误结果

即使你将id定义为方法内局部变量，若fromCallable中引用的变量被其他逻辑意外修改（比如使用可变对象并在外部操作），也可能引发类似问题，但这种情况极少——通常问题都出在共享变量的误用。

正确实现方式 #

方式1：直接在响应式链中引用请求对象属性 #

避免提前提取id到外部变量，直接在响应式操作中使用请求对象的id：

@RestController
public class MyController {
    @PostMapping("/api/handle")
    public Mono<MyResponse> handleRequest(@RequestBody MyRequest request) {
        return Mono.fromCallable(() -> {
            // 直接使用请求对象的id，无变量共享风险
            return executeBusinessLogic(request.getId());
        }).map(result -> new MyResponse(request.getId()));
    }
}

方式2：使用请求专属局部变量 #

将id提取为方法内的局部变量（每个请求调用会生成独立副本），响应式链捕获该副本使用：

@RestController
public class MyController {
    @PostMapping("/api/handle")
    public Mono<MyResponse> handleRequest(@RequestBody MyRequest request) {
        String requestId = request.getId(); // 局部变量，每个请求独立
        return Mono.fromCallable(() -> {
            return executeBusinessLogic(requestId);
        }).map(result -> new MyResponse(requestId));
    }
}

这种写法是线程安全的，因为局部变量存储在当前请求的方法调用栈中，不会被其他请求访问或覆盖。

核心注意事项 #

• 绝对不要将请求相关的状态（如id、请求参数）存储在控制器的成员变量或静态变量中，单例Bean的共享特性会直接引发并发问题。
• 响应式链中的Lambda捕获局部变量时，优先使用不可变类型（如String、基本类型包装类），避免可变对象被意外修改。

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