1

我想每小时更新一次数据库中的数据。所以，我为此找到了很好的FluentScheduler库并创建了我的IJob：

public class InfoLoader : IJob
{
    private readonly DataContext _db;

    public InfoLoader(DataContext db)
    {
        _db = db;
    }

    public void Execute()
    {
        foreach (User user in _db.Users.ToList())
        {
            foreach (Info i in user.Info.ToList())
            {
                UpdateInfo(i);
            }
        }
    }

    private void UpdateInfo(Info info)
    {
        // do some operations to update information in db
    }
}

当然，我创建了我的Registry实现来安排我需要的所有任务：

public class LoadersRegistry : Registry
{
    public LoadersRegistry()
    {
        Schedule<InfoLoader>().ToRunNow().AndEvery(1).Hours();
    }
}

我还在我的 Program.cs 文件中添加了以下代码来初始化调度程序并启动它：

JobManager.JobException += (obj) => { logger.LogError(obj.Exception.Message); };
JobManager.Initialize(new LoadersRegistry());

但是当我运行我的应用程序时，我看到以下错误：

运行应用

我知道LoadersRegistry无法创建InfoLoader（在JobManger初始化期间Program.cs）的实例，因为InfoLoader接收DataContext. 但我不能不接收DataContext，因为我需要它在我的数据库中添加数据。

不幸的是，我找不到解决此问题的方法。

谢谢你的帮助。

PS 我读到过在 asp.net core 中使用 FluentScheduler，但是这个库的开发者说这个功能将来不会因为这个而可用，所以我仍然不知道如何解决这个问题。

4

2 回答 2

2

根据 API 文档，您必须更改注册方式。以下只是一种方法。

public LoadersRegistry()
    {
        var dataContext = new DataContext();
        Schedule(()=> new InfoLoader(dataContext)).ToRunNow().AndEvery(1).Hours();
    }

在这里，我正在做 new DataContext() 但只要您使用它更新 InfoLoader，您就可以随意使用 dataContext。

于 2018-02-18T07:27:32.487 回答
1

如果有人会遇到类似的问题，这是可以帮助我的解决方案：

您只需要在Startup.cs文件中进行初始化：

public void ConfigureServices(IServiceCollection services)
    var provider = services.BuildServiceProvider();

    JobManager.Initialize(new LoadersRegistry(
        provider.GetRequiredService<DataContext>()
    ));

    services.AddMvc();
}

当然，LoadersRegistry应该接收DataContext实例，并且InfoLoader应该在构造函数中接收这个实例：

public LoadersRegistry(DataContext db)
{
    Schedule(new InfoLoader(db)).ToRunNow().AndEvery(30).Seconds();
}

祝你好运！:)

于 2018-02-18T15:39:06.257 回答