多租户分库环境下基于EF+SqlServer实现MassTransit Outbox的方案问询

我们的系统采用多租户架构，每个租户拥有独立物理数据库（对应不同连接字符串），且租户数量较多。此前参考过相关方案，但该方案要求为每个租户部署2个BackgroundService，在100个租户的场景下运维成本过高，并非最优解。

项目技术栈：EntityFramework Core 7 + SQL Server

现有DI与DbContext配置说明 #

1. TenantContext类：存储当前租户ID与连接字符串，已注册到DI容器

public class TenantContext
{
    public string CurrentTenantId { get; set; } = "no-tenant";
    public string? ConnectionStr { get; set; }
}

2. 租户专属Scope创建逻辑：通过ITenantServiceScopeFactory创建包含对应TenantContext的IServiceScope

internal class TenantServiceScopeFactory : ITenantServiceScopeFactory
{
    private readonly IServiceScopeFactory _serviceScopeFactory;

    public TenantServiceScopeFactory(IServiceScopeFactory serviceScopeFactory)
    {
        _serviceScopeFactory = serviceScopeFactory;
    }
    
    public IServiceScope CreateScope(string tenantId)
    {
        var scope = _serviceScopeFactory.CreateScope();
        var tenantContext = scope.ServiceProvider.GetRequiredService<TenantContext>();
        tenantContext.CurrentTenantId = tenantId;
    
        return scope;
    }
}

3. DbContext注册：通过工厂方法依赖TenantContext获取对应租户的连接字符串

builder.Services.AddDbContext<AppDbContext>((sp, optionsBuilder) =>
{
    var tenantContext = sp.GetRequiredService<TenantContext>();
    optionsBuilder.UseSqlServer(tenantContext.ConnectionStr);
});

注：必须创建包含对应TenantContext的IServiceScope，才能获取到该租户的DbContext实例

当前遇到的问题 #

直接使用MassTransit的Outbox配置：

configurator.AddEntityFrameworkOutbox<AppDbContext>(outboxConfigurator => { … });

会默认使用"no-tenant"的TenantContext，该实例无有效连接字符串，导致抛出异常。

需求与疑问 #

我们希望实现单个BackgroundService统一处理所有租户的Outbox消息投递，核心逻辑如下：

protected override async Task ExecuteAsync(CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested)
    {
        var tenants = new[]
        {
            "tenant1",
            "tenant2"
        };
        
        foreach (var tenant in tenants)
        {
            var tenantScope = _tenantServiceScopeFactory.CreateScope(tenant);
            // 基于tenantScope内解析的AppDbContext执行MassTransit Outbox消息投递
        }
        
        await Task.Delay(Interval, cancellationToken);
    }
}

请问当前MassTransit版本是否支持这种实现方式？

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