C#多绑定服务实例如何各占独立作用域？DbContext注册疑问

代码场景 #

服务定义与注册：

abstract class BaseProductService(MyDbContext db) { /* Work with the DbContext */ }
class ComputerProductService : BaseProductService {}
class CarProductService : BaseProductService {}

// 服务绑定
services
    .AddScoped<BaseProductService, MonitorProductService>()
    .AddScoped<BaseProductService, HardDriveProductService>()
    .AddHostedService<ProductWorker>();

后台任务ProductWorker的执行逻辑：

using var scope = services.CreateScope();
var products = scope.ServiceProvider.GetServices<BaseProductService>();

// 并行调用每个product.InitAsync()

问题：当MyDbContext注册为Scoped时，所有BaseProductService实例会共享同一个DbContext实例，无法安全并行操作。

疑问解答 #

1. 是否可以获取每个实例都处于独立作用域的IEnumerable<BaseProductService>？ #

可以实现，但不能一次性从单个作用域中获取所有实例。正确的做法是：先获取所有注册的BaseProductService实现类型，再为每个类型单独创建独立作用域，从对应作用域中解析实例。这样每个实例都会拥有自己的Scoped DbContext。

示例代码：

// 获取所有注册的BaseProductService实现类型
var serviceDescriptors = services.Where(sd => sd.ServiceType == typeof(BaseProductService));

// 并行处理每个服务类型
await Parallel.ForEachAsync(serviceDescriptors, async (descriptor, ct) =>
{
    using var scope = services.CreateScope();
    var service = (BaseProductService)scope.ServiceProvider.GetRequiredService(descriptor.ServiceType);
    await service.InitAsync(ct);
});

2. 直接将MyDbContext注册为Transient是否更简便，有哪些需要注意的弊端？ #

确实简便，但弊端较多，不推荐：

• 性能开销：每次注入都会创建新的DbContext实例，频繁创建销毁会增加额外性能消耗，尤其在高并发场景下。
• 事务一致性丢失：同一个业务流程中多次使用DbContext时，Transient实例无法共享事务，容易出现数据不一致的情况。
• 缓存失效：DbContext的一级缓存（内存缓存）无法复用，相同查询会重复访问数据库，降低查询效率。
• 连接池压力：过多的DbContext实例可能导致数据库连接池被快速耗尽，引发连接等待或超时问题。

自定义思路分析 #

你提出的「不在构造函数注入DbContext，而是在InitAsync/RunAsync方法调用时传入」的思路是可行的，也是推荐的方案之一。

调整后的实现示例：

1. 修改服务定义，移除构造函数的DbContext注入：

abstract class BaseProductService 
{ 
    public abstract Task InitAsync(MyDbContext db, CancellationToken ct);
    // 其他方法...
}

2. 在ProductWorker中为每个服务创建独立作用域，解析DbContext并传入：

var serviceDescriptors = services.Where(sd => sd.ServiceType == typeof(BaseProductService));

await Parallel.ForEachAsync(serviceDescriptors, async (descriptor, ct) =>
{
    using var scope = services.CreateScope();
    var service = (BaseProductService)scope.ServiceProvider.GetRequiredService(descriptor.ServiceType);
    var dbContext = scope.ServiceProvider.GetRequiredService<MyDbContext>();
    await service.InitAsync(dbContext, ct);
});

这种方式既保证了每个服务拥有独立的DbContext，又遵循了依赖注入的设计原则，同时避免了Transient DbContext带来的各种问题。

内容的提问来源于stack exchange，提问作者Luke Vo