Spring Reactor中如何在Mono/Flux的flatMap/flatMapMany中包含多语句？

嘿，我来帮你梳理清楚这个问题～首先得指出你原代码里的一个核心问题：你试图在flatMapMany的lambda里给外部变量title赋值，然后直接在流外使用这个变量。但Spring Reactor是异步非阻塞的，当你执行model.addAttribute("title", title)的时候，这个title大概率还没被赋值（因为flatMapMany里的逻辑可能还没执行到），而且这种外部可变变量在反应式场景下会有线程安全隐患，绝对不推荐这么用。

正确的做法：在反应式流内封装所有操作 #

我们需要把获取Property、生成title、查询Photos这些步骤都串联在反应式流里，把需要的所有数据封装起来，再统一处理Model赋值，而不是依赖外部变量。

方案1：用Reactor自带的Tuple封装数据

// 先把Property、title、Photos整合到一个Mono<Tuple3>中
Mono<Tuple3<Property, String, Flux<Photo>>> combinedData = propertyService.findById(id)
    .map(prop -> {
        // 第一条语句：生成title
        String title = prop.getTitle() + '-' + prop.getType();
        // 第二条语句：查询关联的Photos
        Flux<Photo> photos = photoService.findByPropertyId(prop.getId());
        // 还可以加其他语句，比如打印日志
        System.out.println("正在处理ID为" + prop.getId() + "的Property");
        // 返回封装好的三元组
        return Tuples.of(prop, title, photos);
    });

// 再统一处理Model和返回逻辑
return combinedData.flatMap(tuple -> {
    model.addAttribute("prop", tuple.getT1());
    model.addAttribute("title", tuple.getT2());
    model.addAttribute("photos", tuple.getT3());
    
    if(ajx != null && !ajx.isEmpty() && ajx.equals("1")) {
        return Mono.just("fragment...");
    } else {
        // 返回你的完整视图名称
        return Mono.just("property-detail");
    }
});

方案2：自定义DTO类封装数据（更易读）

如果觉得Tuple不够直观，可以自定义一个简单的数据类来封装需要传递的信息：

// 自定义数据类（Java 16+可用record，也可以用普通类）
record PropertyInfo(Property property, String title, Flux<Photo> photos) {}

// 构建反应式流
Mono<PropertyInfo> propertyInfo = propertyService.findById(id)
    .map(prop -> {
        // 这里可以写任意多条语句
        String title = prop.getTitle() + '-' + prop.getType();
        Flux<Photo> photos = photoService.findByPropertyId(prop.getId());
        log.debug("已获取Property[{}]的关联Photos", prop.getId());
        // 返回自定义DTO
        return new PropertyInfo(prop, title, photos);
    });

// 后续处理逻辑
return propertyInfo.flatMap(info -> {
    model.addAttribute("prop", info.property());
    model.addAttribute("title", info.title());
    model.addAttribute("photos", info.photos());
    
    if(ajx != null && !ajx.isEmpty() && ajx.equals("1")) {
        return Mono.just("fragment...");
    } else {
        return Mono.just("property-detail");
    }
});

核心要点 #

• 在flatMap/flatMapMany的lambda里，你完全可以写多条语句（比如赋值、日志、计算等），但不要把结果暴露到流外部的可变变量中。
• 反应式编程的核心是通过流来传递数据，所有相关的操作都应该在流的操作符（比如map、flatMap）内完成，这样才能保证操作的顺序性和线程安全性。

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