百度360必应搜狗淘宝本站头条
vba高级教程svn连接scheduledtaskmybatis plus结构体数组
当前位置：网站首页 > 编程网 > 正文

通过实例详细讲解Quartz.NET的一些高级功能的应用，你用到了多少

yuyutoo 2024-11-01 15:55 1 浏览 0 评论

Quartz.NET 是一个强大的开源作业调度库，提供了许多高级功能。以下是 Quartz.NET 的常用高级功能：

  1. Cron 表达式触发器： 使用 Cron 表达式定义灵活的调度规则，实现复杂的时间调度策略。
  2. 作业依赖性： 允许定义作业之间的依赖关系，确保它们按照特定的顺序执行。
  3. 作业执行中的数据传递： 在调度作业时，可以传递参数和数据，使得作业能够根据需要获取执行时的上下文信息。
  4. 全局作业监听器： 添加全局监听器，监听作业的执行生命周期事件，例如作业执行前、执行后等。
  5. 全局触发器监听器： 添加全局监听器，监听触发器的生命周期事件，例如触发器触发、触发器完成等。
  6. 自定义日历： 可以实现自定义的日历逻辑，例如排除特定日期或时间段，以满足业务需求。
  7. 集群模式： 允许将 Quartz.NET 实例配置为集群，实现分布式作业调度，确保高可用性和负载均衡。
  8. 持久性作业： Quartz.NET 提供了作业的持久性支持，可以将作业和触发器存储在数据库中，保证作业不会丢失。
  9. 作业状态记录： Quartz.NET 能够记录作业的执行状态，包括成功、失败、被否决等，方便监控和故障排查。
  10. 并行执行： 允许多个作业同时执行，提高系统的并发性能。

这些功能使得 Quartz.NET 成为一个灵活且功能丰富的作业调度框架，适用于各种复杂的调度需求。

以下是 Quartz.NET 的高级功能示例，包含中文注释：

1.Cron 表达式触发器

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<NetworkStatusCheckJob>()
                .WithIdentity("networkStatusCheckJob", "group1")
                .Build();

            // 创建触发器，使用 Cron 表达式，每天10:30触发一次
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("networkStatusCheckTrigger", "group1")
                .StartNow()
                .WithCronSchedule("0 30 10 ? * *")
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

2.作业间的依赖性

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建作业1
            IJobDetail job1 = JobBuilder.Create<Job1>()
                .WithIdentity("job1", "group1")
                .Build();

            // 创建作业2
            IJobDetail job2 = JobBuilder.Create<Job2>()
                .WithIdentity("job2", "group1")
                .Build();

            // 创建触发器1
            ITrigger trigger1 = TriggerBuilder.Create()
                .WithIdentity("trigger1", "group1")
                .StartNow()
                .Build();

            // 创建触发器2，设置在触发器1后执行
            ITrigger trigger2 = TriggerBuilder.Create()
                .WithIdentity("trigger2", "group1")
                .StartNow()
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job1, trigger1).Wait();
            scheduler.ScheduleJob(job2, trigger2.ForJob(job1).Build()).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class Job1 : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("Job1 执行");
    }
}

public class Job2 : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("Job2 执行");
    }
}

3.作业执行中的数据传递

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建带数据的作业
            IJobDetail job = JobBuilder.Create<DataPassingJob>()
                .WithIdentity("dataPassingJob", "group1")
                .UsingJobData("key1", "value1")
                .UsingJobData("key2", 123)
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("dataPassingTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class DataPassingJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        // 从作业执行上下文中获取传递的数据
        JobDataMap dataMap = context.JobDetail.JobDataMap;
        string value1 = dataMap.GetString("key1");
        int value2 = dataMap.GetInt("key2");

        Console.WriteLine(#34;作业执行中的数据：key1={value1}, key2={value2}");
    }
}

4.全局作业监听器

using Quartz;
using Quartz.Impl;
using System;

public class GlobalJobListener : IJobListener
{
    public string Name => "GlobalJobListener";

    public Task JobExecutionVetoed(IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;作业被否决：{context.JobDetail.Key}");
        return Task.CompletedTask;
    }

    public Task JobToBeExecuted(IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;准备执行作业：{context.JobDetail.Key}");
        return Task.CompletedTask;
    }

    public Task JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;作业执行完成：{context.JobDetail.Key}");
        return Task.CompletedTask;
    }
}

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 添加全局作业监听器
            scheduler.ListenerManager.AddJobListener(new GlobalJobListener());

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()


                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

