原文: 
View Code View Code View Code View Code View Code
前言
总结了一下quartz组件的一些常用方法，以备将来不时之需。哈哈，看着挺简单有些好是值得笔记一下的。好记性不如烂笔头吗？
代码部分：
方法类内容：
public class ExamplesGo { static ISchedulerFactory schedFact = new StdSchedulerFactory(); public static IScheduler sched = schedFact.GetScheduler(); } 任务触发器分离实现：
#region 1.运行任务【所有】 ////// 运行任务 /// public void Run() { if (sched != null) sched.Start(); } #endregion #region 2.添加job ////// 添加job /// public void AddJob() { IJobDetail job = JobBuilder.Create() .WithIdentity("HelloJob", "group1") .StoreDurably() .Build(); sched.AddJob(job, true); } #endregion #region 3.添加触发器 /// /// 添加触发器 /// /// 需要添加触发器的job public void AddTrigger(IJobDetail job) { ITrigger trigger = TriggerBuilder.Create() .WithIdentity("myTrigger", "group1") .WithCronSchedule("0/5 * * * * ?") //5秒执行一次 .ForJob(job) .Build(); sched.ScheduleJob(trigger); } public void AddTrigger1(IJobDetail job) { ITrigger trigger = TriggerBuilder.Create() .WithIdentity("myTrigger2", "group1") .WithCronSchedule("0/1 * * * * ?") //5秒执行一次 .ForJob(job) .Build(); sched.ScheduleJob(trigger); } #endregion #region 4.根据key返回Job ////// 根据key返回Job /// /// 需要查找的job名称 ///public IJobDetail GetJob(string jobName) { JobKey jobKey = sched.GetJobKeys(GroupMatcher .AnyGroup()).ToList().Where(b => b.Name == jobName).FirstOrDefault(); return sched.GetJobDetail(jobKey); } #endregion
基本的暂停，恢复，删除：
#region 5.暂停任务[全部暂停] ////// 暂停任务 /// public void PauseAll() { if (sched != null) sched.PauseAll(); } #endregion #region 6.暂停任务【单个任务】 ////// 暂停任务 /// /// 需要暂停任务的名称 public void Shutdown(string jobName) { if (sched != null) { JobKey jobKey = sched.GetJobKeys(GroupMatcher.AnyGroup()).ToList().Where(b => b.Name == jobName).FirstOrDefault(); sched.PauseJob(jobKey); } } #endregion #region 7.恢复当前任务 /// /// 恢复当前任务 /// /// 需要恢复任务的名称 public void ResumeJob(string jobName) { if (sched != null) { JobKey jobKey = sched.GetJobKeys(GroupMatcher.AnyGroup()).ToList().Where(b => b.Name == jobName).FirstOrDefault(); sched.ResumeJob(jobKey); } } #endregion #region 8.恢复所有任务 /// /// 恢复所有任务 /// public void ResumeJobAll() { if (sched != null) { sched.ResumeAll(); } } #endregion #region 9.删除当前任务 ////// 删除当前任务 /// /// 删除任务名称 public void DeleteJob(string jobName) { if (sched != null) { JobKey jobKey = sched.GetJobKeys(GroupMatcher.AnyGroup()).ToList().Where(b => b.Name == jobName).FirstOrDefault(); sched.DeleteJob(jobKey); } } #endregion #region 10.删除所有任务 /// /// 删除所有任务 /// public void DeleteJobAll() { if (sched != null) { sched.Clear(); } } #endregion
最后一些复杂点的查询：
#region 11.返回所有任务键 ////// 返回所有任务键 /// ///public List GetJobAll() { //获取所有job List jobKeys = sched.GetJobKeys(GroupMatcher .AnyGroup()).ToList(); return jobKeys; } #endregion #region 12.返回所有的触发器 /// /// 返回所有的触发器 /// ///public List GetTrigAll() { List trigKeys = sched.GetTriggerKeys(GroupMatcher .AnyGroup()).ToList(); return trigKeys; } #endregion #region 13.返回job对应的trigger /// /// 返回job对应的trigger /// /// 任务名称 ///public List GetJobToTrig(string jobName) { JobKey jobKey = sched.GetJobKeys(GroupMatcher .AnyGroup()).ToList().Where(b => b.Name == jobName).FirstOrDefault(); List triggerList = sched.GetTriggersOfJob(jobKey).ToList(); return triggerList; } #endregion
最后添加的两个一个关闭组件和修改触发器：
#region 14.关闭所有任务 ////// 关闭所有任务 /// public void Shutdown() { if (sched != null) sched.Shutdown(); } #endregion #region 15.修改任务触发器 public void ModiyTrig() { ITrigger trigger = TriggerBuilder.Create() .WithIdentity("myTrigger", "group1") // .StartAt(runTime) .WithCronSchedule("0/10 * * * * ?") //10秒执行一次 .Build(); sched.RescheduleJob(trigger.Key, trigger); sched.Start(); } #endregion
posted on 2018-09-20 08:32 阅读( ...) 评论( ...)