Hangfire运行时如何获取作业所属队列？能否通过PerformContext获取？

这个需求完全可以实现，有两种实现方案，不需要改动现有作业注册逻辑，适配 Hangfire 1.7.9 + ASP.NET Core 3.1 的技术栈。

方案1：全局过滤器实现（推荐，无需修改作业代码） #

通过 Hangfire 服务过滤器在所有作业执行前统一做队列校验，适合临时修复场景，对现有业务代码侵入性为0。

实现步骤 #

1. 自定义校验过滤器

using Hangfire.Common;
using Hangfire.Server;
using System;

public class QueueMatchValidationFilter : IServerFilter
{
    public void OnPerforming(PerformingContext context)
    {
        // 从存储中读取作业绑定的队列名
        var targetQueue = context.Connection.GetJobParameter(context.BackgroundJob.Id, "Queue");
        // 获取当前服务器名称，和你们队列命名规则保持大小写一致即可
        var currentServer = Environment.MachineName;

        // 队列名不匹配则直接取消作业执行
        if (!string.Equals(targetQueue, currentServer, StringComparison.OrdinalIgnoreCase))
        {
            context.Canceled = true;
            // 可在此处添加日志，记录作业ID、预期队列、当前服务器信息，方便后续排查原问题
        }
    }

    public void OnPerformed(PerformedContext context)
    {
        // 无需实现逻辑
    }
}

2. 注册全局过滤器
   在 Startup.cs 的 Hangfire 服务配置中添加过滤器即可生效：

public void ConfigureServices(IServiceCollection services)
{
    services.AddHangfire(config =>
    {
        // 保留你原有Hangfire配置，比如存储配置、序列化配置等
        config.UseFilter<QueueMatchValidationFilter>();
    });

    // 其他服务注册逻辑
}

方案2：单个作业方法内校验 #

如果只需要针对特定作业做校验，可以直接在作业方法中注入PerformContext获取队列名。

实现步骤 #

1. 修改作业接口/实现的方法签名，新增PerformContext参数：

public interface IMyTestJob
{
    // 新增PerformContext参数，Hangfire会自动注入
    Task Run(PerformContext context);
}

2. 调整作业注册代码的表达式，不用传实际参数，填default即可：

RecurringJob.AddOrUpdate<IMyTestJob>(input.Id, x => x.Run(default), input.Cron, TimeZoneInfo.Local, input.QueueName);

3. 在方法内做队列校验：

public async Task Run(PerformContext context)
{
    var targetQueue = context.Connection.GetJobParameter(context.BackgroundJob.Id, "Queue");
    var currentServer = Environment.MachineName;
    if (!string.Equals(targetQueue, currentServer, StringComparison.OrdinalIgnoreCase))
    {
        // 队列不匹配直接终止执行，可按需添加日志
        return;
    }

    // 原有业务逻辑
}

注意事项 #

• 比对队列名和服务器名时，大小写规则要和你们当初创建队列的命名规则完全一致，避免误判。
• 如果要避免校验不通过的作业被计入失败重试，可以给自定义的终止异常添加[AutomaticRetry(Attempts = 0)]特性，或者在全局重试配置中排除此类校验异常。

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