Quartz 實(shí)現(xiàn)定時(shí)任務(wù)調(diào)度

1.需求

  • 生日祝福短信
  • 信用卡催還款
  • 郵箱生日祝福
  • ….

2.什么是Quartz

Quartz是一個(gè)開源的作業(yè)調(diào)用框架,完全由Java編寫,可用于J2SE和J2EE應(yīng)用。它提供了巨大的靈活性而不犧牲簡(jiǎn)單性??梢詾閳?zhí)行一個(gè)作業(yè)而創(chuàng)建簡(jiǎn)單或復(fù)雜的調(diào)度。

3.快速入門

Maven坐標(biāo)

<dependency>
  <groupId>org.quartz-scheduler</groupId>
  <artifactId>quartz</artifactId>
  <version>2.2.1</version>
</dependency>

核心類:

Job:自定義

? 在類編寫需要執(zhí)行的內(nèi)容。類名與回調(diào)函數(shù)名都可以自定義。

JobDetail:MethodInvokingJobDetailFactoryBean

? 定義調(diào)用哪個(gè)任務(wù)的哪個(gè)方法

Trigger:CronTriggerFactoryBean

? 代表一個(gè)調(diào)度參數(shù)的配置

Scheduler:SchedulerFactoryBean

? 程序的入口。代表一個(gè)調(diào)度容器,其中可以注冊(cè)多個(gè)JobDetail和Trigger。當(dāng)兩者組合,就可以被Scheduler容器調(diào)度了。

配置:以Spring環(huán)境為例

<!-- 1 定義一個(gè)任務(wù)類 :job-->
    <bean id="jobBean" class="cn.itcast.jx.quartz.JobTest"></bean>
    <!-- 2 任務(wù)類描述 -->
    <bean id="jobDetails" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <!-- 定義目標(biāo)對(duì)象 -->
        <property name="targetObject" ref="jobBean"></property>
        <!-- 定義目標(biāo)方法 -->
        <property name="targetMethod" value="execute"></property>
    </bean>
    <!-- 3 觸發(fā)器  -->
    <bean id="jobTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <!-- 執(zhí)行哪個(gè)任務(wù) -->
        <property name="jobDetail" ref="jobDetails"></property>
        <!-- 定義何時(shí)執(zhí)行execute方法。注意:value為cron表達(dá)式,下述意為每10秒執(zhí)行一次 -->
        <property name="cronExpression" value="0/10 * * * * ?"></property>
    </bean>
    <!-- 4 總調(diào)度容器:Quartz執(zhí)行的入口 -->
    <bean id="startQuartz" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" >
        <property name="triggers">
            <list>
                <ref bean="jobTrigger"/>
                <!-- 配置多個(gè)觸發(fā)器 -->
            </list>
        </property>
    </bean>
  • 如果有多個(gè)任務(wù)類,則配置多個(gè)jobBean,jobDetails及jobTrigger,并在調(diào)度容器中依次使用<ref>標(biāo)簽進(jìn)行配置。

簡(jiǎn)單實(shí)現(xiàn):Job自定義任務(wù)類

public class JobTest {
    public void execute(){
        System.out.println("執(zhí)行了調(diào)度:"+new Date());
    }
}

關(guān)于CRON表達(dá)式

從左至右,支持 秒分時(shí)日月周年 七個(gè)域,域之間由空格分開

具體使用介紹可參見(jiàn):http://www.cnblogs.com/junrong624/p/4239517.html

4.應(yīng)用案例:

需求:對(duì)當(dāng)天船期到期的廠家發(fā)送提醒郵件

package cn.itcast.jx.quartz;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import cn.itcast.jx.domain.Contract;
import cn.itcast.jx.service.ContractService;
import cn.itcast.jx.util.MailUtil;
public class ShipTimeJob {
    private ContractService contractService;
    public void setContractService(ContractService contractService) {
        this.contractService = contractService;
    }
    //發(fā)送電子郵件
    public void sendMail(){
        //1 查詢今天船期到期的訂單
        //寫法一
        //String hql = "from Contract where to_char(shipTime,'yyyy-mm-dd') = to_char(sysdate,'yyyy-mm-dd')";
        //List<Contract> list = contractService.find(hql, Contract.class, null);
        //寫法二:注意SimpleDateFormat中有大小寫區(qū)分,MM代表月,mm代表分鐘
        String time =new SimpleDateFormat("yyyy-MM-dd").format(new Date()); 
        String hql = "from Contract where to_char(shipTime,'yyyy-mm-dd')=?";
        List<Contract> list = contractService.find(hql, Contract.class, new String[]{time});
        //2 遍歷到期訂單,給廠家發(fā)送電子郵件
        for(final Contract c:list){
            new Thread(new Runnable() {         
                @Override
                public void run() {
                    try {
                        MailUtil.sendMail("xxxx@qq.com", "本日船期到期貨物提醒", "你的合同為"+c.getContractNo()+"的這批貨今日需要出貨");
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }
    }   
}
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容