.NET Core 6 Hangfire多数据库场景下配置不同队列名称求助

你的问题核心是未给每个AddHangfireServer调用指定对应队列配置，且重复调用AddHangfire会导致配置覆盖。以下是修正后的实现方案：

修正后的完整代码 #

var hangfireUserStorageOptions = new SqlServerStorageOptions
{
    CommandBatchMaxTimeout = TimeSpan.FromMinutes(5),
    SlidingInvisibilityTimeout = TimeSpan.FromMinutes(5),
    QueuePollInterval = TimeSpan.Zero,
    UseRecommendedIsolationLevel = true,
    DisableGlobalLocks = true,
    SchemaName = "HangFireUser"
};

var hangfireSystemStorageOptions = new SqlServerStorageOptions
{
    CommandBatchMaxTimeout = TimeSpan.FromMinutes(5),
    SlidingInvisibilityTimeout = TimeSpan.FromMinutes(5),
    QueuePollInterval = TimeSpan.Zero,
    UseRecommendedIsolationLevel = true,
    DisableGlobalLocks = true,
    SchemaName = "HangFireSystem"
};

// 初始化两个独立的存储实例
var hangfireUserStorage = new SqlServerStorage(
    _configuration.GetSection("HangfireSettings:HangfireConnection").Value, 
    hangfireUserStorageOptions);
var hangfireSystemStorage = new SqlServerStorage(
    _configuration.GetSection("HangfireSettings:HangfireConnection").Value, 
    hangfireSystemStorageOptions);

// 全局共享配置只需设置一次
builder.Services.AddHangfire(configuration => configuration
    .SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
    .UseSimpleAssemblyNameTypeSerializer()
    .UseRecommendedSerializerSettings());

// 绑定系统存储与Q1队列
builder.Services.AddHangfireServer(options =>
{
    options.Queues = new[] { "Q1" };
    options.ServerName = "System-Server"; // 仪表板区分服务器用
}, storage: hangfireSystemStorage);

// 绑定用户存储与Q2队列
builder.Services.AddHangfireServer(options =>
{
    options.Queues = new[] { "Q2" };
    options.ServerName = "User-Server"; // 仪表板区分服务器用
}, storage: hangfireUserStorage);

关键说明 #

• 队列指定：通过ServerOptions.Queues属性设置当前服务器监听的队列，数组格式支持同时监听多个队列，这里分别绑定Q1和Q2。
• 存储绑定：每个AddHangfireServer调用通过第二个参数传入对应存储实例，确保服务器与指定数据库Schema关联。
• 服务器命名：设置ServerName可在Hangfire仪表板中直观区分两个服务器，避免混淆。
• 全局配置复用：无需重复调用AddHangfire，一次配置即可共享序列化、兼容性等全局设置。

验证方法 #

启动项目后访问Hangfire仪表板：

• 在Servers标签下可见System-Server和User-Server两个独立服务器；
• 在Queues标签下会显示Q1和Q2队列，提交任务时指定对应队列即可被匹配的服务器处理。

内容的提问来源于stack exchange，提问作者Osman Yalınkaya