我在 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 Trigger Scheduled Job On Demand）
下面是我的控制器：
[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(ControllerContext controllerContext) 在 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() --- 堆疊跟蹤結束上一個位置 --- 在 Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.g__Awaited|19_0（ResourceInvoker 呼叫程式，任務上一個任務，下一個狀態，作用域范圍，物件狀態，布林值已完成）在 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.AspNetCoreization.Authorization.Authorization.Authorization Invoke(HttpContext context) 在 Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke(HttpContext httpContext) 在 Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware.Invoke(HttpContext httpContext, ISwaggerProvider swaggerProvider) 在 Microsoft.AspNetCore.SwaggerUIMiddleware.Invoke(HttpContext httpContext) 在 Microsoft.AspNetCore.SwaggerProvider swaggerProvider) 上任務 requestTask, ILogger logger) 在 Microsoft.AspNetCore.Authorization.AuthorizationMiddleware.Invoke(HttpContext context) 在 Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke(HttpContext httpContext) 在 Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware http.Invoke,ISwaggerMiddleware ) 在 Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware.Invoke(HttpContext 背景關系)任務 requestTask, ILogger logger) 在 Microsoft.AspNetCore.Authorization.AuthorizationMiddleware.Invoke(HttpContext context) 在 Swashbuckle.AspNetCore.SwaggerUI.SwaggerUIMiddleware.Invoke(HttpContext httpContext) 在 Swashbuckle.AspNetCore.Swagger.SwaggerMiddleware http.Invoke,ISwaggerMiddleware ) 在 Microsoft.AspNetCore.Diagnostics.DeveloperExceptionPageMiddleware.Invoke(HttpContext 背景關系)呼叫（HttpContext 背景關系）呼叫（HttpContext 背景關系）
如何訪問控制器內的調度程式并理想地檢查特定作業是否存在及其狀態（是否正在運行）？
uj5u.com熱心網友回復：
我以為這
services.AddQuartz就夠了。
AddQuartz添加調度程式工廠，而不是ISchedulerDI 容器。
由于獲取調度程式是異步完成的，因此在啟動期間很難設定它。
重構您的代碼以改為依賴于工廠并使用它來獲取調度程式
[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");
}
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/qukuanlian/360885.html