在 Scheduled Job 中执行 DB 调用

Question

我有一个在 ASP Core 2 下构建的项目，该项目利用 Quartz.NET 调度程序 3-beta1

我有以下想要执行的工作：

public class TestJob: IJob
{
    private readonly AppDbContext _dbContext;
    public TestJob(AppDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    public Task Execute(IJobExecutionContext context)
    {
        Debug.WriteLine("Test check at " + DateTime.Now);

        var testRun = _dbContext.TestTable.Where(o => o.CheckNumber > 10).ToList();

        Debug.WriteLine(testRun.Count);

        return Task.CompletedTask;
    }
}

不幸的是，它永远无法正常工作，并且没有错误日志表明存在问题。

然而，当我删除所有内容并离开 Debug.WriteLine 时，它的工作原理如下例所示。

public class TestJob: IJob
    {
        public Task Execute(IJobExecutionContext context)
        {
            Debug.WriteLine("Test check at " + DateTime.Now);

            return Task.CompletedTask;
        }
    }

我怎样才能让我的工作来执行数据库调用？

编辑 1：创造就业机会

var schedulerFactory = new StdSchedulerFactory(properties);
            _scheduler = schedulerFactory.GetScheduler().Result;
            _scheduler.Start().Wait();

var testJob = JobBuilder.Create<TestJob>()
    .WithIdentity("TestJobIdentity")
    .Build();
var testTrigger = TriggerBuilder.Create()
    .WithIdentity("TestJobTrigger")
    .StartNow()
    .WithSimpleSchedule(x => x.WithIntervalInMinutes(1).RepeatForever())
    .Build();


if (CheckIfJobRegistered(testJob.Key).Result == false)
    _scheduler.ScheduleJob(testJob, testTrigger).Wait();

Answer 1

这里的主要问题是 Quartz 无法创建作业并吞下异常。

Documentation 声明：

当触发器触发时，它关联的 JobDetail（实例定义）被加载，并且它引用的作业类通过调度器上配置的 JobFactory 实例化。默认 JobFactory 仅使用 Activator.CreateInstance 调用作业类的默认构造函数，然后尝试调用类上与 JobDataMap 中的键名匹配的 setter 属性。您可能希望创建自己的 JobFactory 实现来完成诸如让应用程序的 IoC 或 DI 容器生成/初始化作业实例等事情。

Quartz 提供了IJobFactory 来实现这一点。它与依赖注入一起工作得非常好。 JobFactory 可以如下所示：

public class JobFactory : IJobFactory
{
    //TypeFactory is just the DI Container of your choice
    protected readonly TypeFactory Factory;

    public JobFactory(TypeFactory factory)
    {
        Factory = factory;
    }

    public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler)
    {
        try
        {
            return Factory.Create(bundle.JobDetail.JobType) as IJob;
        }
        catch (Exception e)
        {
            //Log the error and return null
            //every exception thrown will be swallowed by Quartz 
            return null;
        }
    }

    public void ReturnJob(IJob job)
    {
        //Don't forget to implement this,
        //or the memory will not released
        Factory.Release(job);
    }
}

然后只需向调度程序注册您的 JobFactory，一切都会正常工作：

_scheduler.JobFactory = new JobFactory(/*container of choice*/);

编辑：

另外你可以看看我以前的answers。