Quartz总结
Quartz.NET 入门
概述
Quartz.NET是一个开源的做业调度框架，很是适合在平时的工做中，定时轮询数据库同步，定时邮件通知，定时处理数据等。 Quartz.NET容许开发人员根据时间间隔（或天）来调度做业。它实现了做业和触发器的多对多关系，还能把多个做业与不一样的触发器关联。
整合了 Quartz.NET的应用程序能够重用来自不一样事件的做业，还能够为一个事件组合多个做业。数据库
快速搭建一个Quartz
第一步：安装
Install-Package Quartz Install-Package Common.Logging.Log4Net1211 Install-Package log4net Install-Package Topshelf Install-Package Topshelf.Log4Net
Quartz依赖Common.Logging和Common.Logging.Log4Net1211，又由于Log4Net是比较标准的日志工具，所以咱们通常都会安装log4net，
另外定时做业通常都容许在后台服务中，所以咱们也安装了Topshelf。express
第二步：实现IJob
TestJob.cs 实现IJob，在Execute方法里编写要处理的业务逻辑，系统就会按照Quartz的配置，定时处理。c#
using log4net;
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace QuartzDemo.QuartzJobs
{
public sealed class TestJob : IJob
{
private readonly ILog _logger = LogManager.GetLogger(typeof(TestJob));
public void Execute(IJobExecutionContext context)
{
_logger.InfoFormat("TestJob测试");
}
}
}
第三步：使用Topshelf调度任务
using Quartz;
using Quartz.Impl;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Topshelf;
namespace QuartzDemo
{
public sealed class ServiceRunner : ServiceControl, ServiceSuspend
{
private readonly IScheduler scheduler;
public ServiceRunner()
{
scheduler = StdSchedulerFactory.GetDefaultScheduler();
}
public bool Start(HostControl hostControl)
{
scheduler.Start();
return true;
}
public bool Stop(HostControl hostControl)
{
scheduler.Shutdown(false);
return true;
}
public bool Continue(HostControl hostControl)
{
scheduler.ResumeAll();
return true;
}
public bool Pause(HostControl hostControl)
{
scheduler.PauseAll();
return true;
}
}
}
第四步：程序入口
namespace QuartzDemo
{
class Program
{
static void Main(string[] args)
{
log4net.Config.XmlConfigurator.ConfigureAndWatch(new FileInfo(AppDomain.CurrentDomain.BaseDirectory + "log4net.config"));
HostFactory.Run(x =>
{
x.UseLog4Net();
x.Service<ServiceRunner>();
x.SetDescription("QuartzDemo服务描述");
x.SetDisplayName("QuartzDemo服务显示名称");
x.SetServiceName("QuartzDemo服务名称");
x.EnablePauseAndContinue();
});
}
}
}
第五步：配置quartz.config、quartz_jobs.xml、log4net.config
quartz.config
因格式缘由在#前加了/，使用时去掉便可windows
/# You can configure your scheduler in either <quartz> configuration section
/# or in quartz properties file
/# Configuration section has precedence
quartz.scheduler.instanceName = QuartzTest
/# configure thread pool info
quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz
quartz.threadPool.threadCount = 10
quartz.threadPool.threadPriority = Normal
/# 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
quartz_jobs.xml
<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">
<processing-directives>
<overwrite-existing-data>true</overwrite-existing-data>
</processing-directives>
<schedule>
<!--任务-->
<job>
<!--任务名称，同一个group中多个job的name不能相同-->
<name>SimpleJob</name>
<!--任务分组-->
<group>sampleGroup</group>
<!--任务描述-->
<description>Sample job for Quartz Server</description>
<!--完整命名空间的类名及所属程序集名称-->
<job-type>WindowsService.Job.SimpleJob, WindowsService</job-type>
<durable>true</durable>
<recover>false</recover>
</job>
<!--任务触发器-->
<trigger>
<!--简单任务的触发器，能够调度用于重复执行的任务-->
<!--<simple>
--><!--触发器名称，同一个分组中的名称必须不一样--><!--
<name>sampleSimpleTrigger</name>
--><!--触发器组--><!--
<group>sampleGroup</group>
--><!--描述--><!--
<description>Simple trigger to simply fire sample job</description>
--><!--要调度的任务名称，该job-name必须和对应job节点中的name彻底相同--><!--
<job-name>SimpleJob</job-name>
--><!--调度任务(job)所属分组，该值必须和job中的group彻底相同--><!--
<job-group>sampleGroup</job-group>
--><!--任务开始时间--><!--
--><!--<start-time>2017-08-21T11:10:00+08:00</start-time>--><!--
<misfire-instruction>SmartPolicy</misfire-instruction>
--><!--任务执行次数 -1 为无限次执行--><!--
<repeat-count>-1</repeat-count>
--><!--任务触发间隔(毫秒)--><!--
<repeat-interval>1000</repeat-interval>
--><!--每3秒中执行一次--><!--
</simple>-->
<cron>
<name>JobTrigger</name>
<group>JobTriggers</group>
<description>cron trigger</description>
<job-name>SimpleJob</job-name>
<job-group>sampleGroup</job-group>
<!--<start-time>2015-11-26T22:19:00+08:00</start-time>-->
<cron-expression>0/2 * * * * ?</cron-expression>
</cron>
</trigger>
</schedule>
</job-scheduling-data>
job 任务：用来定义每一个具体的任务的，多个任务请建立多个job节点便可
+ name(必填) 任务名称，同一个group中多个job的name不能相同，若未设置group则全部未设置group的job为同一个分组
+ group(选填) 任务所属分组，用于标识任务所属分组
+ description(选填) 任务描述，用于描述任务具体内容
+ job-type(必填) 任务类型，任务的具体类型及所属程序集，格式：实现了IJob接口的包含完整命名空间的类名,程序集名称
+ durable(选填) 具体做用不知，官方示例中默认为true
+ recover(选填) 具体做用不知，官方示例中默认为false
trigger 任务触发器:用于定义使用何种方式出发任务(job)，同一个job能够定义多个trigger ，多个trigger 各自独立的执行调度，
每一个trigger 中必须且只能定义一种触发器类型(calendar-interval、simple、cron)
+ simple 简单任务的触发器类型，能够调度用于重复执行的任务
* name(必填) 触发器名称，同一个分组中的名称必须不一样
* group(选填) 触发器组
* description(选填) 触发器描述
* job-name(必填) 要调度的任务名称，该job-name必须和对应job节点中的name彻底相同
* job-group(选填) 调度任务(job)所属分组，该值必须和job中的group彻底相同
* start-time(选填) 任务开始执行时间utc时间，北京时间须要+08:00，
如：<start-time>2012-04-01T08:00:00+08:00</start-time>表示北京时间2012年4月1日上午8:00开始执行，
注意服务启动或重启时都会检测此属性，若没有设置此属性或者start-time设置的时间比当前时间较早，
则服务启动后会当即执行一次调度，若设置的时间比当前时间晚，服务会等到设置时间相同后才会第一次执行任务，通常若无特殊须要请不要设置此属性
* repeat-count(必填) 任务执行次数，如:<repeat-count>-1</repeat-count>表示无限次执行，<repeat-count>10</repeat-count>表示执行10次
* repeat-interval(必填) 任务触发间隔(毫秒)，如:<repeat-interval>10000</repeat-interval> 每10秒执行一次
+ cron：复杂任务触发器--使用cron表达式定制任务调度
* name(必填) 触发器名称，同一个分组中的名称必须不一样
* group(选填) 触发器组
* escription(选填) 触发器描述
* job-name(必填) 要调度的任务名称，该job-name必须和对应job节点中的name彻底相同
* job-group(选填) 调度任务(job)所属分组，该值必须和job中的group彻底相同
* start-time(选填) 任务开始执行时间utc时间，北京时间须要+08:00，
如：<start-time>2012-04-01T08:00:00+08:00</start-time>表示北京时间2012年4月1日上午8:00开始执行，
注意服务启动或重启时都会检测此属性，若没有设置此属性，服务会根据cron-expression的设置执行任务调度；若start-time设置的时间比当前时间较早，则服务启动后会忽略掉cron-expression设置，当即执行一次调度，以后再根据cron-expression执行任务调度；若设置的时间比当前时间晚，则服务会在到达设置时间相同后才会应用cron-expression，
根据规则执行任务调度，通常若无特殊须要请不要设置此属性
* cron-expression(必填) cron表达式，如:<cron-expression>0/10 * * * * ?</cron-expression>每10秒执行一次
log4net.config
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<configSections>
<section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler, log4net"/>
</configSections>
<log4net>
<appender name="RollingLogFileAppender" type="log4net.Appender.RollingFileAppender">
<!--日志路径-->
<param name= "File" value= "D:\App_Log\servicelog\"/>
<!--是不是向文件中追加日志-->
<param name= "AppendToFile" value= "true"/>
<!--log保留天数-->
<param name= "MaxSizeRollBackups" value= "10"/>
<!--日志文件名是不是固定不变的-->
<param name= "StaticLogFileName" value= "false"/>
<!--日志文件名格式为:2008-08-31.log-->
<param name= "DatePattern" value= "yyyy-MM-dd".read.log""/>
<!--日志根据日期滚动-->
<param name= "RollingStyle" value= "Date"/>
<layout type="log4net.Layout.PatternLayout">
<param name="ConversionPattern" value="%d [%t] %-5p %c - %m%n %loggername" />
</layout>
</appender>
<!-- 控制台前台显示日志 -->
<appender name="ColoredConsoleAppender" type="log4net.Appender.ColoredConsoleAppender">
<mapping>
<level value="ERROR" />
<foreColor value="Red, HighIntensity" />
</mapping>
<mapping>
<level value="Info" />
<foreColor value="Green" />
</mapping>
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%n%date{HH:mm:ss,fff} [%-5level] %m" />
</layout>
<filter type="log4net.Filter.LevelRangeFilter">
<param name="LevelMin" value="Info" />
<param name="LevelMax" value="Fatal" />
</filter>
</appender>
<root>
<!--(高) OFF > FATAL > ERROR > WARN > INFO > DEBUG > ALL (低) -->
<level value="all" />
<appender-ref ref="ColoredConsoleAppender"/>
<appender-ref ref="RollingLogFileAppender"/>
</root>
</log4net>
</configuration>
Quartz任务调度
泛型数组批量job(可用数据库)+服务日志+log4net打印日志+制做windows服务数组
安装
Install-Package Quartz(2.6.2) Install-Package Common.Logging.Log4Net1211(3.0) Install-Package Topshelf(3.2) Install-Package Topshelf.Log4Net(3.2)
配置文件
<configSections>
<sectionGroup name="common">
<section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging" />
</sectionGroup>
<section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler,log4net" />
</configSections>
<common>
<logging>
<factoryAdapter type="Common.Logging.Log4Net.Log4NetLoggerFactoryAdapter, Common.Logging.Log4Net1211">
<arg key="configType" value="INLINE" />
</factoryAdapter>
</logging>
</common>
<log4net>
<!--错误日志-->
<!--自定义错误异常-->
<appender name="CustomExAppender" type="log4net.Appender.RollingFileAppender">
<param name="File" value="Log\\LogCustomEx\\" />
<param name="AppendToFile" value="true" />
<param name="MaxFileSize" value="10240" />
<param name="MaxSizeRollBackups" value="100" />
<param name="StaticLogFileName" value="false" />
<param name="DatePattern" value="yyyy\\yyyyMM\\yyyyMMdd'.txt'" />
<param name="RollingStyle" value="Date" />
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%newline %n记录时间：%date %n线程ID:[%thread] %n日志级别： %-5level %n日志描述：%message%newline %n" />
</layout>
</appender>
<appender name="ErrorExAppender" type="log4net.Appender.RollingFileAppender">
<param name="File" value="Log\\LogErrorEx\\" />
<param name="AppendToFile" value="true" />
<param name="MaxFileSize" value="10240" />
<param name="MaxSizeRollBackups" value="100" />
<param name="StaticLogFileName" value="false" />
<param name="DatePattern" value="yyyy\\yyyyMM\\yyyyMMdd'.txt'" />
<param name="RollingStyle" value="Date" />
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%newline %n记录时间：%date %n线程ID:[%thread] %n日志级别： %-5level %n日志描述：%message%newline %n" />
</layout>
</appender>
<!--CustomEx日志-->
<logger name="LogCustomEx">
<level value="INFO" />
<appender-ref ref="CustomExAppender" />
</logger>
<!--Error日志-->
<logger name="LogErrorEx">
<level value="ERROR" />
<appender-ref ref="ErrorExAppender" />
</logger>
<!--服务执行日志-->
<appender name="RollingLogFileAppender" type="log4net.Appender.RollingFileAppender">
<param name="File" value="Log\\ServerLog\\" />
<param name="AppendToFile" value="true" />
<param name="MaxFileSize" value="10240" />
<param name="MaxSizeRollBackups" value="100" />
<param name="StaticLogFileName" value="false" />
<param name="DatePattern" value="yyyy\\yyyyMM\\yyyyMMdd'.txt'" />
<param name="RollingStyle" value="Date" />
<layout type="log4net.Layout.PatternLayout">
<param name="ConversionPattern" value="%n%date{HH:mm:ss,fff} [%-5level] %m" />
</layout>
</appender>
<!-- 控制台前台显示日志 -->
<appender name="ColoredConsoleAppender" type="log4net.Appender.ColoredConsoleAppender">
<mapping>
<level value="ERROR" />
<foreColor value="Red, HighIntensity" />
</mapping>
<mapping>
<level value="Info" />
<foreColor value="Green" />
</mapping>
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%n%date{HH:mm:ss,fff} [%-5level] %m" />
</layout>
<filter type="log4net.Filter.LevelRangeFilter">
<param name="LevelMin" value="Info" />
<param name="LevelMax" value="Fatal" />
</filter>
</appender>
<root>
<!--(高) OFF > FATAL > ERROR > WARN > INFO > DEBUG > ALL (低) -->
<level value="all" />
<appender-ref ref="ColoredConsoleAppender" />
<appender-ref ref="RollingLogFileAppender" />
</root>
</log4net>
相关Job类
JobInfo对象(任务信息)，JobType类型
任务信息：名称、触发器、群组、类型（根据不一样的类型执行不一样的Job内容app
public class JobInfo
{
public JobInfo(string jobName, string group, string trigger, JobType jobType)
{
if (jobName == null || trigger == null || group == null)
{
throw new ArgumentNullException("jobName");
}
this.JobName = jobName;
this.Trigger = trigger;
this.Group = group;
this.JobType = jobType;
}
/// <summary>
/// 名称
/// </summary>
public string JobName { get; set; }
/// <summary>
/// Job的触发器 cron表达式
/// </summary>
public string Trigger { get; set; }
/// <summary>
/// 群组
/// </summary>
public string Group { get; set; }
/// <summary>
/// Job类型
/// </summary>
public JobType JobType { get; set; }
}
/// <summary>
/// Job类型枚举
/// </summary>
public enum JobType
{
/// <summary>
/// 任务1
/// </summary>
Job1 = 1,
/// <summary>
/// 任务2
/// </summary>
Job2 = 2
}
JobInfoList任务集合
模拟的任务集合，实际应用中可固定，可从数据库中获取框架
public class JobInfoList
{
/// <summary>
/// 脚本服务组
/// </summary>
public static List<JobInfo> JobList_ZhongShanHos = new List<JobInfo>
{
new JobInfo("任务1", "测试脚本", "*/5 * * * * ?", JobType.Job1),
new JobInfo("任务2", "测试脚本", "*/7 * * * * ?", JobType.Job2)
};
}
Job内容
配置具体的Job内容与须要输出的自定义日志，这里的日志使用log4net做为记录tcp
using System;
using Quartz;
namespace T5.Jobs
{
public class TestJob : IJob
{
private static readonly log4net.ILog LogInfo = log4net.LogManager.GetLogger("LogCustomEx");
private static readonly log4net.ILog LogError = log4net.LogManager.GetLogger("LogError");
public void Execute(IJobExecutionContext context)
{
var map = context.JobDetail.JobDataMap;
var jobInfo = map["KEY"] as JobInfo;
if (jobInfo == null) { return; }
//记录日志
LogInfo.Info("\n【服务已启动】" + "\n【启动组】：" + jobInfo.Group + "\n【启动名称】：" + jobInfo.JobName + "\n【启动时间】：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
try
{
switch (jobInfo.JobType)
{
//基础信息
case JobType.Job1: LogInfo.Info("这是任务1"); break;
case JobType.Job2: LogInfo.Info("这是任务2"); break;
default: break;
}
}
catch (Exception ex)
{
//记录日志
LogError.Error("\n【服务执行出错】" +
"\n【启动组】：" + jobInfo.Group +
"\n【启动名称】：" + jobInfo.JobName +
"\n【时间】：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") +
"\n【错误信息】：" + ex.Message);
return;
}
}
}
}
配置Job执行方法
using System.Collections.Generic;
using Quartz;
using Quartz.Impl;
using T5.Jobs;
using Topshelf;
namespace T5
{
public sealed class ServerRunner : ServiceControl, ServiceSuspend
{
private readonly IScheduler scheduler;
public ServerRunner()
{
scheduler = StdSchedulerFactory.GetDefaultScheduler();
}
public bool Start(HostControl hostControl)
{
var jobList = new List<JobInfo>();
//配置JobList任务
jobList.AddRange(JobInfoList.JobList_ZhongShanHos);
jobList.ForEach(
x =>
{
var dic = new Dictionary<string, JobInfo> { { "KEY", x } };
var map = new JobDataMap(dic);
var job =
JobBuilder.Create<TestJob>()
.WithIdentity(x.JobName, x.Group)
.UsingJobData(map)
.RequestRecovery()
.Build();
var trigger =
TriggerBuilder.Create()
.WithIdentity(x.JobName, x.Group)
.WithCronSchedule(x.Trigger)
.Build();
scheduler.ScheduleJob(job, trigger);
});
scheduler.Start();
return true;
}
public bool Stop(HostControl hostControl)
{
scheduler.Shutdown(false);
return true;
}
public bool Continue(HostControl hostControl)
{
scheduler.ResumeAll();
return true;
}
public bool Pause(HostControl hostControl)
{
scheduler.PauseAll();
return true;
}
}
}
配置入口文件
using Topshelf;
namespace T5
{
class Program
{
static void Main(string[] args)
{
//配置Log4日志
log4net.Config.XmlConfigurator.Configure();
//Windows服务
HostFactory.Run(x =>
{
x.UseLog4Net();
x.Service<ServerRunner>();
x.SetDescription("Quartz日志记录服务");
x.SetDisplayName("Quartz");
x.SetServiceName("QuartzLog");
x.EnablePauseAndContinue();
});
}
}
}
相关文章
- 1. Quartz+SignalR 总结
- 2. timer 与 quartz 总结
- 3. Quartz使用总结
- 4. Quartz学习总结
- 5. Spring Quartz与Spring Task总结
- 6. Quartz.NET总结（三）Quartz 配置
- 7. Quartz Spring与Spring Task总结
- 8. Quartz总结（一）：Quartz集成Spring的2个方法
- 9. Quartz.NET总结（四）Quartz 远程调度
- 10. Quartz定时器入门总结
- 更多相关文章...
- • Docker 资源汇总 - Docker教程
- • XML 总结 下一步学习什么呢？ - XML 教程
- • 算法总结-双指针
- • 算法总结-回溯法
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
欢迎关注本站公众号,获取更多信息
