.Net Core中使用Quartz.Net实践记录

下面我将为您详细讲解“.Net Core中使用Quartz.Net实践记录”的完整攻略。

什么是Quartz.Net

Quartz.Net是一个开源的作业调度框架，可以用来实现定时任务、计划任务等。使用Quartz.Net可以实现复杂的任务调度，不仅可以在应用程序内部触发作业，还可以通过网络触发。

实现过程

这里我们将介绍如何在.Net Core中使用Quartz.Net实现一个简单的定时任务。

步骤一：安装依赖

在.NET Core应用程序中，我们需要安装以下依赖：

Quartz.AspNetCore
Quartz.Extensions.Hosting

可以通过NuGet包管理器安装这些依赖。

步骤二：创建一个任务

创建一个任务很简单，我们只需要继承IJob接口，然后实现Execute方法即可。下面是一个简单的IJob实现：

public class MyJob : IJob
{
    public Task Execute(IJobExecutionContext context)
    {
        Console.WriteLine("Hello World!");
        return Task.CompletedTask;
    }
}

步骤三：配置Quartz

我们需要在Startup.cs文件中进行配置。下面是一个简单的配置示例：

public void ConfigureServices(IServiceCollection services)
{
    services.AddQuartz(q =>
    {
        q.UseMicrosoftDependencyInjectionJobFactory();

        // 创建并添加作业
        JobKey jobKey = new JobKey("myJob");
        q.AddJob<MyJob>(j => j.WithIdentity(jobKey));

        // 创建并添加触发器
        TriggerKey triggerKey = new TriggerKey("myTrigger");
        q.AddTrigger(t => t
            .WithIdentity(triggerKey)
            .StartNow()
            .WithSimpleSchedule(x => x
                .WithInterval(TimeSpan.FromSeconds(30))
                .RepeatForever())
            .ForJob(jobKey));
    });

    services.AddQuartzHostedService(
        q => q.WaitForJobsToComplete = true);
}

在以上示例中：

使用了依赖注入工厂。
创建了一个MyJob类型的作业。
创建了一个SimpleTrigger类型的触发器，并将其设置为每30秒触发一次。
将触发器绑定到MyJob作业上。
添加QuartzHostedService。

步骤四：运行应用程序

将应用程序启动起来，控制台将会输出“Hello World!”消息。

另一个使用示例

这里我们再介绍一个稍微复杂一点的使用示例。我们将创建两个任务，一个任务每分钟执行一次，另一个任务每5分钟执行一次。

public class MinuteJob : IJob
{
    public Task Execute(IJobExecutionContext context)
    {
        Console.WriteLine($"Minute Job - {DateTime.Now}");
        return Task.CompletedTask;
    }
}

public class FiveMinuteJob : IJob
{
    public Task Execute(IJobExecutionContext context)
    {
        Console.WriteLine($"Five Minute Job - {DateTime.Now}");
        return Task.CompletedTask;
    }
}

public void ConfigureServices(IServiceCollection services)
{
    services.AddQuartz(q =>
    {
        q.UseMicrosoftDependencyInjectionJobFactory();

        // 创建并添加分钟作业
        JobKey minuteJobKey = new JobKey("minuteJob");
        q.AddJob<MinuteJob>(j => j.WithIdentity(minuteJobKey));

        // 创建并添加分钟触发器
        TriggerKey minuteTriggerKey = new TriggerKey("minuteJobTrigger");
        q.AddTrigger(t => t
            .WithIdentity(minuteTriggerKey)
            .StartNow()
            .WithSimpleSchedule(x => x
                .WithInterval(TimeSpan.FromMinutes(1))
                .RepeatForever())
            .ForJob(minuteJobKey));

        // 创建并添加5分钟作业
        JobKey fiveMinuteJobKey = new JobKey("fiveMinuteJob");
        q.AddJob<FiveMinuteJob>(j => j.WithIdentity(fiveMinuteJobKey));

        // 创建并添加5分钟触发器
        TriggerKey fiveMinuteTriggerKey = new TriggerKey("fiveMinuteJobTrigger");
        q.AddTrigger(t => t
            .WithIdentity(fiveMinuteTriggerKey)
            .StartNow()
            .WithSimpleSchedule(x => x
                .WithInterval(TimeSpan.FromMinutes(5))
                .RepeatForever())
             .ForJob(fiveMinuteJobKey));
    });

    services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);
}

在以上示例中，我们创建了两个作业和两个触发器。分钟作业每分钟执行一次，5分钟作业每5分钟执行一次。