Project Reactor与安全发布：Spring WebFlux实体线程安全问题咨询

问题场景 #

在使用R2dbcRepository的Spring WebFlux应用中，存在如下反应式链：

entityRepository //0
    .findById(entityId) //1 Mono<Entity>
    .doOnNext(e-> e.setValue("0")) //2
    .flatMap(entity-> //3
        entityRepository //4
            .save(entity) //5 Mono<Entity>
            .flatMap(this::process) //6 Mono<Result>
            .flatMap(result-> { //7
                entity.setValue("1"); //8
                return entityRepository //9
                    .save(entity) //10 Mono<Entity>
                    .thenReturn(result); //11 Mono<Result>
            }) //12
            .flatMap(result-> /*REST request using WebFlux*/) //13 Mono<Body>
            .flatMap(body -> { //14
                entity.setValue("2"); //15
                return entityRepository //16
                    .save(entity) //17 Mono<Entity>
                    .thenReturn(body); //18 Mono<Body>
            }) //19
            
    ); //20 Mono<Body>

第3行的entity对象会在后续第8行和第15行被修改（可能处于不同线程）。请问这是否属于反应式流中实体对象的不安全发布？这种编写反应式链的方式是否不正确？

回答 #

这确实属于不安全的实体对象操作，这种编写方式存在明显问题：

• 线程安全风险：Spring WebFlux的操作可能在不同线程上执行（取决于调度器配置），而entity是可变对象且被多个操作共享。在无同步措施的情况下，多线程修改同一个可变实例会引发竞态条件——比如某线程的修改可能被其他线程覆盖，或者读取到不一致的对象状态，导致业务逻辑异常。

• 违反反应式编程核心原则：反应式流要求操作尽可能避免副作用，尤其是共享可变状态的外部副作用。直接修改链中共享的entity实例，会让代码行为变得不可预测，调试和维护难度大幅提升。

正确的优化方式 #

1. 使用实体副本：每次修改前创建实体的不可变副本（比如借助Lombok的@Data+@Builder实现copy()方法），避免共享同一个可变实例：

   .flatMap(result -> {
       Entity updatedEntity = entity.copy().setValue("1");
       return entityRepository.save(updatedEntity)
           .thenReturn(result);
   })
   

2. 依赖保存后的返回实体：R2dbc的save方法通常会返回更新后的实体，后续操作应基于这个返回的新实例进行修改，而非原始的共享对象：

   .flatMap(savedEntity -> this.process(savedEntity))
   .flatMap(result -> {
       Entity updatedEntity = savedEntity.setValue("1"); // 若实体是不可变则用副本
       return entityRepository.save(updatedEntity)
           .thenReturn(result);
   })
   

3. 保持操作纯粹性：每个反应式步骤仅处理当前输入的对象，不依赖外部共享的可变状态，确保逻辑的可预测性和线程安全性。

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