WebFlux响应式处理创建机构接口无法返回生成ID该如何实现？

核心错误点 #

• 误用doOnNext算子：doOnNext是副作用观测钩子，仅适用于日志打印、埋点上报这类不影响主流程的逻辑，既不能转换流内数据，也不会触发内部异步操作（如数据库入库）的订阅，不适合承载业务逻辑。
• 流订阅逻辑缺失：你代码中调用doOnNext后的request流没有被返回也没有被订阅，内部的ID生成、入库逻辑根本不会执行，返回的Mono.just和前面的请求处理逻辑完全割裂，自然拿不到生成的ID。
• 外部变量传递ID不符合响应式规范：响应式流要求所有数据在流内流转，使用外部变量存ID会引发线程安全、数据不同步等问题。

正确实现代码 #

@Service
@AllArgsConstructor
public class AgencyServiceImpl implements AgencyService {
    private final AgencyRepository agencyRepository;
    private final UuidGenerator uuidGenerator;

    public Mono<CreateAgencyResponse> createAgency(Mono<CreateAgencyRequest> request) {
        // 使用flatMap完成异步流转换，所有逻辑在流内完成
        return request.flatMap(agencyReq -> {
            // 1. 生成机构唯一ID
            UUID agencyId = uuidGenerator.getUUID();
            // 2. 构造数据库入库实体
            Agency newAgency = new Agency(agencyId, agencyReq.getFields().getName());
            // 3. 调用响应式Repository执行入库，flatMap会自动订阅save返回的Mono
            return agencyRepository.save(newAgency)
                    // 4. 入库成功后，将保存的实体转换为响应对象返回
                    .map(savedAgency -> new CreateAgencyResponse(
                            new CreateAgencyResponseData(savedAgency.getId().toString())
                    ));
        });
    }
}

实现逻辑说明 #

• 整个流程完全跑在响应式流中，不需要外部变量存储ID，所有数据在流内传递，没有线程安全风险。
• 入库操作的异步流通过flatMap和主请求流绑定，一旦入库出现异常，错误会自动向下游传递，直接被WebFlux全局异常处理机制捕获，不需要手动处理异常传播。
• 所有异步操作都由框架负责调度和订阅，不会出现操作丢失、执行顺序错误的问题，完全符合WebFlux响应式开发规范。

注意事项 #

• 所有IO操作（数据库读写、网络调用等）都要使用返回Mono/Flux的响应式API，通过flatMap/concatMap这类转换算子接入主流程，不要在doOnNext/subscribe中处理业务IO逻辑。
• 不要随便在流中使用Mono.just包裹异步操作，避免异步操作没有被正确订阅导致的逻辑丢失问题。

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