ASP.NET Core基于SQL Server的多租户数据库连接高效处理方案咨询

针对你基于ASP.NET Core+SQL Server的模块化单体MVP需求，下面直接分析三种方案的优劣，并给出兼顾简洁性与扩展性的推荐方案及具体实现思路：

方案1：每个租户独立数据库 #

• 优势：数据物理隔离彻底，完全满足校园系统的隐私合规要求；租户数据备份/恢复、性能优化（如单独索引）可独立操作；租户退出时直接删除数据库即可，逻辑简单。
• 劣势：MVP阶段运维成本较高，需管理多个数据库实例；初始化租户时需自动执行建库/建表逻辑；多连接字符串可能会对数据库连接池造成一定压力。

方案2：带TenantId的共享数据库 #

• 优势：架构最简洁，MVP开发速度最快；无需管理多数据库，所有租户数据存储在同一套表中，仅需在实体类添加TenantId字段实现逻辑隔离。
• 劣势：数据隔离依赖业务逻辑，容易出现遗漏TenantId过滤的漏洞；租户数据量增长后单库性能瓶颈明显；无法单独备份/恢复单个租户数据；后期向独立库模式迁移的重构成本极高。

方案3：每个请求使用动态连接字符串 #

这本质是方案1的自动化实现方式——根据当前请求的租户标识动态切换数据库连接字符串，核心还是租户独立库模式。

• 优势：兼顾方案1的隔离安全性，同时通过自动化逻辑降低运维复杂度；后期租户量级增长时，无需重构核心业务逻辑，可直接扩展数据库部署策略（如SQL Server弹性池）。
• 劣势：需要实现租户信息传递、连接字符串缓存、DbContext动态配置等逻辑，初期开发复杂度略高于方案2，但远低于手动管理多库。

推荐方案：基于动态连接字符串的租户独立数据库模式 #

完全适配你的模块化单体MVP需求：既保证架构简洁，又预留足够的扩展性，同时满足校园系统的数据隔离合规要求。

.NET具体实现步骤 #

1. 租户信息识别与传递

通过中间件从请求中提取租户标识（如学校代码、域名、路由参数），存入HttpContext或自定义上下文服务，供后续逻辑使用：

public class TenantMiddleware
{
    private readonly RequestDelegate _next;

    public TenantMiddleware(RequestDelegate next) => _next = next;

    public async Task InvokeAsync(HttpContext context)
    {
        // 示例：从路由参数获取租户ID，如/schools/{tenantId}/students
        if (context.Request.RouteValues.TryGetValue("tenantId", out var tenantIdObj) && 
            tenantIdObj is string tenantId)
        {
            // 存入HttpContext.Items
            context.Items["TenantId"] = tenantId;
            // 或注入自定义ITenantContext服务
            var tenantContext = context.RequestServices.GetRequiredService<ITenantContext>();
            tenantContext.TenantId = tenantId;
        }
        await _next(context);
    }
}

// 注册中间件
app.UseMiddleware<TenantMiddleware>();

// 自定义租户上下文服务
public interface ITenantContext
{
    string TenantId { get; set; }
}

public class TenantContext : ITenantContext
{
    public string TenantId { get; set; }
}

2. 动态连接字符串管理

实现连接字符串解析服务，从共享系统库（或配置缓存）中获取对应租户的连接字符串，并加入缓存避免重复查询：

public interface ITenantConnectionStringResolver
{
    Task<string> GetConnectionStringAsync(string tenantId);
}

public class TenantConnectionStringResolver : ITenantConnectionStringResolver
{
    private readonly IConfiguration _configuration;
    private readonly IDistributedCache _cache;

    public TenantConnectionStringResolver(IConfiguration configuration, IDistributedCache cache)
    {
        _configuration = configuration;
        _cache = cache;
    }

    public async Task<string> GetConnectionStringAsync(string tenantId)
    {
        var cacheKey = $"TenantConn_{tenantId}";
        var connStr = await _cache.GetStringAsync(cacheKey);
        
        if (!string.IsNullOrEmpty(connStr)) return connStr;

        // 从共享系统库的Tenants表查询租户连接字符串
        var systemConnStr = _configuration.GetConnectionString("SystemDb");
        using var conn = new SqlConnection(systemConnStr);
        await conn.OpenAsync();
        
        var cmd = new SqlCommand("SELECT ConnectionString FROM Tenants WHERE TenantId = @TenantId", conn);
        cmd.Parameters.AddWithValue("@TenantId", tenantId);
        connStr = await cmd.ExecuteScalarAsync() as string;

        // 缓存1小时
        if (!string.IsNullOrEmpty(connStr))
        {
            await _cache.SetStringAsync(cacheKey, connStr, new DistributedCacheEntryOptions
            {
                AbsoluteExpirationRelativeToNow = TimeSpan.FromHours(1)
            });
        }
        return connStr;
    }
}

3. 动态配置DbContext

在DbContext中注入租户上下文和连接字符串解析服务，动态设置数据库连接：

public class SchoolDbContext : DbContext
{
    private readonly ITenantConnectionStringResolver _connResolver;
    private readonly ITenantContext _tenantContext;

    public SchoolDbContext(ITenantConnectionStringResolver connResolver, ITenantContext tenantContext)
    {
        _connResolver = connResolver;
        _tenantContext = tenantContext;
    }

    protected override async void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        var connStr = await _connResolver.GetConnectionStringAsync(_tenantContext.TenantId);
        optionsBuilder.UseSqlServer(connStr);
    }

    // 实体定义
    public DbSet<Student> Students { get; set; }
    public DbSet<Class> Classes { get; set; }
}

4. 租户数据库初始化

提供后台接口实现租户注册时的自动建库逻辑，可复用EF Core迁移或预定义SQL脚本：

public async Task CreateTenantDatabaseAsync(string tenantId, string tenantName)
{
    // 基于模板生成租户库连接字符串
    var templateConnStr = _configuration.GetConnectionString("TenantDbTemplate");
    var tenantConnStr = templateConnStr.Replace("{TenantId}", tenantId);
    
    // 创建数据库
    using var masterConn = new SqlConnection(templateConnStr.Replace("{TenantId}", "master"));
    await masterConn.OpenAsync();
    var createDbCmd = new SqlCommand($"CREATE DATABASE School_{tenantId}", masterConn);
    await createDbCmd.ExecuteNonQueryAsync();
    
    // 执行EF Core迁移初始化表结构
    var dbOptions = new DbContextOptionsBuilder<SchoolDbContext>()
        .UseSqlServer(tenantConnStr)
        .Options;
    using var dbContext = new SchoolDbContext(dbOptions);
    await dbContext.Database.MigrateAsync();
    
    // 将租户信息存入共享系统库
    await SaveTenantToSystemDbAsync(tenantId, tenantName, tenantConnStr);
}

注意事项 #

• 连接池优化：SQL Server按连接字符串缓存连接池，租户过多时可调整连接池大小，或使用SQL Server弹性池降低部署成本。
• 异常处理：需捕获租户不存在、连接字符串无效等异常，返回友好提示。
• 模块化拆分：将租户识别、连接字符串解析等逻辑封装为独立模块，与业务模块解耦，符合模块化单体设计。

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