通过实例详细讲解Quartz.NET的一些高级功能的应用，你用到了多少
yuyutoo 2024-11-01 15:55 4 浏览 0 评论
Quartz.NET 是一个强大的开源作业调度库，提供了许多高级功能。以下是 Quartz.NET 的常用高级功能：
- Cron 表达式触发器： 使用 Cron 表达式定义灵活的调度规则，实现复杂的时间调度策略。
- 作业依赖性： 允许定义作业之间的依赖关系，确保它们按照特定的顺序执行。
- 作业执行中的数据传递： 在调度作业时，可以传递参数和数据，使得作业能够根据需要获取执行时的上下文信息。
- 全局作业监听器： 添加全局监听器，监听作业的执行生命周期事件，例如作业执行前、执行后等。
- 全局触发器监听器： 添加全局监听器，监听触发器的生命周期事件，例如触发器触发、触发器完成等。
- 自定义日历： 可以实现自定义的日历逻辑，例如排除特定日期或时间段，以满足业务需求。
- 集群模式： 允许将 Quartz.NET 实例配置为集群，实现分布式作业调度，确保高可用性和负载均衡。
- 持久性作业： Quartz.NET 提供了作业的持久性支持，可以将作业和触发器存储在数据库中，保证作业不会丢失。
- 作业状态记录： Quartz.NET 能够记录作业的执行状态，包括成功、失败、被否决等，方便监控和故障排查。
- 并行执行： 允许多个作业同时执行，提高系统的并发性能。
这些功能使得 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 的高级功能有所帮助。
相关推荐
- 全局和隐式 using 指令详解（全局命令）
-
1.什么是全局和隐式using？在.NET6及更高版本中，Microsoft引入了...
- 请停止微服务，做好单体的模块化才是王道:Spring Modulith介绍
-
1、介绍模块化单体是一种架构风格，代码是根据模块的概念构成的。对于许多组织而言，模块化单体可能是一个很好的选择。它有助于保持一定程度的独立性，这有助于我们在需要的时候轻松过渡到微服务架构。Spri...
- ASP.NET程序集引用之痛:版本冲突、依赖地狱等解析与实战
-
我是一位多年后端经验的工程师，其中前几年用ASP.NET...
- .NET AOT 详解（.net 6 aot）
-
简介AOT（Ahead-Of-TimeCompilation）是一种将代码直接编译为机器码的技术，与传统的...
- 一款基于Yii2开发的免费商城系统（一款基于yii2开发的免费商城系统是什么）
-
哈喽,我是老鱼，一名致力于在技术道路上的终身学习者、实践者、分享者！...
- asar归档解包（游戏arc文件解包）
-
要学习Electron逆向，首先要有一个Electron开发的程序的发布的包，这里就以其官方的electron-quick-start作为例子来进行一下逆向的过程。...
- 在PyCharm 中免费集成Amazon CodeWhisperer
-
CodeWhisperer是Amazon发布的一款免费的AI编程辅助小工具，可在你的集成开发环境（IDE）中生成实时单行或全函数代码建议，帮助你快速构建软件。简单来说，AmazonCodeWhi...
- 2014年最优秀JavaScript编辑器大盘点
-
1.WebstormWebStorm是一种轻量级的、功能强大的IDE，为Node.js复杂的客户端开发和服务器端开发提供完美的解决方案。WebStorm的智能代码编辑器支持JavaScript,...
- 基于springboot、tio、oauth2.0前端vuede 超轻量级聊天软件分享
-
项目简介：基于JS的超轻量级聊天软件。前端：vue、iview、electron实现的PC桌面版聊天程序，主要适用于私有云项目内部聊天，企业内部管理通讯等功能，主要通讯协议websocket。支持...
- JetBrains Toolbox推出全新产品订阅授权模式
-
捷克知名软件开发公司JetBrains最为人所熟知的产品是Java编程语言开发撰写时所用的集成开发环境IntelliJIDEA，相信很多开发者都有所了解。而近期自2015年11月2日起，JetBr...
- idea最新激活jetbrains-agent.jar包，亲测有效
-
这里分享一个2019.3.3版本的jetbrains-agent.jar，亲测有效，在网上找了很多都不能使用，终于找到一个可以使用的了，这里分享一下具体激活步骤，此方法适用于Jebrains家所有产品...
- CountDownTimer的理解（countdowntomars）
-
CountDownTimer是android开发常用的计时类，按照注释中的说明使用方法如下：kotlin:object:CountDownTimer(30000,1000){...
- 反射为什么性能会很慢?（反射时为什么会越来越长）
-
1.背景前段时间维护一个5、6年前的项目，项目总是在某些功能使用上不尽人意，性能上总是差一些，仔细过了一下代码发现使用了不少封装好的工具类，工具类里面用了好多的反射，反射会影响到执行效率吗？盲猜了一...
- btrace 开源!基于 Systrace 高性能 Trace 工具
-
介绍btrace（又名RheaTrace）是抖音基础技术团队自研的一款高性能AndroidTrace工具，它基于Systrace实现，并针对Systrace不足之处加以改进，核心改进...
欢迎 你 发表评论:
- 一周热门
- 最近发表
-
- .NET 奇葩问题调试经历之3——使用了grpc通讯类库后，内存一直增长......
- 全局和隐式 using 指令详解（全局命令）
- 请停止微服务，做好单体的模块化才是王道:Spring Modulith介绍
- ASP.NET程序集引用之痛:版本冲突、依赖地狱等解析与实战
- .NET AOT 详解（.net 6 aot）
- 一款基于Yii2开发的免费商城系统（一款基于yii2开发的免费商城系统是什么）
- asar归档解包（游戏arc文件解包）
- 在PyCharm 中免费集成Amazon CodeWhisperer
- 2014年最优秀JavaScript编辑器大盘点
- 基于springboot、tio、oauth2.0前端vuede 超轻量级聊天软件分享
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)