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

1.需求

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

2.什么是Quartz

Quartz是一個開源的作業(yè)調(diào)用框架,完全由Java編寫,可用于J2SE和J2EE應(yīng)用。它提供了巨大的靈活性而不犧牲簡單性??梢詾閳?zhí)行一個作業(yè)而創(chuàng)建簡單或復(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)用哪個任務(wù)的哪個方法

Trigger:CronTriggerFactoryBean

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

Scheduler:SchedulerFactoryBean

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

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

<!-- 1 定義一個任務(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)對象 -->
        <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í)行哪個任務(wù) -->
        <property name="jobDetail" ref="jobDetails"></property>
        <!-- 定義何時執(zhí)行execute方法。注意:value為cron表達式,下述意為每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"/>
                <!-- 配置多個觸發(fā)器 -->
            </list>
        </property>
    </bean>
  • 如果有多個任務(wù)類,則配置多個jobBean,jobDetails及jobTrigger,并在調(diào)度容器中依次使用<ref>標(biāo)簽進行配置。

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

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

關(guān)于CRON表達式

從左至右,支持 秒分時日月周年 七個域,域之間由空格分開

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

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

需求:對當(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)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

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

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