两种方式部署定时任务,Spring整合Quartz,Spring整合task(java后台)

(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。

项目结构图如下

image.png

先上代码。提前说一点,每一个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.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.job;

/**
 * @ author ezra
 * @ date 2019/2/18 15:56
 */

import com.service.MessageService;
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 MessageService MessageService;

    public void message() {
        logger.info("【begin】执行批量消息推送定时任务");
            // 执行批量消息推送操作
            MessageService.messageAll();
        logger.info("【end】执行批量消息推送定时任务");
    }


    /**
     * 每隔一星期设置无效form(暂时不实现)
     */
/*
    public void templete() {
        logger.info("【begin】执行批量formid失效删除定时任务");
        // 为了防止定时任务多线程并行执行时出现退款多次的情况,对过程加上互斥锁保证该任务串行执行
        // 如果后期应用改为多机部署,需要将此处改为分布式锁或者由分布式任务调度系统协调串行执行
        synchronized (OrderRefundJob.class) {
            // 执行批量退款操作
            MessageService.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 RefundService RefundService;


    @Scheduled(cron = "* 0/5 *  * * ?")
    public void refund() {
        logger.info("【begin】执行批量退款定时任务开始");
        // 执行批量退款操作
        RefundService.refundAll();
        logger.info("【end】执行批量退款定时任务结束");
    }

}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,444评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,421评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,036评论 0 349
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,363评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,460评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,502评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,511评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,280评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,736评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,014评论 2 328
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,190评论 1 342
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,848评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,531评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,159评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,411评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,067评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,078评论 2 352