从控制器手动触发 Quartz.net 作业
Trigger Quartz.net job manually from controller
我在 VS2019 中构建了一个示例 .NET 5 Web API 应用程序,我有默认模板(WeatherForecastController
)。
我已将 Quartz.net(版本 3.3.3)添加到项目中,并在 Startup
class 中添加:
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"));
(参考:)
下面是我的控制器:
[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: Unable to resolve service for type
'Quartz.IScheduler' while attempting to activate
'QuartzTest.Controllers.QuartzController'. at
Microsoft.Extensions.DependencyInjection.ActivatorUtilities.GetService(IServiceProvider
sp, Type type, Type requiredBy, Boolean isDefaultParameterRequired)
at lambda_method10(Closure , IServiceProvider , Object[] ) at
Microsoft.AspNetCore.Mvc.Controllers.ControllerActivatorProvider.<>c__DisplayClass4_0.b__0(ControllerContext
controllerContext) at
Microsoft.AspNetCore.Mvc.Controllers.ControllerFactoryProvider.<>c__DisplayClass5_0.g__CreateController|0(ControllerContext
controllerContext) at
Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Next(State&
next, Scope& scope, Object& state, Boolean& isCompleted) at
Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.InvokeInnerFilterAsync()
--- End of stack trace from previous location --- at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.g__Awaited|19_0(ResourceInvoker
invoker, Task lastTask, State next, Scope scope, Object state, Boolean
isCompleted) at
Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.g__Awaited|17_0(ResourceInvoker
invoker, Task task, IDisposable scope) at
Microsoft.AspNetCore.Routing.EndpointMiddleware.g__AwaitRequestTask|6_0(Endpoint
endpoint, Task requestTask, ILogger logger) at
Microsoft.AspNetCore.Authorization.AuthorizationMiddleware.Invoke(HttpContext
context) at
Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke(HttpContext
httpContext) at
Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware.Invoke(HttpContext
httpContext, ISwaggerProvider swaggerProvider) at
Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware.Invoke(HttpContext
context)
我如何访问控制器内的调度程序并理想地检查特定作业是否存在以及它们的状态是什么(是 运行ning)?
I thought that services.AddQuartz
will be enough.
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");
}
}
我在 VS2019 中构建了一个示例 .NET 5 Web API 应用程序,我有默认模板(WeatherForecastController
)。
我已将 Quartz.net(版本 3.3.3)添加到项目中,并在 Startup
class 中添加:
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"));
(参考:
下面是我的控制器:
[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: Unable to resolve service for type 'Quartz.IScheduler' while attempting to activate 'QuartzTest.Controllers.QuartzController'. at Microsoft.Extensions.DependencyInjection.ActivatorUtilities.GetService(IServiceProvider sp, Type type, Type requiredBy, Boolean isDefaultParameterRequired)
at lambda_method10(Closure , IServiceProvider , Object[] ) at Microsoft.AspNetCore.Mvc.Controllers.ControllerActivatorProvider.<>c__DisplayClass4_0.b__0(ControllerContext controllerContext) at Microsoft.AspNetCore.Mvc.Controllers.ControllerFactoryProvider.<>c__DisplayClass5_0.g__CreateController|0(ControllerContext controllerContext) at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Next(State& next, Scope& scope, Object& state, Boolean& isCompleted) at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.InvokeInnerFilterAsync() --- End of stack trace from previous location --- at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.g__Awaited|19_0(ResourceInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted) at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.g__Awaited|17_0(ResourceInvoker invoker, Task task, IDisposable scope) at Microsoft.AspNetCore.Routing.EndpointMiddleware.g__AwaitRequestTask|6_0(Endpoint endpoint, Task requestTask, ILogger logger) at Microsoft.AspNetCore.Authorization.AuthorizationMiddleware.Invoke(HttpContext context) at Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke(HttpContext httpContext) at Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware.Invoke(HttpContext httpContext, ISwaggerProvider swaggerProvider) at Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware.Invoke(HttpContext context)
我如何访问控制器内的调度程序并理想地检查特定作业是否存在以及它们的状态是什么(是 运行ning)?
I thought that
services.AddQuartz
will be enough.
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");
}
}