Java批量处理需动态捕获单条异常的核心方案是：用try-catch封装每条数据处理逻辑，确保异常隔离；可结合CompletableFuture实现异步容错；推荐封装为通用模板方法，统一处理、日志与结果聚合。
Java 中批量处理数据时，若想动态捕获每条数据的异常（即某条数据出错不影响其他数据继续执行），核心思路是将单条数据的处理逻辑封装为独立的、可捕获异常的单元，避免整个批次因一次异常而中断。常见于 JDBC 批处理、Stream 处理、消息消费、Excel 导入等场景。
用 try-catch 包裹单条处理逻辑
这是最直接、最可控的方式：在循环或流式处理中，对每条记录单独 try-catch，记录异常信息并继续下一条。
- 适用于 for 循环、增强 for、Iterator 或 Stream 的 forEach（注意：Stream 的 map/filter 不适合放副作用操作，forEach 可用但需确保线程安全）
- 建议将异常详情（如原始数据、错误堆栈、时间戳）写入日志或收集到结果容器中，便于后续排查
- 示例（JDBC 插入）：
for (User user : userList) {
try {
jdbcTemplate.update("INSERT INTO users(name, age) VALUES (?, ?)",
user.getName(), user.getAge());
} catch (DataAccessException e) {
log.warn("插入用户失败 [{}], 原因: {}", user, e.getMessage());
// 可选：存入 failedList 或发告警
failedRecords.add(new FailedRecord(user, e));
}
}
使用 CompletableFuture 实现异步+隔离容错
当批量操作允许异步、且希望进一步解耦失败影响（比如调用远程接口、文件解析等 I/O 密集型任务），可用 CompletableFuture 对每条数据独立提交任务，并统一收集结果与异常。
- 每个 CompletableFuture 内部自行 try-catch，避免 propagate 异常中断整体流程
- 最终通过 allOf + join() 或 whenComplete 统一检查完成状态
- 适合高并发、非强一致性要求的场景，注意线程池配置和资源泄漏风险
自定义批处理模板方法（推荐封装复用）
把“逐条处理 + 异常隔离 + 结果聚合”逻辑抽象成通用工具方法，提升可维护性：
立即学习“Java免费学习笔记（深入）”；
- 输入：数据列表、处理函数（Function<T, R>）、异常处理器（BiConsumer<T, Throwable>）
- 输出：成功结果列表 + 失败记录列表（含原始数据与异常）
- 避免重复写 try-catch，统一日志格式、监控埋点、重试策略（可选）
注意事项与避坑点
- JDBC batchUpdate 默认是原子性批次（addBatch + executeBatch），一旦某条 SQL 报错，整个批次会失败 —— 此时无法“动态捕获单条”，必须改用单条 executeUpdate + try-catch
- MyBatis 的 <foreach> 批量插入本质仍是单条 SQL，不适用“单条异常隔离”；如需逐条控制，应配合 @Transactional(propagation = Propagation.REQUIRES_NEW) 或禁用批量，改用循环 insert
- Spring Batch 提供 SkipPolicy 机制，可配置跳过指定异常类型，天然支持单条容错，适合复杂批作业
- 不要在循环里吞掉异常却不记录 —— 这会导致问题静默丢失
