spring+quartz新增,删除,暂停,恢复定时任务

一时失言乱红尘 2021-09-15 08:34 364阅读 0赞

spring配置

\[html\]  [view plain][]  [copy][view plain]

1.  **<****bean** id="scheduler"  
2.          class="org.springframework.scheduling.quartz.SchedulerFactoryBean"**>**  
3.        
4.  **</****bean****>**

先定义SchedulerJob  javabean

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **class** ScheduleJob \{  
2.      **private** String jobId;//任务id  
3.      **private** String jobName;//任务名称  
4.      **private** String jobGroup;//任务分组  
5.      **private** **int** jobStatus;//任务状态 0禁用 1启用 2删除  
6.      **private** String cronExpression;//任务运行时间表达式  
7.      **private** String jobDesc;//任务描述  
8.      **public** String getJobId() \{  
9.          **return** jobId;  
10.     \}  
11.     **public** **void** setJobId(String jobId) \{  
12.         **this**.jobId = jobId;  
13.     \}  
14.     **public** String getJobName() \{  
15.         **return** jobName;  
16.     \}  
17.     **public** **void** setJobName(String jobName) \{  
18.         **this**.jobName = jobName;  
19.     \}  
20.     **public** String getJobGroup() \{  
21.         **return** jobGroup;  
22.     \}  
23.     **public** **void** setJobGroup(String jobGroup) \{  
24.         **this**.jobGroup = jobGroup;  
25.     \}  
26.       
27.     **public** **int** getJobStatus() \{  
28.         **return** jobStatus;  
29.     \}  
30.     **public** **void** setJobStatus(**int** jobStatus) \{  
31.         **this**.jobStatus = jobStatus;  
32.     \}  
33.     **public** String getCronExpression() \{  
34.         **return** cronExpression;  
35.     \}  
36.     **public** **void** setCronExpression(String cronExpression) \{  
37.         **this**.cronExpression = cronExpression;  
38.     \}  
39.     **public** String getJobDesc() \{  
40.         **return** jobDesc;  
41.     \}  
42.     **public** **void** setJobDesc(String jobDesc) \{  
43.         **this**.jobDesc = jobDesc;  
44.     \}  
45. \}

定时器JOB管理类

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **class** JobManage \{  
2.      **private** **static** **final** Logger logger = LoggerFactory.getActionLog(JobManage.**class**);  
3.      **private** TimedTaskService timedTaskService;  
4.        
5.      **public** TimedTaskService getTimedTaskService() \{  
6.          **return** timedTaskService;  
7.      \}  
8.      **public** **void** setTimedTaskService(TimedTaskService timedTaskService) \{  
9.          **this**.timedTaskService = timedTaskService;  
10.     \}  
11.     **private** **static** SchedulerFactoryBean schedulerFactoryBean;  
12.     **private** **static** Scheduler scheduler;  
13.     **static**\{  
14.         schedulerFactoryBean = (SchedulerFactoryBean) BeanUtil.getBeanByClass(SchedulerFactoryBean.**class**);  
15.         scheduler = schedulerFactoryBean.getScheduler();  
16.     \}  
17.     /\*\* 
18.      \* 初始化定时任务 
19.      \* @throws SchedulerException 
20.      \*/  
21.     **public** **void** initTask() **throws** SchedulerException \{  
22.         //Scheduler scheduler = schedulerFactoryBean.getScheduler();  
23.         // 这里获取任务信息数据  
24.         List<ScheduleJob> jobList = timedTaskService.getAllJob();//从数据库中读取  
25.         **for** (ScheduleJob job : jobList) \{  
26.             addJob(job);  
27.         \}  
28.     \}  
29.     /\*\* 
30.      \* 添加一个任务 
31.      \* @param job 
32.      \*/  
33.     **public** **void** addJob(ScheduleJob job)\{  
34.         **try** \{  
35.             TriggerKey triggerKey = TriggerKey.triggerKey(job.getJobName(), job.getJobGroup());  
36.             // 获取trigger，即在spring配置文件中定义的 bean id="myTrigger"  
37.             CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);  
38.             // 不存在，创建一个  
39.             **if** (**null** == trigger) \{  
40.                 JobDetail jobDetail = JobBuilder.newJob(QuartzJobFactory.**class**)  
41.                         .withIdentity(job.getJobName(), job.getJobGroup()).build();  
42.                 jobDetail.getJobDataMap().put("scheduleJob", job);  
43.                 // 表达式调度构建器  
44.                 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());  
45.                 // 按新的cronExpression表达式构建一个新的trigger  
46.                 trigger = TriggerBuilder.newTrigger().withIdentity(job.getJobName(), job.getJobGroup())  
47.                         .withSchedule(scheduleBuilder).build();  
48.                 scheduler.scheduleJob(jobDetail, trigger);  
49.             \} **else** \{  
50.                 // Trigger已存在，那么更新相应的定时设置  
51.                 // 表达式调度构建器  
52.                 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());  
53.                 // 按新的cronExpression表达式重新构建trigger  
54.                 trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();  
55.                 // 按新的trigger重新设置job执行  
56.                 scheduler.rescheduleJob(triggerKey, trigger);  
57.             \}  
58.             **if**(job.getJobStatus()==0)\{  
59.                 pauseJob(job);  
60.             \}  
61.               
62.         \} **catch** (SchedulerException e) \{  
63.             // TODO Auto-generated catch block  
64.             e.printStackTrace();  
65.         \}  
66.     \}  
67.     /\*\* 
68.      \* 暂停一个job 
69.      \* @param scheduleJob 
70.      \* @throws SchedulerException 
71.      \*/  
72.     **public** **void** pauseJob(ScheduleJob scheduleJob)\{  
73.         //Scheduler scheduler = schedulerFactoryBean.getScheduler();  
74.         logger.info(scheduleJob.getJobName(),"定时任务暂停");  
75.         JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());  
76.         **try** \{  
77.             scheduler.pauseJob(jobKey);  
78.         \} **catch** (SchedulerException e) \{  
79.             // TODO Auto-generated catch block  
80.             e.printStackTrace();  
81.         \}  
82.     \}  
83.     /\*\* 
84.      \* 恢复一个job 
85.      \* @param scheduleJob 
86.      \*/  
87.     **public** **void** resumeJob(ScheduleJob scheduleJob)\{  
88.         logger.info(scheduleJob.getJobName(),"定时任务启动");  
89.         //Scheduler scheduler = schedulerFactoryBean.getScheduler();  
90.         JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(),scheduleJob.getJobGroup());  
91.         **try** \{  
92.             scheduler.resumeJob(jobKey);  
93.         \} **catch** (SchedulerException e) \{  
94.             // TODO Auto-generated catch block  
95.             e.printStackTrace();  
96.         \}  
97.     \}  
98.     /\*\* 
99.      \* 删除一个任务 
100.      \* @param scheduleJob 
101.      \*/  
102.     **public** **void** removeJob(ScheduleJob job)\{  
103.         logger.info(job.getJobName(),"删除定时任务");  
104.         TriggerKey triggerKey = TriggerKey.triggerKey(job.getJobName(), job.getJobGroup());  
105.         JobKey jobKey = JobKey.jobKey(job.getJobName(),job.getJobGroup());  
106.         // 获取trigger，即在spring配置文件中定义的 bean id="myTrigger"  
107.         //CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);  
108.         **try** \{  
109.             scheduler.pauseTrigger(triggerKey);  
110.             scheduler.unscheduleJob(triggerKey);  
111.             scheduler.deleteJob(jobKey);  
112.         \} **catch** (SchedulerException e) \{  
113.             // TODO Auto-generated catch block  
114.             e.printStackTrace();  
115.         \}  
116.     \}  
117. \}

