c# - .NET Entity Framework Core、依赖注入和线程的 DBContext System.ObjectDisposed 异常
问题描述
我不确定我是否正确地处理了这个问题。
背景:我以控制器操作 GET foo() 为例。这个 foo() 需要去调用 bar(),而 bar() 可能需要很长时间。因此,我需要 foo() 在 bar() 完成之前(或无论何时)以“OK”响应。
稍微复杂的是 bar() 需要访问 DBContext 并从 DB 中获取一些数据。在我当前的实现中,当我尝试通过 bar 访问数据库时出现“DBContext System.ObjectDisposed”异常。任何想法为什么以及如何解决这个问题?我对线程和任务真的很陌生,所以我可能完全犯了这个错误!
我使用依赖注入在启动时提供数据库上下文
services.AddEntityFrameworkNpgsql()
.AddDbContext<MyDBContext>()
.BuildServiceProvider();
然后我调用 foo() ,后者又使用新线程调用 bar() (也许我做错了?):
public async Task<string> foo(string msg)
{
Thread x = new Thread(async () =>
{
await bar(msg);
});
x.IsBackground = true;
x.Start();
return "OK.";
}
所以 bar 立即尝试访问 DBContext 以获取一些实体并抛出异常!
未处理的异常:System.ObjectDisposedException:无法访问已处置的对象。此错误的一个常见原因是释放从依赖注入中解析的上下文,然后尝试在应用程序的其他地方使用相同的上下文实例。如果您在上下文上调用 Dispose() 或将上下文包装在 using 语句中,则可能会发生这种情况。如果你使用依赖注入,你应该让依赖注入容器负责处理上下文实例。对象名称:'MyDBContext'。
如果我将 bar() 从线程中取出,那很好,但当然,直到 bar 完成其非常长的过程才返回“OK”,这是我需要解决的问题。
非常感谢您的指导。
使用正在运行的代码进行编辑,但它仍在等待 Task.Run 完成,然后返回“OK”。(差不多好了?)
public async Task<string> SendBigFile(byte[] fileBytes)
{
ServerLogger.Info("SendBigFile called.");
var task = Task.Run(async () =>
{
using (var scope = _serviceScopeFactory.CreateScope())
{
var someProvider = scope.ServiceProvider.GetService<ISomeProvider>();
var fileProvider = scope.ServiceProvider.GetService<IFileProvider>();
await GoOffAndSend(someProvider, fileProvider, fileBytes);
}
});
ServerLogger.Info("Hello World, this should print and not wait for Task.Run."); //Unfortunately this is waiting even though GoOffAndSend takes at least 1 minute.
return "Ok"; //This is not returned until Task.Run finishes unfortunately... how do I "skip" to this immediately?
}
private async Task GoOffAndSend(ISomeProvider s, IFileProvider f, byte[] bytes)
{
// Some really long task that can take up to 1 minute that involves finding the file, doing weird stuff to it and then
using (var client = new HttpClient())
{
var response = await client.PostAsync("http://abcdef/somewhere", someContent);
}
}
解决方案
AddDbContext<>()
将 注册MyDBContext
为服务,ServiceLifetime.Scoped
这意味着您DbContext
是根据 Web 请求创建的。它在请求完成时被释放。
避免该异常的最简单方法是注入IServiceScopeFactory
您的控制器,然后使用创建一个新范围CreateScope()
并从该范围请求MyDBContext
服务(您无需担心DbContextOptions
)。工作完成后,处置随后处置的范围DbContext
。而不是Thread
更好地使用Task
. Task
API 更强大,通常具有更好的性能。它看起来像这样:
public class ValuesController : ControllerBase
{
IServiceScopeFactory _serviceScopeFactory
public ValuesController(IServiceScopeFactory serviceScopeFactory)
{
_serviceScopeFactory = serviceScopeFactory;
}
public async Task<string> foo(string msg)
{
var task = Task.Run(async () =>
{
using (var scope = _serviceScopeFactory.CreateScope())
{
var db = scope.ServiceProvider.GetService<MyDBContext>();
await bar(db, msg);
}
});
// you may wait or not when task completes
return "OK.";
}
}
此外,您应该知道这Asp.Net
不是后台任务的最佳位置(例如,当应用程序托管在 IIS 中时,由于应用程序池回收,它可能会被关闭)
更新
当完成时,您ServerLogger.Info("SendBigFile finished.");
不会等待client.PostAsync
。它在Task.Run
开始新任务后立即记录。要在完成后记录它,client.PostAsync
您需要在ServerLogger.Info("SendBigFile finished.");
之后放置await GoOffAndSend(someProvider, fileProvider, fileBytes);
:
...
await GoOffAndSend(someProvider, fileProvider, fileBytes);
ServerLogger.Info("SendBigFile finished.");
...
推荐阅读
- scala - 在 Scala 中覆盖具有不同类型的特征函数
- android - React Native 在构建时抛出访问被拒绝错误
- regex - 有没有办法在 RE2 中指定字符之前和之后进行匹配?
- excel - 在同一张 Excel 表中打开 Office JS 模板
- bash - 合并文本文件列表(太长),在其间添加换行符
- ios - 对成员 OCKCarePlanActivity '评估的模糊引用
- javascript - 多个 Mysql 查询附加 url
- unit-testing - 如何在测试中轻松设置自动增量 ID
- spring - 在某些语言环境中,Thymeleaf 不会在消息中呈现变量
- python - df ['X'].unique() 和 TypeError: unhashable type: 'numpy.ndarray'