Hangfire的Fire and Forget任务重复执行及进度上报问题咨询

问题1：Fire and Forget模式任务反复自动重入队 #

核心原因 #

• Hangfire默认开启自动重试机制：任务执行过程抛出未捕获异常时，默认最多重试10次，间隔逐次拉长，就会出现每隔几分钟重新执行的现象。
• 任务执行时长超过配置的InvisibilityTimeout（不可见超时，默认30分钟）时，Hangfire会判定任务执行失败，自动重新入队。
• 多实例部署时如果锁配置异常，也可能出现重复执行的情况。

解决步骤 #

1. 关闭或自定义重试策略：给任务执行方法加重试配置特性，完全禁用重试可以写：

[AutomaticRetry(Attempts = 0, OnAttemptsExceeded = AttemptsExceededAction.Delete)]
[ApiExplorerSettings(IgnoreApi = true)]
public void RunImportProcess()
{
    // 业务逻辑
}

2. 调整不可见超时时间：根据你的任务最大执行时长，调整存储配置的超时参数，以SqlServer存储为例：

// Program.cs 或 Startup.cs 中Hangfire配置处修改
GlobalConfiguration.Configuration.UseSqlServerStorage("你的数据库连接字符串", new SqlServerStorageOptions
{
    InvisibilityTimeout = TimeSpan.FromHours(2) // 按实际最长任务耗时设置
});

3. 排查任务逻辑：检查imports.RunServerSide()是否有未捕获的异常，确保任务能正常执行完成返回。

另外你现有代码里的email.SendSupportEmail逻辑位置错误：你是把任务加入队列后立刻发邮件，此时任务还未执行，完全不符合「任务完成发通知」的预期，建议改为任务执行完成后触发：

[HttpPost]
[Route("BackgroundJobTask")]
public IActionResult BackgroundJobTask()
{
    var jobId = BackgroundJob.Enqueue(() => RunImportProcess());
    // 任务执行成功后再发通知
    BackgroundJob.ContinueWith(jobId, () => email.SendSupportEmail("Background Job Complete", "Test", false,true));
    return Ok(jobId); // 建议把jobId返回给前端，用于进度查询
}

问题2：任务执行进度上报实现 #

Hangfire本身没有内置进度跟踪能力，轻量实现方案如下：

1. 新增进度存储结构：在数据库中新增任务进度表，字段至少包含JobId（字符串主键）、Progress（整型，0-100）、Status（枚举：排队中/执行中/成功/失败）、ErrorMsg（异常信息）、CreateTime、UpdateTime，也可以用Redis做缓存存储。
2. 执行过程更新进度：在RunImportProcess的业务逻辑节点处，更新对应JobId的进度值，比如：

[ApiExplorerSettings(IgnoreApi = true)]
public void RunImportProcess()
{
    // 任务启动，更新状态为执行中，进度0
    ProgressService.Update(JobId.Current, 0, JobStatus.Running);
    // 执行第一个业务阶段
    imports.RunFirstStep();
    ProgressService.Update(JobId.Current, 30, JobStatus.Running);
    // 执行第二个业务阶段
    imports.RunSecondStep();
    ProgressService.Update(JobId.Current, 70, JobStatus.Running);
    // 执行完成
    imports.RunServerSide();
    ProgressService.Update(JobId.Current, 100, JobStatus.Success);
}

3. 新增进度查询接口：提供GET接口接收jobId参数，返回对应任务的进度数据。
4. 前端交互逻辑：调用任务触发接口拿到返回的jobId后，每隔几秒轮询进度查询接口，实时渲染进度即可。

如果不想自己实现存储逻辑，也可以使用Hangfire官方的付费扩展Hangfire.Pro.Progress，无需额外开发。

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