job工厂类

\[java\]  [view plain][]  [copy][view plain]

1.  @DisallowConcurrentExecution //只有上一个人任务执行完毕才可以执行下一次任务  
2.  **public** **class** QuartzJobFactory **implements** Job\{  
3.      **private** **static** **final** Logger logger = LoggerFactory.getActionLog(QuartzJobFactory.**class**);  
4.      @Override  
5.      **public** **void** execute(JobExecutionContext context)\{  
6.          // TODO Auto-generated method stub  
7.          **try**\{  
8.              ScheduleJob scheduleJob = (ScheduleJob)context.getMergedJobDataMap().get("scheduleJob");  
9.              logger.info(scheduleJob.getJobName(),"任务开始");  
10.             ((TaskService) BeanUtil.getBean(scheduleJob.getJobName())).exe();  
11.             logger.info(scheduleJob.getJobName(),"任务结束");  
12.         \}**catch**(Exception e)\{  
13.             e.printStackTrace();  
14.         \}  
15.         //logger.info("任务结束", scheduleJob.getJobName());  
16.     \}  
17.   
18. \}

具体业务接口

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **interface** TaskService \{  
2.      /\*\* 
3.       \* 具体业务逻辑 
4.       \*/  
5.      **public** **abstract** **void** exe();  
6.  \}

实现上面的接口,在spring配置bean

\[html\]  [view plain][]  [copy][view plain]

1.  **<****bean** id="test" class="com.cmos.ccscore.service.timedTask.impl.Test" parent="baseService"**>**  
2.   **</****bean****>**

在数据库中插入记录.

spring获取bean工具类

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **class** BeanUtil **implements** ApplicationContextAware\{  
2.      **private** **static** ApplicationContext context;  
3.        
4.      @Override  
5.      **public** **void** setApplicationContext(ApplicationContext arg0) **throws** BeansException \{  
6.          // TODO Auto-generated method stub  
7.          context = arg0;  
8.      \}  
9.      **public** **static** Object getBean(String beanName)\{  
10.         **return** context.getBean(beanName);  
11.     \}  
12.     **public** **static** <T> Object getBeanByClass(Class<T> c)\{  
13.         **return** context.getBean(c);  
14.     \}  
15. \}

监听器用于服务启动初始化定时任务

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **class** TaskListener **implements** ServletContextListener\{  
2.      **private** **static** **final** Logger logger = LoggerFactory.getActionLog(TaskListener.**class**);  
3.      @Override  
4.      **public** **void** contextDestroyed(ServletContextEvent arg0) \{  
5.          // TODO Auto-generated method stub  
6.      \}  
7.    
8.      @Override  
9.      **public** **void** contextInitialized(ServletContextEvent arg0) \{  
10.   
11.         logger.info("TaskListener", "定时任务初始化");  
12.         JobManage m = (JobManage) BeanUtil.getBean("jobManage");  
13.         **try** \{  
14.             m.initTask();  
15.         \} **catch** (SchedulerException e) \{  
16.             // TODO Auto-generated catch block  
17.             e.printStackTrace();  
18.         \}  
19.     \}  
20.   
21. \}

\[java\]  [view plain][]  [copy][view plain]

1.  TimedTaskService 定时任务服务类就是获取前端请求对数据库的操作,需注入JobManage类来对定时任务进行管理

最终页面效果

![Center][]

[view plain]: https://blog.csdn.net/a3781386/article/details/51470013#
[Center]: /images/20210527/4e5a0842d626448c8c08c3b3b694690f.png