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

来源：这里教程网时间：2026-02-21 17:29:47 作者：

在高并发场景下，数据库的读写分离是提升系统性能的重要手段。.NET 中使用 Entity Framework Core 实现读写分离，可以通过配置多个数据库连接来分别处理查询（读）和命令（写）操作，从而减轻主库压力，提高响应速度。

理解读写分离的基本原理

读写分离的核心思想是：所有写操作（INSERT、UPDATE、DELETE）走主数据库（Master），而读操作（SELECT）则路由到一个或多个从数据库（Slave）。主库负责数据变更，并将变更同步到从库，从库仅用于查询。

EF Core 本身不直接提供读写分离功能，但可以通过以下方式手动实现：

为读和写分别创建不同的 DbContext 实例 在运行时根据操作类型选择对应的上下文 确保从库的数据延迟在业务可接受范围内

配置主从数据库连接字符串

在 appsettings.json 中定义两个连接字符串：

{
  "ConnectionStrings": {
    "MasterDb": "Server=localhost;Database=MyAppDb;User=sa;Password=...;",
    "SlaveDb": "Server=replica-host;Database=MyAppDb;User=sa;Password=...;"
  }
}

主库用于写入，从库用于读取。实际部署中，从库通常是主库的只读副本，通过数据库复制机制保持数据一致。

创建读写专用的 DbContext

可以使用同一个 DbContext 类型，但在不同实例中传入不同的连接字符串：

public class AppDbContext : DbContext
{
    public AppDbContext(DbContextOptions options) : base(options) { }
    public DbSet<User> Users { get; set; }
    // 其他 DbSet...
}

在 Program.cs 或 Startup.cs 中注册两个服务：

builder.Services.AddScoped<IWriteDbContext, AppDbContext>(sp =>
    new AppDbContext(new DbContextOptionsBuilder<AppDbContext>()
        .UseSqlServer(builder.Configuration.GetConnectionString("MasterDb"))
        .Options));
builder.Services.AddScoped<IReadDbContext, AppDbContext>(sp =>
    new AppDbContext(new DbContextOptionsBuilder<AppDbContext>()
        .UseSqlServer(builder.Configuration.GetConnectionString("SlaveDb"))
        .Options));

或者更简单的方式是通过命名区分：

builder.Services.AddDbContext<AppDbContext>(options => 
    options.UseSqlServer(builder.Configuration.GetConnectionString("MasterDb")));
builder.Services.AddDbContext<ReadOnlyAppDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("SlaveDb")));

在服务中动态选择读写上下文

在实际业务逻辑中，根据操作类型选择对应的 DbContext：

public class UserService
{
    private readonly AppDbContext _writeContext;
    private readonly ReadOnlyAppDbContext _readContext;
    public UserService(AppDbContext writeContext, ReadOnlyAppDbContext readContext)
    {
        _writeContext = writeContext;
        _readContext = readContext;
    }
    public async Task<User> GetUserById(int id)
    {
        // 读操作走从库
        return await _readContext.Users.FindAsync(id);
    }
    public async Task AddUser(User user)
    {
        // 写操作走主库
        await _writeContext.Users.AddAsync(user);
        await _writeContext.SaveChangesAsync();
    }
}

这种方式清晰分离了职责，便于维护和调试。