使用HangFire执行定时任务时如何复用类的同一实例以保留Queue数据

问题根本原因 #

• HangFire默认使用内置的JobActivator创建任务类实例，不会读取ASP.NET Core DI容器中的服务注册，即便你将任务类注册为单例，默认激活器依然会每次反射创建新实例，导致实例内的队列每次都被初始化。

推荐解决方案 #

方案1：替换HangFire激活器+单独注册队列单例（生产环境最优） #

该方案完全贴合.NET依赖注入规范，稳定性最高：

1. 首先将队列封装为独立的单例服务，避免和任务执行类生命周期绑定

// 自定义队列包装类
public class CustomTaskQueue
{
    // 对外暴露队列实例，也可以封装入队、出队方法控制访问
    public Queue<string> InnerQueue { get; } = new Queue<string>();
}

// 在Startup.cs/Program.cs中注册为全局单例
builder.Services.AddSingleton<CustomTaskQueue>();

2. 替换HangFire默认的JobActivator为.NET DI容器的激活器，让HangFire创建任务类时从DI容器获取依赖

builder.Services.AddHangfire(config =>
{
    // 你原有HangFire配置，比如数据库存储等
    config.UseActivator(new AspNetCoreJobActivator(builder.Services.BuildServiceProvider()));
});

3. 任务执行类通过构造函数注入队列服务，调度任务时采用DI类型绑定的方式

// 任务执行类定义
public class ScheduledTaskService
{
    private readonly CustomTaskQueue _taskQueue;

    // 注入的队列永远是同一个单例实例
    public ScheduledTaskService(CustomTaskQueue taskQueue)
    {
        _taskQueue = taskQueue;
    }

    // 任务执行方法
    public void RunPerMinuteTask()
    {
        // 直接操作队列即可，值会全局保留
        _taskQueue.InnerQueue.Enqueue("新的测试值");
        if(_taskQueue.InnerQueue.TryDequeue(out var value))
        {
            // 你的业务逻辑
        }
    }
}

// 调度任务的写法，绑定DI容器中的服务类型
RecurringJob.AddOrUpdate<ScheduledTaskService>("每分钟执行任务", t => t.RunPerMinuteTask(), Cron.Minutely);

方案2：静态队列（快速验证用） #

如果仅需要快速验证功能，可以直接将队列定义为静态变量，静态变量属于类级别，所有实例共享：

public class ScheduledTaskService
{
    // 静态队列全局唯一，不会随实例创建重置
    private static readonly Queue<string> _sharedQueue = new Queue<string>();

    public void RunPerMinuteTask()
    {
        // 直接操作_sharedQueue即可
    }
}

注意：静态变量会在应用重启、进程回收时清空，多实例部署时每个实例有独立的静态队列，无法跨实例共享，不适合生产环境核心业务使用。

方案3：持久化队列存储 #

如果你需要队列数据不随应用重启丢失、或多实例部署时全局共享，可以将队列存储到Redis、数据库等持久化介质中，每次任务执行时直接读写介质中的队列数据即可。

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