Project Reactor 不提供响应式集合类型，而是通过 Flux 和 Mono 将集合转为异步序列；支持 fromIterable、fromArray 等工厂方法转换，配合 filter、collectList 等操作符实现响应式集合处理，强调懒加载、背压与非阻塞。
Project Reactor 并不提供“响应式集合”这一独立类型，它处理集合变量的方式是将集合转化为异步序列——核心载体就是 Flux 和 Mono。所谓“对集合变量的异步序列处理”，本质是把同步的 List、Array、Iterable 等结构，封装为可非阻塞、可背压、可组合的操作流，而非直接改造集合本身。
集合数据如何变成响应式流
Reactor 提供了多种工厂方法，把已有集合快速转为 Flux 或 Mono：
- Flux.fromIterable(list)：最常用，适用于 List、Set、Queue 等任意 Iterable；不会复制数据，而是按需拉取
- Flux.fromArray(arr)：适合已知大小、不可变的数组，性能略优
- Flux.range(start, count)：生成整数序列，常用于模拟分页或测试
- Mono.justOrEmpty(optional) 或 Mono.justOrEmpty(obj)：安全包装可能为 null 的单个值，避免 NPE
- Flux.empty() / Mono.empty()：显式表示空结果，语义清晰，优于返回 null
注意：这些操作本身是同步的，只是“声明”了数据源；真正的异步行为发生在后续操作符（如 flatMap 调用 WebClient）、调度器切换（publishOn）或订阅时触发的异步任务中。
集合类操作的响应式替代方案
传统集合操作（如 filter、map、collect）在 Reactor 中由对应操作符实现，但语义和执行时机不同：
构建 Shopify 嵌入式应用（Embedded App）的开发技能：基于 @shopify/shopify-app-react-router + React Router v7 + Admin API 2026-04。覆盖 shopifyApp 配置、authenticate.admin 的 GraphQL/REST 调用、Webhook 校验、Session 存储、订阅计费、App Bridge 导航、部署，并新增：适用场景判断、安全最佳实践、错误处理与容错、最佳实践、常见问题 FAQ、高级场景。G
- filter + map：仍是一对一转换，但延迟执行、支持背压；不立即遍历整个集合，而是逐个元素判断与加工
-
collectList() / collectSortedList() / collectMultimap()：这些是终止操作，会等待流完成，最终聚合为 Mono
- 、Mono
等——这是“把流还原为集合”的标准路径 - reduce()：适合累积计算（如求和、拼接），返回 Mono；相比 Stream.reduce 更强调异步完成语义
-
buffer(int) / window(int)：把长流切分为多个 Flux
- 或 Flux
，用于分批处理，避免 OOM
关键区别在于：Java Stream 是一次性、饥饿求值；而 Flux 是懒加载、按需拉取、可中断。例如对十万条记录调用 Flux.fromIterable(list).filter(...).take(10)，底层只遍历前若干项就停止，不构造中间集合。
常见陷阱与注意事项
把集合转成响应式流看似简单，但几个细节容易引发问题：
- 无限流慎用 collectList()：Flux.interval(...) 这类无限流若直接 collectList()，会导致内存持续增长直至 OOM
- 同步集合操作别混进异步链：比如在 flatMap 内部用 new ArrayList().addAll(...) 做批量收集，会破坏非阻塞特性，应改用 buffer 或 collectList
- null 处理要主动：Flux.fromIterable(null) 会抛 NullPointerException；应先判空，或用 Flux.defer(() -> list == null ? Flux.empty() : Flux.fromIterable(list))
- 大集合首次订阅开销：Flux.fromIterable(list) 在 subscribe 时才会开始迭代，但若 list 是数据库查询结果且未分页，仍可能造成瞬时内存压力
何时该用 Flux，何时选 Mono
取决于业务语义，而非集合大小：
- 返回零到多个实体列表（如查用户列表、日志流）→ 用 Flux
- 返回单个聚合结果（如 count()、sum()、findFirst()、toSet()）→ 用 Mono
/ Mono - 返回一个完整集合对象（如 findAll() 返回 List
）→ 推荐 Flux ，由调用方决定是否 collectList；若强依赖 List 接口（如第三方 SDK），再用 Mono - >
- 空结果统一语义：Flux.empty() 比 Mono.just(Collections.emptyList()) 更符合响应式契约，也利于下游操作符链自然传播
不复杂但容易忽略：集合变量本身没变，变的是你与它的交互方式——从“我拉取全部再处理”，变成“我声明处理逻辑，让数据按节奏流向我”。
