Spring Data MongoDB聚合$out阶段避免数据回传的疑问

核心结论 #

• 直接关闭未遍历的Stream<Person>，不会将targetCollection中的文档传输到Java应用。
• 原因在于Spring Data MongoDB的Stream实现是延迟加载的：只有当你触发Stream的遍历操作（比如调用forEach、collect、iterator等）时，才会驱动MongoDB客户端向服务端发起数据拉取请求。而聚合管道里的$out或$merge阶段是完全在MongoDB服务端执行的——不管客户端是否拉取聚合结果，服务端都会完成写入targetCollection的操作，只是客户端不会接收这些数据。

官方文档佐证 #

Spring Data MongoDB官方文档明确说明：

返回Stream的查询（包括聚合操作）采用延迟执行策略，只有在迭代Stream的过程中，才会触发实际的数据获取逻辑。聚合操作的服务端执行流程（包括$out/$merge这类写入集合的阶段）独立于客户端的结果拉取动作，客户端仅在遍历Stream时才会接收聚合的返回数据（如果有需要返回的内容）。

同时MongoDB Java驱动的文档也补充：

聚合操作的$out阶段会在服务端直接完成结果写入目标集合的操作，该操作的完成不依赖客户端是否读取聚合结果。当使用Stream接收聚合结果时，Stream仅作为客户端获取结果的通道，未触发遍历则不会发起任何数据传输请求。

额外实践建议 #

• 如果你仅需要执行聚合并写入目标集合、不需要获取返回结果，更推荐使用MongoTemplate的aggregate方法，无需处理返回值，更贴合业务意图：

Aggregation aggregation = Aggregation.newAggregation(
    // 你的聚合阶段定义
    Aggregation.out("targetCollection")
);
mongoTemplate.aggregate(aggregation, "sourceCollection", Object.class);

• 使用MongoRepository的@Aggregation配合Stream时，即便不遍历Stream，服务端的$out写入操作依然会正常执行，只是客户端不会拉取数据，这一点可以放心。

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