【Quartz】常用方法的使用方式(三)

综合编程 2018-05-16

前言




总结了一下quartz组件的一些常用方法,以备将来不时之需。哈哈,看着挺简单有些好是值得笔记一下的。好记性不如烂笔头吗?

代码部分:

方法类内容:


 public class ExamplesGo
    {
        static ISchedulerFactory schedFact = new StdSchedulerFactory();
        public static IScheduler sched = schedFact.GetScheduler();

    }

View Code

任务触发器分离实现:


    #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

View Code

基本的暂停,恢复,删除:


   #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

View Code

最后一些复杂点的查询:


 #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

View Code

最后添加的两个一个关闭组件和修改触发器:


 #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

View Code
博客园精华区

责编内容by:博客园精华区 (源链)。感谢您的支持!

您可能感兴趣的

jeecg 定时任务 简述 定时任务模块是为了方便管理员更好地管理一些需要定时执行的任务,比如可能在某段时间需要周期性地执行发送提醒消息,但有可能又要临时控制这周期性任务的终止或重启,或者是需要立即执行任务。通常...
Spring整合Quartz分布式调度 前言 为了保证应用的高可用和高并发性,一般都会部署多个节点;对于定时任务,如果每个节点都执行自己的定时任务,一方面耗费了系统资源, 另一方面有些任务多次执行,可能引发应用逻辑...
Quartz数据库表分析 前言 上一篇文章 Spring整合Quartz分布式调度 介绍了Quartz通过数据库的方式来实现分布式调度,通过使用数据库来存储trigger,job等信息,可以在停服...
深入解读Quartz任务调度器 Quartz是OpenSymphony提供的强大的开源任务调度框架。 官网: www.quartz-scheduler.org 纯Java实现,精细控制排程。 1....
基于springboot和quartz的任务调度系统 一、简述 项目地址: https://github.com/littlechare/job-manager 项目详细的信息请参看项目的 README 下载地址...