ASP.Net Core集成Quartz.NET 3.4.0任务未执行问题求助

问题描述 #

在ASP.Net Core中使用Quartz.NET 3.4.0，自定义QuartzHostedService作为托管服务配置任务、触发器和调度器，StartAsync方法已执行，但关联的HelloWorldJob从未运行。

可能原因及解决步骤 #

1. 任务调度的条件判断未满足 #

代码中只有当_initializationModuleConfiguration.DataLoaderStarted为true且isEnabled为false时，才会执行ScheduleJob方法。如果DataLoaderStarted初始值为false，任务根本不会被调度到Quartz中。

验证与解决：

• 临时注释掉if判断，直接执行await _scheduler.ScheduleJob(_jobDetail, _trigger);，运行程序看任务是否执行。如果任务正常输出"Hello world!"，说明是DataLoaderStarted的状态问题，需要检查该配置项的初始化逻辑，确保它在StartAsync执行时为true。

2. 重复注册Quartz托管服务导致冲突 #

你同时使用了Quartz官方的AddQuartzHostedService和自定义的QuartzHostedService作为托管服务，这会创建两个独立的Quartz调度器实例：

• 官方的AddQuartzHostedService会自动创建并管理一个调度器
• 自定义的QuartzHostedService又创建了另一个调度器

这种情况下，可能自定义调度器的任务未被正确激活，或者两个调度器互相干扰。

解决：
选择一种方式管理Quartz调度器，不要同时混用：

• 方案一：使用官方配置方式（推荐）
  移除自定义的QuartzHostedService和相关注册，改用Quartz官方的依赖注入配置：

  public class Startup
  {
      // ...其他配置
      public void ConfigureServices(IServiceCollection services)
      {
          // 配置Quartz
          services.AddQuartz(q =>
          {
              // 使用微软DI容器创建Job实例
              q.UseMicrosoftDependencyInjectionJobFactory();
              
              // 注册Job
              q.AddJob<HelloWorldJob>(j => j.WithIdentity("_job", "group"));
              
              // 注册触发器
              q.AddTrigger(t => t
                  .ForJob("_job", "group")
                  .WithIdentity("_trigger", "group")
                  .StartNow()
                  .WithSimpleSchedule(s => s.WithIntervalInSeconds(5).RepeatForever()));
          });
          
          // 添加Quartz托管服务
          services.AddQuartzHostedService(quartz => quartz.WaitForJobsToComplete = true);
          
          // 注册Job（如果需要直接注入的话，否则上面的AddJob已经足够）
          services.AddSingleton<HelloWorldJob>();
      }
  }
  

• 方案二：保留自定义托管服务
  移除services.AddQuartzHostedService(...)，只保留自定义的QuartzHostedService注册，同时完善StopAsync方法确保调度器能正常关闭：

  public Task StopAsync(CancellationToken cancellationToken)
  {
      if (_scheduler != null)
      {
          return _scheduler.Shutdown(cancellationToken);
      }
      return Task.CompletedTask;
  }
  

3. Job实例的依赖注入问题 #

虽然你注册了HelloWorldJob为单例，但如果Quartz无法通过DI容器获取Job实例，也会导致任务执行失败（但通常会有日志报错）。使用官方的UseMicrosoftDependencyInjectionJobFactory()可以确保Quartz使用DI容器创建Job实例，避免此类问题。

实现暂停/恢复功能 #

如果需要通过用户命令控制任务的暂停和恢复，可以注入IScheduler来操作：

[ApiController]
[Route("api/job")]
public class JobController : ControllerBase
{
    private readonly IScheduler _scheduler;

    public JobController(IScheduler scheduler)
    {
        _scheduler = scheduler;
    }

    [HttpPost("pause")]
    public async Task<IActionResult> PauseHelloWorldJob()
    {
        await _scheduler.PauseJob(new JobKey("_job", "group"));
        return Ok("任务已暂停");
    }

    [HttpPost("resume")]
    public async Task<IActionResult> ResumeHelloWorldJob()
    {
        await _scheduler.ResumeJob(new JobKey("_job", "group"));
        return Ok("任务已恢复");
    }
}

内容的提问来源于stack exchange，提问作者Roman