【发布时间】:2020-07-20 12:30:39
【问题描述】:
我正在使用 HangFire 和 EntityFramework 进行重复性工作
public void Start(IContainer container)
{
GlobalConfiguration.Configuration
.UseColouredConsoleLogProvider(LogLevel.Debug)
.SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
.UseSimpleAssemblyNameTypeSerializer()
.UseActivator(new MyActivator(container))
.UseRecommendedSerializerSettings();
RecurringJob.AddOrUpdate<EveryMinute>((x) => x.ExecuteAsync(), Cron.Minutely);
}
激活器:
public class MyActivator : JobActivator
{
private readonly IContainer _container;
public MyActivator (IContainer container)
{
_container = container;
}
public override object ActivateJob(Type type)
{
return _container.Resolve(type);
}
}
然后我有 ctor 初始化 Datacontext 和 RepositoryA
public EveryMinute(DataContext dataContext,RepositoryA repositoryA)
{
_dataContext = dataContext;
_repositoryA = repositoryA;
}
但是,当我像下面这样每分钟从数据库中检索数据时,我收到了错误的数据(项目在 Hangfire 作业之外由其他应用程序更新)。
public async Task ExecuteAsync()
{
var dbItem = _dataContext.Items.Single(x => x.Id == 1);
//dbItem.StateProperty property is old
}
从创建作业(应用程序启动)开始,项目或 DataContext 似乎已被“缓存”。因为当我使用
public EveryMinute()
{
_dataContext = new DataContext();
_repositoryA = new RepositoryA(_dataContext);
}
效果很好。
我是不是用错了激活器?或者如何指定每次调用依赖注入需要新实例DataContext?
【问题讨论】:
标签: c# .net entity-framework hangfire hangfire-autofac