服务器重启后重试失败任务的Java成熟库方案咨询

一、生产级可用的Java库 #

1. Spring Batch #

Spring Batch 是专为持久化任务、批处理场景设计的框架，完美适配重启后恢复失败任务的需求：

• 将图片上传到第三方API的逻辑封装为 Step，任务执行状态（含失败记录）会持久化到 JobRepository（默认支持数据库存储）；
• 内置重试、跳过策略，可配置重试次数、间隔时间；
• 应用重启后，能自动从上次失败的断点继续执行未完成任务，无需额外开发状态恢复逻辑。

2. Quartz Scheduler #

Quartz 是成熟的任务调度框架，支持将任务元数据持久化到数据库，可实现失败任务的重启恢复：

• 将每个图片上传请求封装为 JobDetail，任务执行状态、重试规则均存储在数据库中；
• 配置 Trigger 实现失败后的自动重试，可自定义重试间隔、次数；
• 应用重启时，Quartz 会自动从数据库加载所有未完成/失败的任务，重新调度执行。

3. Resilience4j Retry + 自定义持久化扩展 #

Resilience4j 的 Retry 组件轻量灵活，虽默认是内存级重试，但可通过扩展实现持久化：

• 自定义 RetryRegistry，每次重试失败时，将任务关键信息（图片ID、第三方API参数、当前重试次数、下次重试时间）持久化到数据库；
• 应用启动时，初始化扫描任务，加载数据库中未完成的失败任务，重新触发重试流程。

二、自定义实现方案 #

1. 基于数据库的任务队列 #

如果需要完全贴合业务逻辑，可自行实现持久化任务队列：

• 创建任务表，字段包含：任务ID、图片存储路径/标识、第三方API参数、任务状态（待处理/处理中/失败/成功）、重试次数、下次重试时间、创建时间；
• 用异步线程池定期扫描表中「失败」或「待处理」且到达重试时间的任务，执行上传逻辑；
• 任务成功则更新状态为「成功」，失败则递增重试次数、计算下次重试时间并更新；
• 应用重启时，启动初始化逻辑，扫描所有未完成任务，加入执行队列。

2. 修复Spring Retry的RetryContextCache实现 #

你之前尝试自定义 RetryContextCache 失败，大概率是因为 RetryContext 包含不可序列化对象（如请求上下文、IO流等）。可调整实现思路：

• 不要直接序列化整个 RetryContext，而是抽取其中的业务关键数据（如图片ID、第三方API调用参数）进行序列化存储；
• 恢复时，根据存储的业务数据重新构建重试逻辑，而非反序列化原生 RetryContext；
• 自定义 RetryContextCache 的 get 和 put 方法，仅处理可序列化的业务元数据，避免序列化失败问题。

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