Spring Boot 3.2.2中MongoItemReader已弃用，如何使用MongoPagingItemReader

Spring Batch 5.x（对应Spring Boot 3.2+）中，MongoPagingItemReader的原有setTemplate、setQuery、setTargetType等setter方法已被弃用，官方推荐使用构建器模式配合Spring Data MongoDB的原生查询API来创建实例。不同于JdbcPagingItemReader需要QueryProvider，Mongo端直接用Query对象就能完成查询逻辑定义，更贴合MongoDB的使用习惯。

核心配置步骤 #

1. 用构建器替代Setter注入 #

直接通过MongoPagingItemReader.builder()链式配置所有参数，替代传统的setter调用：

• 传入MongoTemplate实例
• 指定目标实体类型
• 用Query对象定义查询条件与排序规则

2. 必须配置稳定排序 #

MongoDB的分页依赖稳定的排序字段（如主键id），否则分页过程中会出现数据重复或遗漏，这是配置的核心要求。

完整可运行示例 #

import org.springframework.batch.item.data.MongoPagingItemReader;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.domain.Sort;

// 假设业务实体为User
public class UserBatchReader {

    public MongoPagingItemReader<User> buildUserReader(MongoTemplate mongoTemplate) {
        // 构建查询条件，替代原有的字符串Query
        Query query = new Query()
                .addCriteria(Criteria.where("status").is("VALID")) // 示例业务筛选条件
                .with(Sort.by(Sort.Direction.ASC, "id")); // 必须指定排序，保证分页一致性

        return MongoPagingItemReader.<User>builder()
                .name("userPagingReader") // 给Reader命名，用于Batch监控与日志
                .mongoTemplate(mongoTemplate)
                .collection("user_collection") // 指定MongoDB集合名称
                .targetType(User.class)
                .query(query)
                .pageSize(100) // 每页读取的数据量
                .build();
    }
}

分区任务适配 #

如果是批量分区场景，只需在每个分区的Reader实例中，通过Query添加分区专属的筛选条件即可，比如按ID范围分片：

// 分区示例：仅读取ID在[startId, endId]区间内的数据
Query partitionQuery = new Query()
        .addCriteria(Criteria.where("id").gte(startId).lte(endId))
        .with(Sort.by(Sort.Direction.ASC, "id"));

return MongoPagingItemReader.<User>builder()
        // 复用通用配置...
        .query(partitionQuery)
        .build();

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