.NET如何使用Entity Framework Core进行读写分离-C#.Net教程-PHP中文网

.NET如何使用Entity Framework Core进行读写分离

畫卷琴夢

发布： 2025-11-07 09:35:32

原创

532人浏览过

通过配置主从数据库连接并动态选择，实现EF Core读写分离。在appsettings.json中定义MasterDb和SlaveDb连接字符串，通过DbContextFactory根据操作类型创建对应上下文，读操作使用从库，写操作使用主库，结合中间件可按请求类型自动路由，提升性能与可用性，需注意数据同步延迟问题。

.net如何使用entity framework core进行读写分离

在 .NET 应用中使用 Entity Framework Core 实现读写分离，主要是通过区分主库（写操作）和从库（读操作）的数据库连接，来提升系统性能与可用性。这种模式适用于读多写少的场景，能有效减轻主数据库的压力。

配置多个数据库连接

读写分离的前提是拥有至少两个数据库实例：一个用于写入（主库），一个或多个用于读取（从库）。你需要在 appsettings.json 中配置多个连接字符串：

{
  "ConnectionStrings": {
    "MasterDb": "Server=master;Database=AppDb;...",
    "SlaveDb": "Server=slave;Database=AppDb;..."
  }
}

登录后复制

然后在 Program.cs 或 Startup.cs 中注册 DbContext 时暂不直接注入连接，而是通过策略或运行时判断选择连接。

动态切换数据库上下文连接

EF Core 默认不支持自动读写分离，但可以通过自定义逻辑控制使用哪个连接。常见做法是在创建 DbContext 实例时传入不同的连接字符串。

例如，定义一个基于操作类型选择连接的服务：

public class DbContextFactory
{
    private readonly string _masterConnectionString;
    private readonly string _slaveConnectionString;

    public DbContextFactory(IConfiguration configuration)
    {
        _masterConnectionString = configuration.GetConnectionString("MasterDb");
        _slaveConnectionString = configuration.GetConnectionString("SlaveDb");
    }

    public AppDbContext CreateForWrite()
    {
        return new AppDbContext(_masterConnectionString);
    }

    public AppDbContext CreateForRead()
    {
        return new AppDbContext(_slaveConnectionString);
    }
}

登录后复制

你的 DbContext 构造函数接收连接字符串：

知网AI智能写作

知网AI智能写作，写文档、写报告如此简单

查看详情

public class AppDbContext : DbContext
{
    private readonly string _connectionString;

    public AppDbContext(string connectionString)
    {
        _connectionString = connectionString;
    }

    protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
    {
        optionsBuilder.UseSqlServer(_connectionString);
    }
}

登录后复制

在服务中使用读写分离

在实际业务逻辑中，根据操作类型调用不同的实例：

public class ProductService
{
    private readonly DbContextFactory _dbContextFactory;

    public ProductService(DbContextFactory dbContextFactory)
    {
        _dbContextFactory = dbContextFactory;
    }

    public async Task<Product> GetProduct(int id)
    {
        using var context = _dbContextFactory.CreateForRead();
        return await context.Products.FindAsync(id);
    }

    public async Task AddProduct(Product product)
    {
        using var context = _dbContextFactory.CreateForWrite();
        context.Products.Add(product);
        await context.SaveChangesAsync();
    }
}

登录后复制

这样就实现了读操作走从库、写操作走主库的基本分离逻辑。