您的位置:首页 > 编程语言 > Java开发

两种方式部署定时任务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】执行批量退款定时任务结束");
}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