如何在同一.NET Core WebApp中注册并区分两个独立Hangfire实例？

要解决WebApp同时使用自身和Mailer的Hangfire实例、将任务提交到对应数据库的问题，核心是注册两个独立的Hangfire客户端实例并通过DI区分注入，具体步骤如下：

1. 配置独立连接字符串 #

在appsettings.json中添加两个Hangfire专属连接字符串，分别对应WebApp和Mailer的数据库：

"ConnectionStrings": {
  "Hangfire_WebApp": "Server=你的服务器;Database=Hangfire_WebApp;Trusted_Connection=True;TrustServerCertificate=True;",
  "Hangfire_Mailer": "Server=你的服务器;Database=Hangfire_Mailer;Trusted_Connection=True;TrustServerCertificate=True;"
}

2. 注册多实例Hangfire客户端 #

在Program.cs中，分别注册WebApp和Mailer的JobStorage与IBackgroundJobClient，推荐用自定义标记接口区分，避免DI混淆：

第一步：定义标记接口 #

创建两个继承自IBackgroundJobClient的空接口，用于标记不同实例：

public interface IWebAppBackgroundJobClient : IBackgroundJobClient { }
public interface IMailerBackgroundJobClient : IBackgroundJobClient { }

第二步：注册WebApp的Hangfire实例 #

// 注册WebApp专属的JobStorage
var webAppJobStorage = JobStorage.UseSqlServerStorage(builder.Configuration.GetConnectionString("Hangfire_WebApp"));
builder.Services.AddSingleton(webAppJobStorage);

// 注册WebApp专属的BackgroundJobClient，绑定到自定义接口
builder.Services.AddSingleton<IWebAppBackgroundJobClient>(sp => 
    new BackgroundJobClient(sp.GetRequiredService<JobStorage>())
);

// 注册WebApp的Hangfire服务器（仅处理自身队列任务）
builder.Services.AddHangfireServer(options =>
{
    options.Queues = new[] { "webapp-jobs" };
});
// 注册WebApp的仪表盘
builder.Services.AddHangfireDashboard();

第三步：注册Mailer的Hangfire客户端 #

// 注册Mailer专属的JobStorage
var mailerJobStorage = JobStorage.UseSqlServerStorage(builder.Configuration.GetConnectionString("Hangfire_Mailer"));
builder.Services.AddSingleton(mailerJobStorage);

// 注册Mailer专属的BackgroundJobClient，绑定到自定义接口
builder.Services.AddSingleton<IMailerBackgroundJobClient>(sp => 
    new BackgroundJobClient(mailerJobStorage)
);

注：Mailer的Hangfire服务器无需在WebApp中注册，保持在Mailer微服务自身配置即可，确保其监听mailer-jobs队列。

3. 注入对应客户端提交任务 #

在需要提交任务的类中，注入对应的自定义接口，确保任务提交到目标数据库：

提交WebApp自身任务 #

public class DataProcessingService
{
    private readonly IWebAppBackgroundJobClient _webAppJobClient;

    public DataProcessingService(IWebAppBackgroundJobClient webAppJobClient)
    {
        _webAppJobClient = webAppJobClient;
    }

    public void EnqueueDataTask()
    {
        // 任务将存入WebApp的Hangfire数据库
        _webAppJobClient.Enqueue<DataProcessingJob>(job => job.ProcessBatchData());
    }
}

提交Mailer的邮件任务 #

public class EmailTriggerService
{
    private readonly IMailerBackgroundJobClient _mailerJobClient;

    public EmailTriggerService(IMailerBackgroundJobClient mailerJobClient)
    {
        _mailerJobClient = mailerJobClient;
    }

    public void EnqueueEmail(string to, string subject, string content)
    {
        // 任务将存入Mailer的Hangfire数据库，由Mailer的Hangfire服务器执行
        _mailerJobClient.Enqueue<MailerEmailJob>(job => job.Send(to, subject, content));
    }
}

4. 关键注意事项 #

• 任务类可访问性：Mailer的任务类（如MailerEmailJob）需放在WebApp和Mailer都能引用的共享类库中，确保Mailer的Hangfire服务器能识别任务类型。
• 队列隔离：WebApp和Mailer的Hangfire服务器分别监听专属队列（如webapp-jobs、mailer-jobs），即使出现误提交，也不会跨实例执行任务。

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