在控制器中为多线程创建EF Core DBContext？

问题描述：

在我的控制器之一，我有了做几分贝同时调用异步方法，所以我把它像这样：在控制器中为多线程创建EF Core DBContext？

public xxxController(IConfiguration configuration, xxxContext xxxContext, xxx2Context xxx2Context) 
    : base(xxxContext)

我店被注射的上下文。在具体方法：

var v = await Task.WhenAll(...)

里面WhenAll的，我需要使用xxxContext每个项目，所以我得到了非线程安全的异常。

什么是创建新的DbContext的正确方法？现在我做：

var v = new DbContextOptionsBuilder<xxxContext>(); 
v.UseSqlServer(_xxxContext.Database.GetDbConnection().ConnectionString);  
xxContext e = new xxContext(v.Options);

所以我越来越从注射并用它来创建一个新的存在的上下文的连接字符串。

连接字符串存储在appSettings.json中。在“ConnectionStrings”部分。

是否有更简洁的方式来创建多线程的上下文？

答

为此，我创建了类似工厂类的东西，可以为每次调用提供上下文。对于你的情况可能是

public class AppDependencyResolver 
{ 
    private static AppDependencyResolver _resolver; 

    public static AppDependencyResolver Current 
    { 
     get 
     { 
      if (_resolver == null) 
       throw new Exception("AppDependencyResolver not initialized. You should initialize it in Startup class"); 
      return _resolver; 
     } 
    } 

    public static void Init(IServiceProvider services) 
    { 
     _resolver = new AppDependencyResolver(services); 
    } 

    private readonly IServiceProvider _serviceProvider; 

    private AppDependencyResolver(IServiceProvider serviceProvider) 
    { 
     _serviceProvider = serviceProvider; 
    } 

    public xxxContext CreatexxxContextinCurrentThread() 
    { 
     var scopeResolver = _serviceProvider.GetRequiredService<IServiceScopeFactory>().CreateScope(); 
     return scopeResolver.ServiceProvider.GetRequiredService<xxxContext>(); 
    } 
}

应该比你调用Init方法启动

public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory) 
{ 
    AppDependencyResolver.Init(app.ApplicationServices); 
    //other configure code 
}

你可以看看我的这种做法对github

答

我怕你在执行本您的异步方法way

var task = Task.Run(() => MyAsynchronosMethod());

DbContext操作是输入 - 输出操作，您不需要在不同线程上执行它们以“同时”工作。你可以在没有新线程的情况下工作。

public MyController(IConfiguration configuration, AContext aContext, BContext bContext) 
    : base(aContext) 
{ 
    _aContext = aContext; 
    _bContext = bContext; 
} 

public Task<IActionResult> GetSomething(int id) 
{ 
    var customerTask = aContext.Customers 
            .FirstOrDefaultAsync(customer => customer.Id == id); 
    var sellerTask = aContext.Sellers 
            .FirstOrDefaultAsync(seller => seller.CustomerId == id); 
    var ordersTask = bContext.Orders 
            .Where(order => order.CustomerId == id) 
            .ToListAsync(); 
    var invoicesTask = bContext.Invoices 
            .Where(invoice => invoice.CustomerId == id) 
            .ToListAsync(); 
    var allTasks = new[] { customerTask, sellerTask, ordersTask, invoicesTask}; 
    await Task.WhenAll(allTasks); 

    // Do stuff with result of completed tasks 

    Return OK(calculatedResult); 
}

在上面的方法中，您将几乎同时发送所有查询而不必等待响应。只有在发送所有查询后，您才开始等待回复。
在所有查询结果到达后，您可以处理数据 - 所有操作都将在一个线程上执行。

在控制器中为多线程创建EF Core DBContext？

相关推荐