5.全局触发器监听器

using Quartz;
using Quartz.Impl;
using System;

public class GlobalTriggerListener : ITriggerListener
{
    public string Name => "GlobalTriggerListener";

    public Task TriggerComplete(ITrigger trigger, IJobExecutionContext context, Trigger.CompletedExecutionInstruction triggerInstructionCode, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;触发器完成：{trigger.Key}");
        return Task.CompletedTask;
    }

    public Task TriggerFired(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;触发器触发：{trigger.Key}");
        return Task.CompletedTask;
    }

    public Task TriggerMisfired(ITrigger trigger, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;触发器错过触发：{trigger.Key}");
        return Task.CompletedTask;
    }

    public Task<bool> VetoJobExecution(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;否决作业执行：{trigger.Key}");
        return Task.FromResult(false);
    }
}

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 添加全局触发器监听器
            scheduler.ListenerManager.AddTriggerListener(new GlobalTriggerListener());

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

6.自定义日历

using Quartz;
using Quartz.Impl;
using System;

public class CustomCalendar : BaseCalendar
{
    // 实现自定义的日历逻辑，这里简单演示一个排除周末的例子
    public override bool IsTimeIncluded(DateTimeOffset timeStampUtc)
    {
        return timeStampUtc.DayOfWeek != DayOfWeek.Saturday && timeStampUtc.DayOfWeek != DayOfWeek.Sunday;
    }

    public override DateTimeOffset GetNextIncludedTimeUtc(DateTimeOffset timeStampUtc)
    {
        // 确保下一个时间是在排除条件内的
        DateTimeOffset nextTime = timeStampUtc.AddSeconds(1);
        while (!IsTimeIncluded(nextTime))
        {
            nextTime = nextTime.AddSeconds(1);
        }
        return nextTime;
    }
}

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 使用自定义日历
            scheduler.AddCalendar("customCalendar", new CustomCalendar(), true, true);

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器，关联自定义日历
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .ModifiedByCalendar("customCalendar")
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

7.集群模式

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例，设置为集群模式
            IScheduler scheduler = schedulerFactory.GetScheduler(new NameValueCollection { { "quartz.jobStore.type", "Quartz.Simpl.RAMJobStore, Quartz" } }).Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

