如何用Flux与Spring Boot响应式编程将主库表数据读入Map？

核心原因 #

响应式流是惰性求值的：你只定义了flatMap的处理逻辑，但没有触发数据流的实际执行，导致statusMap.put代码从未被调用。

修复方案 #

结合服务启动场景（用@PostConstruct确保初始化时机），调整代码如下：

import java.util.concurrent.ConcurrentHashMap;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;

@Service
public class YourService {
    private ConcurrentHashMap<String, StatusMaster> statusMap = new ConcurrentHashMap<>();
    private final StatusMasterRepository statusMasterRepository;

    // 构造注入Repository
    public YourService(StatusMasterRepository statusMasterRepository) {
        this.statusMasterRepository = statusMasterRepository;
    }

    @PostConstruct
    public void loadStatusMasterToMap() {
        statusMasterRepository.findAll()
            // 用doOnNext处理元素存入map的副作用，语义更准确
            .doOnNext(status -> statusMap.put(status.getAccountStatus(), status))
            // 阻塞直到流处理完成，确保服务启动时map已填充完毕
            .blockLast();
    }
}

关键要点 #

• 用doOnNext替代flatMap：flatMap用于流的转换（比如把一个元素转成多个元素），而这里只是对每个元素执行存入map的副作用操作，doOnNext更贴合场景。
• 必须触发订阅：响应式流只有在被订阅后才会执行，blockLast()会阻塞当前线程直到流处理完成，适合服务启动时的同步初始化场景；如果不需要同步等待，也可以用subscribe()，但要注意后续业务逻辑可能访问到空map的风险。
• 使用线程安全集合：换成ConcurrentHashMap避免多线程场景下的并发问题，更符合响应式编程的线程模型。

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