如何使用Reactive Mongo Template高效批量删除指定条件文档？

针对你处理50K条文档删除耗时15秒的问题，可通过以下几点优化：

1. 给createdAt字段添加索引 #

当前查询依赖createdAt的范围条件，无索引时MongoDB会执行全表扫描，这是性能瓶颈的核心原因。添加单字段索引后，查询效率可从O(n)降至O(logn)。

创建索引的代码示例：

// 在项目初始化阶段执行
mongoTemplate.indexOps(AuditLog.class)
    .ensureIndex(new Index("createdAt", Sort.Direction.ASC));

2. 替换findAllAndRemove为remove（不返回删除文档） #

findAllAndRemove会将所有被删文档查询并返回，50K条数据的序列化、传输会占用大量内存与IO资源。改用remove直接执行删除操作，不返回文档，能大幅降低开销。

优化后的核心代码：

public Mono<Long> archiveAuditLogs(long filteredEpochTime) {
    Date filteredDate = Date.from(Instant.ofEpochMilli(filteredEpochTime));
    Query query = Query.query(Criteria.where("createdAt").lte(filteredDate));
    return mongoTemplate.remove(query, AuditLog.class)
        .map(DeleteResult::getDeletedCount);
}

3. 分批删除（避免一次性锁表） #

若删除数据量过大，一次性操作可能导致集合锁，影响其他业务。可分批次删除，每次处理固定数量文档，直到无符合条件的数据。

分批删除的代码示例：

public Mono<Void> archiveAuditLogsBatch(long filteredEpochTime, int batchSize) {
    Date filteredDate = Date.from(Instant.ofEpochMilli(filteredEpochTime));
    Query query = Query.query(Criteria.where("createdAt").lte(filteredDate))
        .limit(batchSize);

    return mongoTemplate.remove(query, AuditLog.class)
        .flatMap(result -> {
            if (result.getDeletedCount() > 0) {
                // 递归执行下一批删除
                return archiveAuditLogsBatch(filteredEpochTime, batchSize);
            }
            return Mono.empty();
        });
}

调用时可设置合理批次大小（如1000-5000），平衡删除效率与资源占用。

4. 异步执行删除操作（非阻塞业务流程） #

若业务无需等待删除完成结果，可将操作放到异步线程池执行，避免阻塞主线程或调用方请求响应。

示例：

// 使用Reactor线程池异步执行
public Mono<Void> archiveAuditLogsAsync(long filteredEpochTime) {
    Date filteredDate = Date.from(Instant.ofEpochMilli(filteredEpochTime));
    Query query = Query.query(Criteria.where("createdAt").lte(filteredDate));
    
    return mongoTemplate.remove(query, AuditLog.class)
        .subscribeOn(Schedulers.boundedElastic())
        .then();
}

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