Spring Data MongoRepository saveAll能否忽略重复错误并处理并发写入？

当然可以实现这个需求，结合MongoDB的唯一索引特性和Spring Data的自定义逻辑，既能忽略重复插入的错误，又能确保并发场景下至少有一方成功完成批量保存操作。下面是具体的实现方案：

1. 先配置唯一索引（核心前提） #

首先必须在MongoDB集合上创建唯一索引，这是检测重复数据的基础。你可以在实体类中通过Spring Data的注解直接配置：

@Document(collection = "your_target_collection")
public class YourBusinessEntity {
    @Id
    private String id;
    
    // 标记业务唯一字段，确保重复数据会触发MongoDB的唯一键冲突
    @Indexed(unique = true)
    private String uniqueBizKey; // 比如订单号、用户唯一标识等
    
    // 其他业务字段及getter/setter
}

MongoDB的唯一索引是原子性的，并发写入时只会有第一个请求能成功插入重复数据，后续请求会立即抛出DuplicateKeyException，从根源上避免“两边都失败”的情况。

2. 自定义批量保存逻辑，忽略重复错误 #

Spring Data默认的MongoRepository.saveAll()遇到唯一键冲突时会直接中断整个批量操作，我们需要自定义逻辑来绕过这个限制，同时处理异常。

方案一：用MongoTemplate实现批量插入（忽略重复，继续执行） #

通过MongoTemplate构建批量插入操作，开启continueOnError选项，这样即使部分文档触发重复错误，其他文档仍会继续插入。同时捕获唯一键异常，视为数据已存在的正常情况：

@Service
public class YourEntityService {
    private final MongoTemplate mongoTemplate;
    private static final Logger log = LoggerFactory.getLogger(YourEntityService.class);

    public YourEntityService(MongoTemplate mongoTemplate) {
        this.mongoTemplate = mongoTemplate;
    }

    public void batchSaveIgnoringDuplicates(List<YourBusinessEntity> entities) {
        List<InsertOneModel<YourBusinessEntity>> insertTasks = entities.stream()
                .map(InsertOneModel::new)
                .collect(Collectors.toList());

        BulkWriteOptions options = new BulkWriteOptions();
        options.continueOnError(true); // 遇到错误不中断，继续处理后续文档

        try {
            mongoTemplate.bulkWrite(insertTasks, options);
        } catch (DuplicateKeyException e) {
            // 仅处理唯一键冲突（错误码11000），其他异常正常抛出
            if (e.getErrorCode() == 11000) {
                log.info("部分或全部数据已存在，无需重复插入");
            } else {
                throw e;
            }
        }
    }
}

方案二：重写MongoRepository的saveAll方法（逐行处理，精细控制） #

如果你想保留MongoRepository的接口风格，可以自定义Repository扩展，实现带重复忽略逻辑的saveAll：

// 自定义Repository接口
public interface CustomYourEntityRepository {
    <S extends YourBusinessEntity> List<S> saveAllIgnoringDuplicates(Iterable<S> entities);
}

// 实现类
public class CustomYourEntityRepositoryImpl implements CustomYourEntityRepository {
    private final MongoTemplate mongoTemplate;
    private static final Logger log = LoggerFactory.getLogger(CustomYourEntityRepositoryImpl.class);

    public CustomYourEntityRepositoryImpl(MongoTemplate mongoTemplate) {
        this.mongoTemplate = mongoTemplate;
    }

    @Override
    public <S extends YourBusinessEntity> List<S> saveAllIgnoringDuplicates(Iterable<S> entities) {
        List<S> savedEntities = new ArrayList<>();
        for (S entity : entities) {
            try {
                savedEntities.add(mongoTemplate.insert(entity));
            } catch (DuplicateKeyException e) {
                if (e.getErrorCode() == 11000) {
                    log.warn("实体[唯一键: {}]已存在，跳过插入", entity.getUniqueBizKey());
                } else {
                    throw e;
                }
            }
        }
        return savedEntities;
    }
}

// 主Repository继承自定义接口
public interface YourEntityRepository extends MongoRepository<YourBusinessEntity, String>, CustomYourEntityRepository {
}

这种方式会逐个处理实体，遇到单个重复时跳过，继续处理下一个，适合需要跟踪每个实体插入结果的场景。

3. 确保并发写入至少一方成功的关键 #

• 依赖MongoDB唯一索引的原子性：并发请求中，第一个到达的请求会成功插入所有数据，后续请求触发的唯一键异常可以明确判定数据已存在，无需再重试或报错。
• 精准的异常处理：只忽略11000错误码的唯一键冲突，其他异常（比如网络问题、字段校验失败）正常抛出，避免掩盖真正的问题。

额外说明 #

如果你的需求是“存在则更新，不存在则插入”，可以改用upsert操作（配合UpdateOptions.upsert(true)），这样不会触发重复错误，但会覆盖已存在的文档。如果不需要更新数据，上面的插入忽略方案更适合。

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