Quartz在.NET中怎么使用
导读:本文共3867字符,通常情况下阅读需要13分钟。同时您也可以点击右侧朗读,来听本文内容。按键盘←(左) →(右) 方向键可以翻页。
摘要: 一、背景例如需要在某年某月去将数据库的某个数据更新或者同步,又或者是每隔一段时间来执行一部分代码去调用接口,但是又不想人为的手动去执行针对此类业务可以使用"定时调用任务",市面上有很多的定时调度任务框架,甚至你可以使用定时器来结合Windows服务做一个简易版的任务调度程序,此处我们学习Quartz,因为Quartz是一个强大、开源、轻量级的... ...
目录
(为您整理了一些要点),点击可以直达。一、背景
例如需要在某年某月去将数据库的某个数据更新或者同步,又或者是每隔一段时间来执行一部分代码去调用接口,但是又不想人为的手动去执行
针对此类业务可以使用"定时调用任务",市面上有很多的定时调度任务框架,甚至你可以使用定时器来结合Windows服务做一个简易版的任务调度程序,此处我们学习Quartz,因为Quartz是一个强大、开源、轻量级的任务调度框架,支持cron-like表达式其他一些优秀的特性。
二、Quartz
1.基本概念
2.初步使用
1.Nuget引入QuartZ程序集
2.创建一个Scheduler任务调度容器
3.指定具体执行的任务Job和触发器
4.把策略和任务放入到Scheduler并启动
publicclassQuartzManager{publicasyncstaticvoidInit(){StdSchedulerFactoryfactory=newStdSchedulerFactory();//创建一个Scheduler任务调度容器ISchedulerscheduler=awaitfactory.GetScheduler();//指定具体执行的任务JobIJobDetailsendEmailJob=JobBuilder.Create<SendMailJob>().WithIdentity("sendEmailJob","sendEmailJobGrop").WithDescription("定时发送邮件").Build();//设置触发条件为五秒执行一次ITriggersendEmailTrigger=TriggerBuilder.Create().WithIdentity("sendEmailTrigger","sendEmailJobGrop".WithDescription("QuartZ").WithCronSchedule("3/5****?").Build();//把策略和任务放入到Schedulerawaitscheduler.ScheduleJob(sendEmailJob,sendEmailTrigger);//执行任务awaitscheduler.Start();}}//增加特性保证任务不会重叠执行[DisallowConcurrentExecution]publicclassSendMailJob:IJob{//Job类publicasyncTaskExecute(IJobExecutionContextcontext){awaitTask.Run(()=>{//doSomthingConsole.WriteLine($"开始发送邮件{DateTime.Now}");});}}
三、传递参数
有时候我们想在Job执行时需要一些参数,并根据这些参数来做一些逻辑处理,这时候就需要使用Quartz传参了。
在Quartz中传参主要有一些几种方式
1.job传参
2.Trigger传参
1.job传参和Trigger传参
使用JobDataMap.Add添加参数,在job内部使用上下文的JobDataMap.GetString获取
IJobDetailsendEmailJob=JobBuilder.Create<SendMailJob>().Build();//往Job传一个参数sendEmailJob.JobDataMap.Add("params","job测试传参");ITriggertrigger=TriggerBuilder.Create().Build();//往trigger传一个参数trigger.JobDataMap.Add("params","trigger测试传参");//在job中获取参数publicasyncTaskExecute(IJobExecutionContextcontext){awaitTask.Run(()=>{//获取job传参stringparamJob=context.JobDetail.JobDataMap.GetString("params");//获取Trigger传参stringparamTrigger=context.Trigger.JobDataMap.GetString("params");//doSomthingConsole.WriteLine($"开始发送邮件{DateTime.Now}");});}
四、在scheduler中注册监听器
监听器是为调度程序中发生的事件执行操作而创建的对象,主要有一下三种监听器
1.调度监听器ISchedulerListener主要用于调度过程的监听。
2.触发器监听器ITriggerListener主要用于接收和触发器相关的事件监听。
3.作业监听器IJobListener用于接收Job运行生命周期相关事件监听。
1.实现监听器
以作业监听器为例,因为触发和调度监听一样的实现。
1.自定义作业监听器需要继承自IJobListener接口并实现方法.
2.在调度器的监听管理中添加自定义监听器.
//实现监听器publicclassCustomJobListener:IJobListener{publicstringName=>"CustomJobListener";}//添加到监听管理中scheduler.ListenerManager.AddJobListener(newCustomJobListener());
五、可视化管理界面
用于可视化工具来查看当前运行Job的信息。
1.需要新建一个web项目或者控制台项目。
2.在web项目中 Nuget 引入Quartz 和CrystalQuartz.Remote程序包
3.在Job调度中配置StdSchedulerFactory相关信息指定监听端口
varproperties=newNameValueCollection();properties["quartz.scheduler.instanceName"]="TestMonitorSystem";//设置线程池properties["quartz.threadPool.type"]="Quartz.Simpl.SimpleThreadPool,Quartz";properties["quartz.threadPool.threadCount"]="5";properties["quartz.threadPool.threadPriority"]="Normal";//远程输出配置properties["quartz.scheduler.exporter.type"]="Quartz.Simpl.RemotingSchedulerExporter,Quartz";properties["quartz.scheduler.exporter.port"]="8081";properties["quartz.scheduler.exporter.bindName"]="QuartzScheduler";properties["quartz.scheduler.exporter.channelType"]="tcp";varschedulerFactory=newStdSchedulerFactory(properties);IScheduler_scheduler=awaitschedulerFactory.GetScheduler();
4.web监控端去访问统一的端口号下的CrystalQuartzPanel.axd即可查看。
六、配置文件配置任务
我们除了在代码中定义任务的各种调度和触发器之外,还可以使用xml配置文件的方式来创建Job任务
1.准备配置文件,配置Job+trigger相关信息,一定要将此文件属性设为"始终复制"
<?xmlversion="1.0"encoding="UTF-8"?><job-scheduling-dataxmlns="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><name>sendEmailJob</name><group>TestMailJob</group><description>ThisisTestMailJob</description><!--此处为Job所在的类,及程序集--><job-type>DispatcherProject.Job.SendMailJob,DispatcherProject</job-type><durable>true</durable><recover>false</recover></job><trigger><cron><name>sendEmailTrigger</name><group>sendEmailJobGrop</group><job-name>sendEmailJob</job-name><job-group>TestMailJob</job-group><cron-expression>5/3****?</cron-expression></cron></trigger></schedule></job-scheduling-data>
2.读取配置文件,获取信息,生成对应的Job和Trigger
XMLSchedulingDataProcessorprocessor=newXMLSchedulingDataProcessor(newSimpleTypeLoadHelper());//读取配置文件awaitprocessor.ProcessFileAndScheduleJobs("~/config/quartz.xml",scheduler);//启动调度任务awaitscheduler.Start();
</div> <div class="zixun-tj-product adv-bottom"></div> </div> </div> <div class="prve-next-news">
Quartz在.NET中怎么使用的详细内容,希望对您有所帮助,信息来源于网络。