Quartz.Net调度框架配置解析
发布时间 - 2026-01-11 02:23:57 点击率:次在平时的工作中,估计大多数都做过轮询调度的任务,比如定时轮询数据库同步,定时邮件通知等等。大家通过windows计划任务,windows服务等都实现过此类任务,甚至实现过自己的配置定制化的框架。那今天就来介绍个开源的调度框架Quartz.Net(主要介绍配置的实现,因为有朋友问过此类问题)。调度的实现代码很简单,在源码中有大量Demo,这里就略过了。

Quartz.Net当前最新版本Quartz.NET 2.0 beta 1 Released
一、基于文件配置
先看一下简单的实现代码
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using Quartz;
using Quartz.Impl;
using Common.Logging;
namespace Demo
{
class Program
{
static void Main(string[] args)
{
// First we must get a reference to a scheduler
ISchedulerFactory sf = new StdSchedulerFactory();
IScheduler sched = sf.GetScheduler();
sched.Start();
sched.Shutdown(true);
}
}
}
代码很简单,配置文件中的quartz基础配置,以及job,trigger信息是如何加载的?这个过程是发生 IScheduler sched = sf.GetScheduler();过程,主要体现在源码这一段
public void Initialize()
{
// short-circuit if already initialized
if (cfg != null)
{
return;
}
if (initException != null)
{
throw initException;
}
NameValueCollection props = (NameValueCollection) ConfigurationManager.GetSection("quartz");
string requestedFile = Environment.GetEnvironmentVariable(PropertiesFile);
string propFileName = requestedFile != null && requestedFile.Trim().Length > 0 ? requestedFile : "~/quartz.config";
// check for specials
propFileName = FileUtil.ResolveFile(propFileName);
if (props == null && File.Exists(propFileName))
{
// file system
try
{
PropertiesParser pp = PropertiesParser.ReadFromFileResource(propFileName);
props = pp.UnderlyingProperties;
Log.Info(string.Format("Quartz.NET properties loaded from configuration file '{0}'", propFileName));
}
catch (Exception ex)
{
Log.Error("Could not load properties for Quartz from file {0}: {1}".FormatInvariant(propFileName, ex.Message), ex);
}
}
if (props == null)
{
// read from assembly
try
{
PropertiesParser pp = PropertiesParser.ReadFromEmbeddedAssemblyResource("Quartz.quartz.config");
props = pp.UnderlyingProperties;
Log.Info("Default Quartz.NET properties loaded from embedded resource file");
}
catch (Exception ex)
{
Log.Error("Could not load default properties for Quartz from Quartz assembly: {0}".FormatInvariant(ex.Message), ex);
}
}
if (props == null)
{
throw new SchedulerConfigException(
@"Could not find <quartz> configuration section from your application config or load default configuration from assembly.
Please add configuration to your application config file to correctly initialize Quartz.");
}
Initialize(OverrideWithSysProps(props));
}
通过上面代码分析,初始化首先会检查系统config中是否有<quartz> configuration section节点 (config指的app.config,web.config),如果系统config有quartz节点,则直接加载此处的配置信息。如果系统config没有quartz的基础配置信息,则会继续查找是否有quartz.config/Quartz.quartz.config 这两个配置文件的存在,如果有则加载配置信息,如果没有则扔出初始化配置异常。
而jobs.xml(调度的任务和触发器plugin节点配置文件)
app.config/web.config 中plugin配置
<quartz> <add key="quartz.scheduler.instanceName" value="ExampleDefaultQuartzScheduler"/> <add key="quartz.threadPool.type" value="Quartz.Simpl.SimpleThreadPool, Quartz"/> <add key="quartz.threadPool.threadCount" value="10"/> <add key="quartz.threadPool.threadPriority" value="2"/> <add key="quartz.jobStore.misfireThreshold" value="60000"/> <add key="quartz.jobStore.type" value="Quartz.Simpl.RAMJobStore, Quartz"/> <!--******************************Plugin配置********************************************* --> <add key="quartz.plugin.xml.type" value="Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz" /> <add key="quartz.plugin.xml.fileNames" value="quartz_jobs.xml"/> </quartz>
quartz.config 中plugin配置指向(quartz.plugin.xml.type / quartz.plugin.xml.fileNames)
# You can configure your scheduler in either <quartz> configuration section # or in quartz properties file # Configuration section has precedence quartz.scheduler.instanceName = ServerScheduler # configure thread pool info quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz quartz.threadPool.threadCount = 10 quartz.threadPool.threadPriority = Normal #--------------------------------*************plugin配置------------------------------------ # job initialization plugin handles our xml reading, without it defaults are used quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz quartz.plugin.xml.fileNames = ~/quartz_jobs.xml # export this server to remoting context quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz quartz.scheduler.exporter.port = 555 quartz.scheduler.exporter.bindName = QuartzScheduler quartz.scheduler.exporter.channelType = tcp quartz.scheduler.exporter.channelName = httpQuartz
二、基于代码的方式
这种情况直接通过代码实现的,官方DEMO很多都是如此,我们举个例子
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text; using Quartz;
using Quartz.Impl;
using System.Threading;
using Common.Logging;
namespace Demo
{
class Program
{
static void Main(string[] args)
{
ILog log = LogManager.GetLogger(typeof(Demo.HelloJob));
log.Info("------- Initializing ----------------------");
// First we must get a reference to a scheduler
ISchedulerFactory sf = new StdSchedulerFactory();
IScheduler sched = sf.GetScheduler();
log.Info("------- Initialization Complete -----------");
//---------------------------------------代码添加job和trigger
// computer a time that is on the next round minute
DateTimeOffset runTime = DateBuilder.EvenMinuteDate(DateTimeOffset.UtcNow);
log.Info("------- Scheduling Job -------------------");
// define the job and tie it to our HelloJob class
IJobDetail job = JobBuilder.Create<HelloJob>()
.WithIdentity("job1", "group1")
.Build();
// Trigger the job to run on the next round minute
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("trigger1", "group1")
.StartAt(runTime)
.Build();
// Tell quartz to schedule the job using our trigger
sched.ScheduleJob(job, trigger);
log.Info(string.Format("{0} will run at: {1}", job.Key, runTime.ToString("r")));
// Start up the scheduler (nothing can actually run until the
// scheduler has been started)
sched.Start();
log.Info("------- Started Scheduler -----------------");
// wait long enough so that the scheduler as an opportunity to
// run the job!
log.Info("------- Waiting 65 seconds... -------------");
// wait 65 seconds to show jobs
Thread.Sleep(TimeSpan.FromSeconds(65));
// shut down the scheduler
log.Info("------- Shutting Down ---------------------");
sched.Shutdown(true);
log.Info("------- Shutdown Complete -----------------");
}
}
}
其实代码方式已经实现了和配置文件混搭的方式了。但是这种对方式是通过配置关联加载job与trigger配置,我们还有第三种方式,自己加载job与trigger配置文件。
三、手动加载配置文件
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Quartz;
using Quartz.Xml;
using Quartz.Impl;
using Quartz.Simpl;
using System.Threading;
using Common.Logging;
using System.IO;
namespace Demo
{
class Program
{
static void Main(string[] args)
{
XMLSchedulingDataProcessor processor = new XMLSchedulingDataProcessor(new SimpleTypeLoadHelper());
ISchedulerFactory sf = new StdSchedulerFactory();
IScheduler scheduler = sf.GetScheduler();
Stream s = new StreamReader("~/quartz.xml").BaseStream;
processor.ProcessStream(s, null);
processor.ScheduleJobs(scheduler);
scheduler.Start();
scheduler.Shutdown();
}
}
}
亦或者这样
using System.Text;
using Quartz;
using Quartz.Xml;
using Quartz.Impl;
using Quartz.Simpl;
using System.Threading;
using Common.Logging;
using System.IO;
namespace Demo
{
class Program
{
static void Main(string[] args)
{
XMLSchedulingDataProcessor processor = new XMLSchedulingDataProcessor(new SimpleTypeLoadHelper());
ISchedulerFactory sf = new StdSchedulerFactory();
IScheduler scheduler = sf.GetScheduler();
processor.ProcessFileAndScheduleJobs("~/quartz.xml",scheduler);
scheduler.Start();
scheduler.Shutdown();
}
}
}
目前根据源码分析大致就这几种配置方式,很灵活可以任意组合。 关于quartz的使用源码很详细,并且园子量有大量的学习文章。
记住quartz的配置读取方式首先app.config/web.config ---->quartz.config/Quartz.quartz.config ---->quartz_jobs.xml .
通过代码方式我们可以改变quartz_jobs.xml 的指向即自己新命名的xml文件
(默认的quartz_jobs.xml是在XMLSchedulingDataProcessor.QuartzXmlFileName = "quartz_jobs.xml"被指定的)
方式一,通过quartz节点/quartz.config指向指定的jobs.xml。
方式二,通过XMLSchedulingDataProcessor 加载指定的jobs.xml
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
# Quartz.Net
# 调度框架
# .NET6+Quartz实现定时任务的示例详解
# ASP.NET MVC使用Quartz.NET执行定时任务
# 作业调度框架Quartz.net用法详解
# .Net Core中使用Quartz.Net实践记录
# .net下Quartz.Net的使用方法
# 在.NET6中使用配置Quartz.NET定时任务并使用IHostedService实现项目启动自动
# 配置文件
# 加载
# 很简单
# 此类
# 自己的
# 都是
# 是在
# 过了
# 中有
# 我们可以
# 这两个
# 如果没有
# 做过
# 这种情况
# 几种
# 就来
# 最新版本
# 体现在
# 问过
# 则会
相关栏目:
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐:
佛山网站制作系统,佛山企业变更地址网上办理步骤?
Laravel如何实现数据导出到CSV文件_Laravel原生流式输出大数据量CSV【方案】
网站制作怎么样才能赚钱,用自己的电脑做服务器架设网站有什么利弊,能赚钱吗?
如何快速重置建站主机并恢复默认配置?
百度输入法ai面板怎么关 百度输入法ai面板隐藏技巧
linux写shell需要注意的问题(必看)
Windows10如何删除恢复分区_Win10 Diskpart命令强制删除分区
香港服务器租用每月最低只需15元?
Laravel如何清理系统缓存命令_Laravel清除路由配置及视图缓存的方法【总结】
Android滚轮选择时间控件使用详解
香港服务器网站测试全流程:性能评估、SEO加载与移动适配优化
JavaScript Ajax实现异步通信
如何在万网自助建站平台快速创建网站?
实例解析angularjs的filter过滤器
如何快速配置高效服务器建站软件?
如何有效防御Web建站篡改攻击?
微博html5版本怎么弄发语音微博_语音录制入口及时长限制操作【教程】
如何用PHP快速搭建CMS系统?
Laravel如何连接多个数据库_Laravel多数据库连接配置与切换教程
如何快速使用云服务器搭建个人网站?
大型企业网站制作流程,做网站需要注册公司吗?
laravel怎么为API路由添加签名中间件保护_laravel API路由签名中间件保护方法
如何快速辨别茅台真假?关键步骤解析
Laravel如何生成PDF或Excel文件_Laravel文档导出工具与使用教程
今日头条微视频如何找选题 今日头条微视频找选题技巧【指南】
如何在云主机上快速搭建网站?
简历没回改:利用AI润色让你的文字更专业
如何在腾讯云服务器上快速搭建个人网站?
美食网站链接制作教程视频,哪个教做美食的网站比较专业点?
网页制作模板网站推荐,网页设计海报之类的素材哪里好?
如何用AI帮你把自己的生活经历写成一个有趣的故事?
教你用AI将一段旋律扩展成一首完整的曲子
韩国网站服务器搭建指南:VPS选购、域名解析与DNS配置推荐
实例解析Array和String方法
lovemo网页版地址 lovemo官网手机登录
Windows驱动无法加载错误解决方法_驱动签名验证失败处理步骤
php增删改查怎么学_零基础入门php数据库操作必知基础【教程】
如何快速搭建个人网站并优化SEO?
Laravel怎么配置自定义表前缀_Laravel数据库迁移与Eloquent表名映射【步骤】
Claude怎样写结构化提示词_Claude结构化提示词写法【教程】
如何快速生成橙子建站落地页链接?
标题:Vue + Vuex 项目中正确使用 JWT 进行身份认证的实践指南
Laravel如何发送系统通知_Laravel Notifications实现多渠道消息通知
阿里云网站搭建费用解析:服务器价格与建站成本优化指南
如何在阿里云虚拟机上搭建网站?步骤解析与避坑指南
Laravel Eloquent关联是什么_Laravel模型一对一与一对多关系精讲
香港服务器建站指南:外贸独立站搭建与跨境电商配置流程
Python结构化数据采集_字段抽取解析【教程】
手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站?
Edge浏览器怎么启用睡眠标签页_节省电脑内存占用优化技巧

