本文详解 spring batch 中基于步骤执行结果（如 failed 或 complete）动态决定后续流程与作业最终状态的正确配置方式，重点解决因 transition 配置错误导致作业状态与预期不符的问题。
本文详解 spring batch 中基于步骤执行结果（如 failed 或 complete）动态决定后续流程与作业最终状态的正确配置方式，重点解决因 transition 配置错误导致作业状态与预期不符的问题。
在 Spring Batch 的 Job 构建中，流程控制（Flow Control）依赖于 SimpleStepHandler 对步骤退出码（Exit Status）的精确匹配与跳转（transition）配置。常见误区是混淆 on("*") 的匹配优先级、忽略 from() 的隐式起始点，或误用 .fail() 与 .end() 的作用范围。以下将结合实际需求，给出健壮、可维护的配置方案。
✅ 正确的流程逻辑解析
您的需求本质是双路径分支控制：
- 路径 A（失败路径）：fileCollectTasklet() 返回 FAILED → 执行 writerTasklet() → 无论其结果如何，作业强制以 FAILED 状态结束；
- 路径 B（默认路径）：fileCollectTasklet() 返回任意非 FAILED 状态（如 COMPLETED, NOOP 等）→ 执行 writerTasklet() → 无论其结果如何，作业正常以 COMPLETED 状态结束。
关键点在于：
? on("FAILED") 必须紧接在 .start() 或 .from() 后显式声明，且仅匹配该步骤的退出码；
? 每个 .to(step) 后必须跟 .on(...) 定义下一步跳转条件，"*" 表示通配所有退出码；
? .fail() 表示立即终止作业并标记为 FAILED，不执行后续任何步骤；
? .end() 表示正常结束当前 Flow，作业整体状态由最后一步的 ExitStatus 决定——但配合 .on("*").end() 可实现“忽略 writer 结果，强制成功”。
✅ 正确代码实现
@Bean
public Job testJob() {
return jobBuilderFactory.get("test_job")
.incrementer(new RunIdIncrementer())
.preventRestart()
// 主起点：fileCollectTasklet()
.start(fileCollectTasklet())
// 分支1：若 fileCollect 失败 → 运行 writer → 强制作业失败
.on("FAILED")
.to(writerTasklet())
.on("*") // 匹配 writer 的任意退出码（COMPLETED/FAILED/STOPPED等）
.fail() // ⚠️ 关键：此处 fail 作用于整个 Job，非仅 flow
// 分支2：从同一起点出发，匹配其他所有状态
.from(fileCollectTasklet())
.on("*") // 匹配 COMPLETE、NOOP 等非 FAILED 状态
.to(writerTasklet())
.on("*") // 同样忽略 writer 结果
.end() // 正常结束 Flow，Job 状态为 COMPLETED
.end(); // 完成 Job 构建
}
⚠️ 常见错误与注意事项
- 禁止重复定义同一步骤起点：fileCollectTasklet() 在 start() 和 from() 中各出现一次是合法的，但不可写成 start(...).from(...).from(...) 多重嵌套，会导致 IllegalStateException。
- *`on("")的匹配顺序很重要**：Spring Batch 按注册顺序匹配 transition。因此on("FAILED")必须放在on("")之前，否则会提前捕获所有状态，使FAILED` 分支失效。
- .fail() 与 .stopAndRestart() 的区别：.fail() 是终态，作业不可重启（因 preventRestart() 已启用）；若需支持人工干预后重试，应改用 .stopAndRestart() 并配合自定义 ExitStatus。
- Tasklet 退出码需显式返回：确保 fileCollectTasklet() 在异常时返回 ExitStatus.FAILED（可通过 StepExecution.setExitStatus(ExitStatus.FAILED)），否则默认返回 COMPLETED，导致分支逻辑失效。
✅ 总结
Spring Batch 的流程控制核心在于 “步骤退出码 + 显式 transition 规则”。通过合理组合 .on(), .to(), .fail(), .end()，可精准实现复杂业务场景下的作业状态编排。务必验证每个 Tasklet 的实际退出码，并利用 JobExplorer 或日志输出 StepExecution.getExitStatus() 进行调试，避免因状态不一致引发静默失败。
