如何在Spring WebFlux响应式管道中间提取变量并在后续环节使用

原代码无法运行的原因 #

你写的代码无法正常编译运行是因为Java语法的硬性限制：lambda表达式内部引用的外部局部变量必须是final或者有效final（即赋值后不会再修改），你直接在lambda中修改外部声明的name变量会直接触发编译错误。就算你用数组/原子引用绕开编译限制，异步运行的响应式流也会存在变量可见性、多线程并发修改、订阅复用时值覆盖的问题，最终运行结果不符合预期。

可行解决方案 #

方案1：作用域封装（推荐，符合响应式规范） #

不需要用zip一路传递参数，只需要在拿到name的节点后用flatMap把所有后续需要用到name的操作都封装在同一个lambda作用域内即可，name作为lambda内部的局部变量可以被后续所有操作直接访问，没有任何并发风险，也支持多订阅场景：

public class Example {

    public Mono<String> test() {
        return Mono.just("some random string")
                    .map(String::toUpperCase)
                    // 拿到name后，后续所有需要用name的逻辑都包在这个flatMap里
                    .flatMap(name -> Mono.just(name)
                                .map(/* 你原来的第一个map逻辑 */)
                                .map(/* 你原来的第二个map逻辑 */)
                                .flatMap(/* 你原来的flatMap逻辑 */)
                                .map(/* 你原来的第四个map逻辑 */)
                                .map(result -> result + name)
                                .doOnSuccess(res -> asyncPublish(name))
                    );
    }
     
    public void asyncPublish(String name) {
        // 异步写入消息队列的逻辑
    }
}

方案2：原子引用存储（仅适合单订阅场景） #

如果你确定当前流只会被订阅一次，也可以用原子引用绕开编译限制，实现类似全局变量的效果：

public Mono<String> test() {
    AtomicReference<String> nameRef = new AtomicReference<>();
    return Mono.just("some random string")
                .map(s -> {
                    String name = s.toUpperCase();
                    nameRef.set(name);
                    return name;
                }).map(/* 后续操作逻辑 */)
                  .map(result -> result + nameRef.get())
                  .doOnSuccess(res -> asyncPublish(nameRef.get()));
}

注意：该方案仅适合流只会被订阅一次的场景，若流被多次订阅，原子引用里的值会被多次覆盖，出现线程安全问题，不推荐生产环境使用。

方案3：响应式Context传递（适合跨多流传递的复杂场景） #

如果需要在多个独立的响应式流之间共享变量，可以用WebFlux自带的订阅级Context存储：

public Mono<String> test() {
    return Mono.just("some random string")
                .map(String::toUpperCase)
                // 把name写入Context
                .flatMap(name -> Mono.just(name)
                            .map(/* 其他逻辑 */)
                            .contextWrite(ctx -> ctx.put("name", name))
                )
                // 后续需要用name的位置从Context取
                .flatMap(result -> Mono.deferContextual(ctx -> 
                    Mono.just(result + ctx.get("name"))
                ))
                .doOnSuccess(res -> Mono.deferContextual(ctx -> {
                    asyncPublish(ctx.get("name"));
                    return Mono.empty();
                }));
}

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