Hangfire多队列单Worker配置：失败重试任务回归原队列求助

你的问题很典型——Hangfire默认会将失败重试的任务路由到default队列，这确实会打乱你按队列隔离Worker的设计。下面给你两种简单有效的解决办法：

方案1：全局过滤器（推荐，所有任务自动生效） #

创建一个自定义的Job过滤器，当任务进入失败状态时，强制将重试任务的队列重置为原任务的队列。

首先，定义过滤器类：

using Hangfire.Common;
using Hangfire.Server;
using Hangfire.States;

public class KeepOriginalQueueOnRetryAttribute : JobFilterAttribute, IElectStateFilter
{
    public void OnStateElected(ElectStateContext context)
    {
        // 仅处理失败重试的情况
        if (context.CandidateState is FailedState failedState)
        {
            // 获取原任务的队列信息
            var originalQueue = context.Job.GetJobParameter<string>("Queue");
            
            if (!string.IsNullOrEmpty(originalQueue))
            {
                // 创建新的重试状态，并指定原队列
                var retryState = new ScheduledState(failedState.NextExecution)
                {
                    Queue = originalQueue
                };
                
                context.CandidateState = retryState;
            }
        }
    }
}

然后在你的Configure方法里注册这个全局过滤器：

public void Configure(IApplicationBuilder app, IHostingEnvironment env) 
{ 
    // 注册全局过滤器，让所有失败任务重试时回到原队列
    GlobalJobFilters.Filters.Add(new KeepOriginalQueueOnRetryAttribute());

    // 你的现有代码...
    app.UseHangfireDashboard("/scheduler", new DashboardOptions { 
        Authorization = new[] { new HangFireAuthorization() }, 
        AppPath = "/" 
    }); 
    app.UseHangfireServer(new BackgroundJobServerOptions() { 
        ServerName = string.Format("{0}:facebookqueue", Environment.MachineName), 
        Queues = new[] { "facebookqueue" }, 
        WorkerCount = 1 
    }); 
    app.UseHangfireServer(new BackgroundJobServerOptions() { 
        ServerName = string.Format("{0}:googlequeue", Environment.MachineName), 
        Queues = new[] { "googlequeue" }, 
        WorkerCount = 1 
    }); 
    RecurringJob.AddOrUpdate<IScheduledJobs>(recurringJobId: "FacebookExtractorJobYesterday", methodCall: services => services.RecurringJobYesterday(null, JobCancellationToken.Null), cronExpression: cronExp, timeZone: TimeZoneInfo.Local, queue: "facebookqueue"); 
    RecurringJob.AddOrUpdate<IGoogleScheduledJobs>(recurringJobId: "GoogleExtractorJobYesterday", methodCall: services => services.RecurringJobYesterday(null, JobCancellationToken.Null), cronExpression: cronExp, timeZone: TimeZoneInfo.Local, queue: "googlequeue"); 
}

方案2：针对单个任务配置重试队列 #

如果你只想让特定任务生效，可以直接在任务方法上添加RetryAttribute并指定队列：

public interface IScheduledJobs
{
    // 指定该任务失败重试时进入facebookqueue队列
    [Retry(Attempts = 3, Queue = "facebookqueue")]
    void RecurringJobYesterday(string param, JobCancellationToken token);
}

public interface IGoogleScheduledJobs
{
    // 指定该任务失败重试时进入googlequeue队列
    [Retry(Attempts = 3, Queue = "googlequeue")]
    void RecurringJobYesterday(string param, JobCancellationToken token);
}

原理说明 #

• 方案1通过全局过滤器拦截任务状态变更，当任务失败时，手动将重试任务的队列设置为原任务的队列，所有任务都会自动继承这个行为，完美适配你的多队列隔离场景。
• 方案2更灵活，针对单个任务指定重试队列，适合不需要全局生效的场景。

两种方案都能实现你的核心需求：让失败重试的任务回到原所属队列，保证任务始终在对应的Worker队列中执行，不会破坏你原本的任务隔离设计。

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