.NET如何使用Entity Framework Core进行读写分离_石家庄创泽智能科技有限公司

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

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

2025-11-07

浏览次数：次

返回列表

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

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

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

配置多个数据库连接

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

{
  "ConnectionStrings": {
    "MasterDb": "Server=master;Database=AppDb;...",
    "Sl*eDb": "Server=sl*e;Database=AppDb;..."
  }
}

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

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

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

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

public class DbContextFactory
{
    private readonly string _masterConnectionString;
    private readonly string _sl*eConnectionString;

    public DbContextFactory(IConfiguration configuration)
    {
        _masterConnectionString = configuration.GetConnectionString("MasterDb");
        _sl*eConnectionString = configuration.GetConnectionString("Sl*eDb");
    }

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

    public AppDbContext CreateForRead()
    {
        return new AppDbContext(_sl*eConnectionString);
    }
}

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

刺鸟创客

一款专业高效稳定的AI内容创作平台

110 查看详情刺鸟创客

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.S*eChangesAsync();
    }
}