.NET6用起来-Quartz.NET

Quartz.NET是一个功能齐全的开源作业调用系统,大大小小的应用程序都可使用。

创建一个asp.NET core web项目,使用quartz.NET的作业,定时调用远程接口是否能正常访问,发生异常调用飞书消息接口,把异常发送给指定的同事飞书。.

1.准备工作

定义一个作业调用的服务接口ICheckService

public interface ICheckService
    {
        Task ConnectRemoteApi(ConnectRemoteApiInput input);
    }

实现类CheckService

public class CheckService : ICheckService
{
        private readonly ILogger<CheckService> _logger;
        private readonly IHttpClientFactory _httpClientFactory;
        private readonly AppSetting _appSetting;
        public CheckService(ILogger<CheckService> logger, IHttpClientFactory httpClientFactory
            , IOptionsMonitor<AppSetting> options)
        {
            _logger = logger;
            _httpClientFactory = httpClientFactory;
            _appSetting = options.CurrentValue;
        }

        public async Task ConnectRemoteApi(ConnectRemoteApiInput input)
        {

            var para = new SecurityCodeInput()
            {
                Code = input.InnerCode,
                Inner = input.Inner
            };

            HttpClient client = _httpClientFactory.CreateClient();
            var paraContent = new StringContent(JsonSerializer.Serialize(para),
                encoding: Encoding.UTF8,
                mediaType: "application/json");

            try
            {
                using var httpResponse = await client.PostAsync(_appSetting.CheckUrl, paraContent);
                var result = await httpResponse.Content.ReadAsStringAsync();
                _logger.LogInformation(httpResponse.StatusCode.ToString());
            }
            catch (Exception ex)
            {
                //通过飞书发送消息给指定的人员
                _logger.LogInformation(ex.Message);

            }
        }
    }

实现Ijob接口

public class CheckRemoteApiJob : IJob
    {
        private readonly ICheckService _checkService;
        private readonly AppSetting _appSetting;
        public CheckRemoteApiJob(ICheckService checkService, IOptionsMonitor<AppSetting> options)
        {
            _checkService = checkService;
            _appSetting = options.CurrentValue;
        }

        public async Task Execute(IJobExecutionContext context)
        {
            await _checkService.ConnectRemoteApi(new ConnectRemoteApiInput
            {
                InnerCode = _appSetting.InnerCode,
            });
        }
    }

请先安装Quartz.AspNetCore nuget包,我使用的是最新的版本3.4.0,Execute方法默认是异步的,如果你的业务没有异步,可以使用Task.CompletedTask。

2.Job和Trigger绑定

作业已经实现,何时进行触发呢,Quartz.NET提供了一个trigger的概念。job和trigger进行绑定,Quartz既可以调度我们的job了。触发器和job的绑定,可以通过代码的方式,也可以通过xml形式(可以通过设置参数ScanInterval支持定期去扫描最新的变动),以下代码演示代码配置的两种方式进行调度我们的作业CheckRemoteApiJob。

2.1.使用ScheduleJob方法,Job绑定到单个Trigger,代码如下:

builder.Services.Configure<AppSetting>(builder.Configuration.GetSection("AppSetting"));
builder.Services.AddHttpClient();
builder.Services.AddScoped<ICheckService, CheckService>();
builder.Services.AddQuartz(q =>
{
    //支持DI,默认Ijob 实现不支持有参构造函数
    q.UseMicrosoftDependencyInjectionJobFactory();

    q.ScheduleJob<CheckRemoteApiJob>(trigger => trigger
            .WithIdentity("ConnectionRemoteApiTrigger")
            .StartAt(DateBuilder.EvenSecondDate(DateTimeOffset.UtcNow.AddSeconds(7)))
            .WithDailyTimeIntervalSchedule(x => x.WithInterval(builder.Configuration.GetValue<int>("AppSetting:CheckRemoteApiJobIntervalMinute"), IntervalUnit.Minute))
            .WithDescription("定时访问远程接口")
        );

});
builder.Services.AddQuartzServer(options =>
{
    // when shutting down we want jobs to complete gracefully
    options.WaitForJobsToComplete = true;
});

builder.Services.AddTransient<CheckRemoteApiJob>();

调用ScheduleJob方法,job默认只能绑定一个trigger。

运行代码,在控制台查看,每隔1分钟输出如下

.NET6用起来-Quartz.NET

2.2.job可以绑定到多个Trigger

builder.Services.AddQuartz(q =>
{
    //支持DI,默认Ijob 实现不支持有参构造函数
    q.UseMicrosoftDependencyInjectionJobFactory();
    //------sample
    //q.ScheduleJob<CheckRemoteApiJob>(trigger => trigger
    //        .WithIdentity("ConnectionRemoteApiTrigger")
    //        .StartAt(DateBuilder.EvenSecondDate(DateTimeOffset.UtcNow.AddSeconds(7)))
    //        .WithDailyTimeIntervalSchedule(x => x.WithInterval(builder.Configuration.GetValue<int>("AppSetting:CheckRemoteApiJobIntervalMinute"), IntervalUnit.Minute))
    //        .WithDescription("定时访问远程接口")
    //    );


    //---------cron

    var jobKey = new JobKey("ConnectionRemoteApi job", "ConnectionRemoteApi group");

    q.AddJob<CheckRemoteApiJob>(jobKey, j => {
        j.WithDescription("定时访问远程接口job");
    });


    q.AddTrigger(t => t
           .WithIdentity("ConnectionRemoteApi Cron Trigger")
           .ForJob(jobKey)
           .StartAt(DateBuilder.EvenSecondDate(DateTimeOffset.UtcNow.AddSeconds(3)))
           .WithCronSchedule(builder.Configuration.GetValue<string>("AppSetting:CheckRemoteApiJobCron"))
           .WithDescription("定时访问远程接口trigger")
       );

});

如果不想使用cron表达式,也可以使用方法 WithSimpleSchedule替换 如:

WithSimpleSchedule(x=> x.WithInterval(TimeSpan.FromMinutes(builder.Configuration.GetValue<int>"AppSetting:CheckRemoteApiJobIntervalMinute"))).RepeatForever())

再次运行代码,跟上面的输出是一样的。

参考官网:https://www.quartz-scheduler.net/