两种方式部署定时任务Spring整合Quartz、Spring整合Task(java后台)
2019-02-26 18:29
489 查看
##(Notice:以下所有经验也是我根据网上的经验整理的,如有侵权可以联系我删除,欢迎交流和沟通,Wx:IT_Ezra,QQ 654303408。 有问题讨论也可联系我。)
###(Tips:我是第一次开发,一个刚毕业的java工程师,我觉得我并非天赋异禀,我能学会,相信聪敏的你,一定可以)
(PS:定时任务是一个非常常见的功能,在我们进行系统开发中,经常会用到,有点类似于OS中的批处理。对于一些实时性不高的任务,比如退款,消息推送,会用到定时任务。)
首先需要使用的jar包:用maven在pom.xml中配置。版本有很多哦,自己可以去世界库找一个。
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.1</version> </dependency>
-
方式一(相对代码较多):通过XML文件配置。通过上下文配置逻辑清晰。流程清晰。通常情况下,我们的spring配置文件命名为applicationContext.xml,并且存放在resource文件夹下。我们不妨在resource文件夹下新建一个spring文件夹。这个文件夹可以专门去配置一些spring集成框架。与spring是同级的。(为什么不配置到springMVC,问这个问题的同学,可以去了解一下springMVC的原理。因为SpringMVC是一个servlet的框架,是作用于Web层,controller等等。而类似于quartz等框架是与SpringMVC平级的,是对定时任务进行管理,作用于Conponent,不属于附属关系。)然后新建一个XML文件 ,建议命名为:spring-scheduler.xml。
-
项目结构图如下
先上代码。提前说一点,每一个class对应的FactoryBean是对应的。一共有三个, 要么都用Bean,要么都用***FactoryBean。用混的情况下是会报错的。(曾经在eclipse没报错,但是在idea报错了)
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd"> <!-- 申明执行任务的类 --> <bean id="messageSendJob" class="com.dfs.job.MessageSendJob"></bean> <!-- 申请线程池 --> <bean id="schedulerExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <property name="corePoolSize" value="10" /> <property name="maxPoolSize" value="100" /> <property name="queueCapacity" value="500" /> </bean> <!-- 调度业务 --> <bean id="messageSendJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="messageSendJob" /> <property name="targetMethod" value="message" /> </bean> <!-- 触发器 --> <bean id="messageSendCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="messageSendJobDetail" /> <property name="cronExpression" value="* 0/20 * * * ?" /> </bean> <!-- 设置调度 --> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref bean="messageSendCronTrigger" /> </list> </property> <property name="taskExecutor" ref="schedulerExecutor" /> </bean> </beans>
-
该部分是spring-scheduler.xml配置文件的内容。层级关系也十分明显,配置内容也很简单。其中要介绍的就是cron表达式,可以自行百度。corn从左到右(用空格隔开):* * * * * ? * 通常情况下只使用六位,也就是 * * * * * ? 。最后一位用“?” , 下面有解释
-
秒 分 小时 月份中的日期 月份 星期中的日期 年份
-
字段 允许值 允许的特殊字符
-
秒(Seconds) 0~59的整数 , - * / 四个字符
-
分(Minutes) 0~59的整数 , - * / 四个字符
-
小时(Hours) 0~23的整数 , - * / 四个字符
-
日期(DayofMonth) 1~31的整数(但是你需要考虑你月的天数) ,- * ? / L W C 八个字符
-
月份(Month) 1~12的整数或者 JAN-DEC , - * / 四个字符
-
星期(DayofWeek) 1~7的整数或者 SUN-SAT (1=SUN) , - * ? / L C # 八个字符
-
年(可选,留空)(Year) 1970~2099 , - * / 四个字符
-
(1)* :表示匹配该域的任意值。假如在Minutes域使用*, 即表示每分钟都会触发事件。
-
(2)? :只能用在DayofMonth和DayofWeek两个域。它也匹配域的任意值,但实际不会。因为- ####DayofMonth和DayofWeek会相互影响。例如想在每月的20日触发调度,不管20日到底是星期几,则只能使用如下写法: 13 13 15 20 * ?, 其中最后一位只能用?,而不能使用*,如果使用*表示不管星期几都会触发,实际上并不是这样。
-
(3)- :表示范围。例如在Minutes域使用5-20,表示从5分到20分钟每分钟触发一次
-
(4)/ :表示起始时间开始触发,然后每隔固定时间触发一次。例如在Minutes域使用5/20,则意味着5分钟触发一次,而25,45等分别触发一次.
-
(5), :表示列出枚举值。例如:在Minutes域使用5,20,则意味着在5和20分每分钟触发一次。
-
(6)L :表示最后,只能出现在DayofWeek和DayofMonth域。如果在DayofWeek域使用5L,意味着在最后的一个星期四触发。
-
(7)W :表示有效工作日(周一到周五),只能出现在DayofMonth域,系统将在离指定日期的最近的有效工作日触发事件。例如:在 DayofMonth使用5W,如果5日是星期六,则将在最近的工作日:星期五,即4日触发。如果5日是星期天,则在6日(周一)触发;如果5日在星期一到星期五中的一天,则就在5日触发。另外一点,W的最近寻找不会跨过月份 。
-
(8)LW :这两个字符可以连用,表示在某个月最后一个工作日,即最后一个星期五。
-
(9)# :用于确定每个月第几个星期几,只能出现在DayofMonth域。例如在4#2,表示某月的第二个星期三。
其次一个需要介绍的就是具体的调度任务,也就是如下代码块
<!-- 调度业务 --> <bean id="messageSendJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject" ref="messageSendJob" /> <property name="targetMethod" value="message" /> </bean>
bean的id自己命名,property中name自己命名。而ref中的调度业务。 我的调度业务如下
package com.dfs.job; /** * @ author ezra * @ date 2019/2/18 15:56 */ import com.dfs.service.SenseAgroMessageService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; /** * 消息推送定时任务 * @author zjj * @date 2019-02-13 */ @Component public class MessageSendJob { private static final Logger logger = LoggerFactory.getLogger(MessageSendJob.class); /** * 每隔5分钟查询一次是否有消息 */ @Autowired private SenseAgroMessageService senseAgroMessageService; public void message() { logger.info("【begin】执行批量消息推送定时任务"); // 执行批量消息推送操作 senseAgroMessageService.messageAll(); logger.info("【end】执行批量消息推送定时任务"); } /** * 每隔一星期设置无效form(暂时不实现) */ /* public void templete() { logger.info("【begin】执行批量formid失效删除定时任务"); // 为了防止定时任务多线程并行执行时出现退款多次的情况,对过程加上互斥锁保证该任务串行执行 // 如果后期应用改为多机部署,需要将此处改为分布式锁或者由分布式任务调度系统协调串行执行 synchronized (OrderRefundJob.class) { // 执行批量退款操作 senseAgroMessageService.templateDelete(); } logger.info("【end】执行批量formid失效删除定时任务"); } */ }
完成以上操作之后,基本上定时任务已经配置完成。接下来最后一步,是通过web.xml去加载,应该每个人都知道applicationContext.xml的加载吧,在后面添加classpath:spring/spring-scheduler.xml即可。
<!-- 获取requst respose对象--> <listener> <listener-class> org.springframework.web.context.request.RequestContextListener </listener-class> </listener> <!-- 利用Spring提供的ContextLoaderListener监听器去监听ServletContext对象的创建,并初始化WebApplicationContext对象 --> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> <!-- Context Configuration locations for Spring XML files(默认查找/WEB-INF/applicationContext.xml) --> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:applicationContext.xml,classpath:spring/spring-scheduler.xml</param-value> </context-param>
方法二,非常暴力,在application里面扫描添加扫描项task:annotation-driven/
通过注解完成。@Scheduled 后面接cron表达式。相当于集成spring-task
@Component public class OrderRefundJob { private static final Logger logger = LoggerFactory.getLogger(OrderRefundJob.class); @Autowired private SenseAgroRefundService senseAgroRefundService; @Scheduled(cron = "* 0/5 * * * ?") public void refund() { logger.info("【begin】执行批量退款定时任务开始"); // 执行批量退款操作 senseAgroRefundService.refundAll(); logger.info("【end】执行批量退款定时任务结束"); } }
相关文章推荐
- spring实现定时任务的两种方式之Spring 3整合Quartz 2实现定时任务
- spring boot 集成quartz 2.0 实现前端动态配置(获取spring上下文)的两种方式,启动数据库中已开启定时任务
- spring集成定时任务框架 Quartz的两种方式
- spring boot 集成quartz 2.0 实现前端动态配置(获取spring上下文)的两种方式,启动数据库中已开启定时任务
- 最流行的java后台框架spring quartz定时任务
- JAVA定时任务之Spring与Quartz整合
- Spring中使用quartz执行定时任务的两种方式
- SpringBoot定时任务两种(Spring Schedule 与 Quartz 整合 )实现方法
- Spring中使用quartz执行定时任务的两种方式
- 最流行的java后台框架spring quartz定时任务
- SpringMVC整合Quartz实现定时任务和Spring自带Task定时任务
- 两种方式实现java定时器,使用quartz定时器框架和java自带Timer定时器,编写定时任务
- springboot动态配置定时任务2种方式,整合Quartz多线程并发执行多个定时任务配置
- SpringBoot之旅 -- 定时任务两种(Spring Schedule 与 Quartz 整合 )实现
- spring和quartz整合实现定时任务(配置文件配置方式
- SpringBoot的定时任务两种(Spring Schedule 与 Quartz 整合 )实现
- 结合Spring使用Quartz编写定时任务两种方式
- SpringMVC整合Quartz实现定时任务和Spring自带Task定时任务
- SpringBoot之旅 -- 定时任务两种(Spring Schedule 与 Quartz 整合 )实现
- SpringBoot之旅 -- 定时任务两种(Spring Schedule 与 Quartz 整合 )实现