本文环境为.Net5 + ASP.Net Core Web API + EFCore 5.0.12 + MySQL 5,介绍了如何使用EFCore开启数据库连接池。
在实现了自己的DbContext之后,需要在Startup.cs的ConfigureServices方法中注册DbContext。在ASP.Net Core Web API中,每次请求对应的Controller都会创建一次DbContext对象,而普通的注册会在每次创建DbContext对象时连接一次数据库,这样会频繁的连接数据库(然后关闭),很有可能会使数据库的连接资源耗尽。因此,需要使用连接池以便减少数据库的连接次数,使系统更加稳健。
EFCore提供了2种开启数据库连接池的方法,一种是使用IServiceCollection接口的扩展方法AddDbContextPool,该扩展方法注册了DbContext类,可以在Controller中注入DbContext对象;另一种方法是使用IServiceCollection接口的扩展方法AddPooledDbContextFactory,该扩展方法注册了IDbContextFactory接口,可以在Controller中注入IDbContextFactory类型的对象。
2种开启数据库连接池方法的区别是:前者(AddDbContextPool)直接注入DbContext对象,因此在请求建立连接时就进行数据库连接,尽管是使用池种的数据库连接;后者(AddPooledDbContextFactory)对IDbContextFactory进行了单例注册,在需要数据库连接的时候使用CreateDbContext方法建立数据库连接,可视为能够仅在需要请求数据库的时候动态建立数据库连接,灵活性比较大。
针对上述2种方法,AddDbContextPool方法适合在每个请求都需要连接数据库的Controller中使用,AddPooledDbContextFactory方法则没有使用限制,唯一需要注意的是处理好2个关联的需要使用DbContext对象的方法,防止频繁创建DbContext。鉴于此,更推荐使用AddPooledDbContextFactory方法启用数据库连接池。
需要注意的是,在启用数据库连接池的时候,自己实现的DbContext派生类中,构造函数不能有除了DbContextOptions以外的参数,这是因为连接池时DbContext对象会被连接池保存,这意味着DbContext对象是单例的,所以不能有其他注入的服务。参考stackoverflow。
此外,数据库连接字符串默认参数是pooling=true,如果改为pooling=false也会对启用数据库连接池造成影响。
1、默认不启用数据库连接池
//注册数据库上下文 services.AddDbContext<MySqlDbContext>();
2、使用AddDbContextPool启用数据库连接池
//注册数据库上下文(启用数据库连接池) var connectionString = Configuration.GetConnectionString("MySQLConnection"); services.AddDbContextPool<MySqlDbContext>(optionsBuilder => optionsBuilder.UseMySql(connectionString, ServerVersion.AutoDetect(connectionString)), 64 );
3、使用AddPooledDbContextFactory启用数据库连接池
//注册数据库上下文(启用数据库连接池) var connectionString = Configuration.GetConnectionString("MySQLConnection"); services.AddPooledDbContextFactory<MySqlDbContext>(optionsBuilder => optionsBuilder.UseMySql(connectionString, ServerVersion.AutoDetect(connectionString)), 64 );
[Route("api/[controller]")] [ApiController] public class ClientsController : ControllerBase { private readonly ILogger<ClientsController> _logger; private readonly IDbContextFactory<MySqlDbContext> _dbContextFactory; public ClientsController( ILogger<ClientsController> logger, IDbContextFactory<MySqlDbContext> dbContextFactory ) { _logger = logger; _dbContextFactory = dbContextFactory; } [HttpGet("count")] public async Task<IActionResult> GetCountAsync() { try { using (var dbContext = _dbContextFactory.CreateDbContext()) { var count = await dbContext.Clients.CountAsync(); return Ok(count); } } catch (Exception e) { var message = $@"GetCountAsync failed:{e.Message}."; _logger.LogError(message); return Problem(message); } } }