8.持久性作业

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例，设置为使用 AdoJobStore 持久性存储
            IScheduler scheduler = schedulerFactory.GetScheduler(new NameValueCollection
            {
                { "quartz.jobStore.type", "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz" },
                { "quartz.jobStore.driverDelegateType", "Quartz.Impl.AdoJobStore.StdAdoDelegate, Quartz" },
                { "quartz.jobStore.dataSource", "myDS" },
                { "quartz.dataSource.myDS.connectionString", "YourConnectionString" },
                { "quartz.jobStore.tablePrefix", "QRTZ_" },
                { "quartz.jobStore.useProperties", "true" },
                { "quartz.jobStore.misfireThreshold", "60000" }
            }).Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .StoreDurably() // 设置为持久性作业
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.AddJob(job, true).Wait();
            scheduler.ScheduleJob(trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

9.作业状态记录

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<StatusRecordingJob>()
                .WithIdentity("statusRecordingJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("statusRecordingTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class StatusRecordingJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        // 记录作业状态
        Console.WriteLine(#34;作业执行中... 执行状态：{context.Result}");
    }
}

10.并行执行

using Quartz;
using Quartz.Impl;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        try


        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = await schedulerFactory.GetScheduler();

            // 创建作业1
            IJobDetail job1 = JobBuilder.Create<ParallelJob>()
                .WithIdentity("parallelJob1", "group1")
                .Build();

            // 创建作业2
            IJobDetail job2 = JobBuilder.Create<ParallelJob>()
                .WithIdentity("parallelJob2", "group1")
                .Build();

            // 创建触发器1
            ITrigger trigger1 = TriggerBuilder.Create()
                .WithIdentity("trigger1", "group1")
                .StartNow()
                .Build();

            // 创建触发器2
            ITrigger trigger2 = TriggerBuilder.Create()
                .WithIdentity("trigger2", "group1")
                .StartNow()
                .Build();

            // 将作业和触发器添加到调度器
            await scheduler.ScheduleJob(job1, trigger1);
            await scheduler.ScheduleJob(job2, trigger2);

            // 启动调度器
            await scheduler.Start();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            await scheduler.Shutdown();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class ParallelJob : IJob
{
    public async Task Execute(IJobExecutionContext context)
    {
        // 模拟作业执行时间
        await Task.Delay(TimeSpan.FromSeconds(10));

        Console.WriteLine(#34;并行作业执行中... 执行时间：{DateTime.Now}");
    }
}

这些示例涵盖了 Quartz.NET 的一些高级功能，包括 Cron 表达式触发器、作业间的依赖性、作业执行中的数据传递、全局作业监听器、全局触发器监听器、自定义日历、集群模式、持久性作业、作业状态记录和并行执行。希望对你理解 Quartz.NET 的高级功能有所帮助。

相关推荐

jQuery VS AngularJS 你更钟爱哪个?

在这一次的Web开发教程中，我会尽力解答有关于jQuery和AngularJS的两个非常常见的问题，即jQuery和AngularJS之间的区别是什么？也就是说jQueryVSAngularJS？...

Jquery实时校验，指定长度的「负小数」，小数位未满末尾补0

在可以输入【负小数】的输入框获取到焦点时，移除千位分隔符，在输入数据时，实时校验输入内容是否正确，失去焦点后，添加千位分隔符格式化数字。同时小数位未满时末尾补0。HTML代码...

如何在pbootCMS前台调用自定义表单?pbootCMS自定义调用代码示例

要在pbootCMS前台调用自定义表单，您需要在后台创建表单并为其添加字段，然后在前台模板文件中添加相关代码，如提交按钮和表单验证代码。您还可以自定义表单数据的存储位置、添加文件上传字段、日期选择器、...

编程技巧:Jquery实时验证，指定长度的「负小数」

为了保障【负小数】的正确性，做成了通过Jquery，在用户端，实时验证指定长度的【负小数】的方法。HTML代码<inputtype="text"class="forc...

一篇文章带你用jquery mobile设计颜色拾取器

【一、项目背景】现实生活中，我们经常会遇到配色的问题，这个时候去百度一下RGB表。而RGB表只提供相对于的颜色的RGB值而没有可以验证的模块。我们可以通过jquerymobile去设计颜色的拾取器...

编程技巧:Jquery实时验证，指定长度的「正小数」

为了保障【正小数】的正确性，做成了通过Jquery，在用户端，实时验证指定长度的【正小数】的方法。HTML做成方法<inputtype="text"class="fo...

jquery.validate检查数组全部验证

问题：html中有多个name[]，每个参数都要进行验证是否为空，这个时候直接用required:true话，不能全部验证，只要这个数组中有一个有值就可以通过的。解决方法使用addmethod...

Vue进阶(幺叁肆):npm查看包版本信息

第一种方式npmviewjqueryversions这种方式可以查看npm服务器上所有的...

layui中使用lay-verify进行条件校验

一、layui的校验很简单，主要有以下步骤：1.在form表单内加上class="layui-form"2.在提交按钮上加上lay-submit3.在想要校验的标签，加上lay-...

jQuery是什么?如何使用? jquery是什么功能组件

jQuery于2006年1月由JohnResig在BarCampNYC首次发布。它目前由TimmyWilson领导,并由一组开发人员维护。jQuery是一个JavaScript库，它简化了客户...

django框架的表单form的理解和用法-9

表单呈现...

jquery对上传文件的检测判断 jquery实现文件上传

总体思路：在前端使用jquery对上传文件做部分初步的判断，验证通过的文件利用ajaxFileUpload上传到服务器端，并将文件的存储路径保存到数据库。<asp:FileUploadI...

Nodejs之MEAN栈开发(四)-- form验证及图片上传

这一节增加推荐图书的提交和删除功能，来学习node的form提交以及node的图片上传功能。开始之前需要源码同学可以先在git上fork：https://github.com/stoneniqiu/R...

大数据开发基础之JAVA jquery 大数据java实战

上一篇我们讲解了JAVAscript的基础知识、特点及基本语法以及组成及基本用途，本期就给大家带来了JAVAweb的第二个知识点jquery，大数据开发基础之JAVAjquery，这是本篇文章的主要...

推荐四个开源的jQuery可视化表单设计器

jquery开源在线表单拖拉设计器formBuilder(推荐)jQueryformBuilder是一个开源的WEB在线html表单设计器，开发人员可以通过拖拉实现一个可视化的表单。支持表单常用控件...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表