从控制器手动触发 Quartz.net 作业

Question

我在 VS2019 中构建了一个示例 .NET 5 Web API 应用程序，我有默认模板（带有WeatherForecastController）。我已将 Quartz.net （版本 3.3.3）添加到项目中，并在Startup课堂上添加了：

public void ConfigureServices(IServiceCollection services)
{
    services.AddQuartz(q =>
    {
        q.UseMicrosoftDependencyInjectionJobFactory();
        q.AddJobAndTrigger<HelloWorldJob>(Configuration);
    });

    // ASP.NET Core hosting
    services.AddQuartzServer(options =>
    {
        // when shutting down we want jobs to complete gracefully
        options.WaitForJobsToComplete = true;
    });

    services.AddControllers();
    services.AddSwaggerGen(c =>
    {
        c.SwaggerDoc("v1", new OpenApiInfo { Title = "QuartzTest", Version = "v1" });
    });
}

并创建了一个示例作业。
代码AddJobAndTrigger取自https://andrewlock.net/using-quartz-net-with-asp-net-core-and-worker-services/

该部分工作完美，但现在我想让最终用户能够通过 REST API 手动触发特定作业。

我创建了一个简单的控制器，应该能够使用以下命令手动触发作业：

scheduler.TriggerJob(new Jobkey("MarkAsSolutionReminderJob"));

（参考：Quartz.Net 按需触发预定作业）

下面是我的控制器：

[ApiController]
[Route("[controller]")]
public class QuartzController : ControllerBase
{
    private readonly IScheduler _scheduler;
    private readonly ILogger<WeatherForecastController> _logger;

    public QuartzController(IScheduler scheduler, ILogger<WeatherForecastController> logger)
    {
        _scheduler = scheduler;
        _logger = logger;
    }

    [HttpGet("Run")]
    public async Task<OkObjectResult> Run(string jobName)
    {
        //check if a specific job exists

        //if yes then run that job
        await _scheduler.TriggerJob(new JobKey("HelloWorldJob"));
        return Ok("OK");
    }
}

但是当我尝试运行它时，我收到此错误：

System.InvalidOperationException：尝试激活“QuartzTest.Controllers.QuartzController”时无法解析类型“Quartz.IScheduler”的服务。在 Microsoft.Extensions.DependencyInjection.ActivatorUtilities.GetService(IServiceProvider sp, Type type, Type requiredBy, Boolean isDefaultParameterRequired)
在 lambda_method10(Closure , IServiceProvider , Object[] ) 在 Microsoft.AspNetCore.Mvc.Controllers.ControllerActivatorProvider.<>c__DisplayClass4_0.b__0 (ControllerContextcontrollerContext) 在 Microsoft.AspNetCore.Mvc.Controllers.ControllerFactoryProvider.<>c__DisplayClass5_0.g__CreateController|0(ControllerContextcontrollerContext) 在 Microsoft.AspNetCore.Mvc.Infrastruct.ControllerActionInvoker.Next(状态&下一个、范围&范围、对象&状态、布尔& isCompleted ) 在 Microsoft.AspNetCore.Mvc.Infrastruct.ControllerActionInvoker.InvokeInnerFilterAsync() --- 之前位置的堆栈跟踪结束 --- 在 Microsoft.AspNetCore.Mvc.Infrastruct.ResourceInvoker.g__Awaited|19_0(ResourceInvoker invoker, Task lastTask, State接下来，范围范围，对象状态，布尔值 isCompleted）在 Microsoft.AspNetCore.Mvc.Infrastruct.ResourceInvoker.g__Awaited|17_0（ResourceInvoker 调用程序，任务任务，IDisposable 范围）在 Microsoft.AspNetCore.Routing.EndpointMiddleware.g__AwaitRequestTask|6_0（端点端点、任务 requestTask、ILogger 记录器）位于 Microsoft.AspNetCore.Authorization.AuthorizationMiddleware.Invoke（HttpContext 上下文）位于 Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke（HttpContext httpContext）位于 Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware.Invoke（HttpContext httpContext，ISwaggerProvider） swaggerProvider）位于 Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware.Invoke（HttpContext 上下文）

如何访问控制器内的调度程序并理想地检查特定作业是否存在以及它们的状态是什么（是否正在运行）？

Answer 1

我想这就services.AddQuartz足够了。

AddQuartz添加调度器工厂，而不是IScheduler添加到 DI 容器。

由于获取调度程序是异步完成的，因此在启动期间很难对其进行设置。

重构您的代码以依赖工厂并使用它来获取调度程序

[ApiController]
[Route("[controller]")]
public class QuartzController : ControllerBase {
    private readonly ISchedulerFactory factory;
    private readonly ILogger<WeatherForecastController> _logger;

    public QuartzController(ISchedulerFactory factory, ILogger<WeatherForecastController> logger) {
        this.factory = factory;
        _logger = logger;
    }

    [HttpGet("Run")]
    public async Task<OkObjectResult> Run(string jobName) {
        IScheduler scheduler = await factory.GetScheduler();

        //...check if a specific job exists

        //if yes then run that job
        await scheduler.TriggerJob(new JobKey("HelloWorldJob"));

        return Ok("OK");
    }
}