spring中定時任務的多種實現

本文主要是記錄工作中所遇到的情況，並非教學！！！ 

一、通過spring自帶的@Scheduled注解實現定時任務

1.更改ApplicationContext-mvc.xml/spring.xml 等配置文件，如果不知道自己應該配置哪個文件的話去web.xml中找到<servlet>標簽中的配置文件去配置就行（因為我試過配置在<context-param>標簽下的ApplicationContext.xml里面會報錯）

文件中需要更改的內容如下：

 

（1）xmlns:task="http://www.springframework.org/schema/task"

（2）xsi:schemaLocation中添加  （其中spring-task-3.1.xsd的版本可以更改看你的spring版本）具體參考下圖

 

 

 

http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-3.1.xsd

 

<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:aop="http://www.springframework.org/schema/aop"
 xmlns:mvc="http://www.springframework.org/schema/mvc"
 xmlns:task="http://www.springframework.org/schema/task"
 xsi:schemaLocation="http://www.springframework.org/schema/beans  8  http://www.springframework.org/schema/beans/spring-beans.xsd  9  http://www.springframework.org/schema/aop 10  http://www.springframework.org/schema/aop/spring-aop-4.0.xsd 11  http://www.springframework.org/schema/context 12  http://www.springframework.org/schema/context/spring-context.xsd 13  http://www.springframework.org/schema/mvc 14  http://www.springframework.org/schema/mvc/spring-mvc.xsd 15 http://www.springframework.org/schema/task 16 http://www.springframework.org/schema/task/spring-task-3.1.xsd">

（3）添加 task標簽設置 ，可以詳細配置也可以直接默認

多的部分是對與線程池的設置，配置線程池后如果多個定時任務同時執行也沒問題，不配置的話spring默認是單線程模式

<!--形式一-->
<task:executor id="executor" pool-size="5" />
<task:scheduler id="scheduler" pool-size="10" />
<task:annotation-driven executor="executor" scheduler="scheduler" />


<!--形式二-->
 <task:annotation-driven />

（4）不要忘記配置你要執行的自動化程序所在的包的路徑，將該包的路徑加入掃描(按照自身實際情況配置)

<context:component-scan base-package="com.project.*" />

2.創建你的定時任務程序

/**
 * @author 
 * @Time 2020-07-08 17:07  4  */
//必須添加注解交由spring管控才能生效
@Component  7 public class ScheduledDemo {  8     //由於將整個類交由spring管控不必擔心@Autowired注解失效的情況
 @Autowired 10     private TestService testService; 11 
    //有點缺點該注解只支持6位參數的cron表達式不支持7位的
    @Scheduled(cron = "0 0/1 * * * ? ") 14     public void aaa(){ 15         //實現你需要的方法即可
 testService.XXX(); 17         System.out.println("哈哈哈哈"); 18  } 19 
}    

 

二、通過quartz組件實現定時任務（有點問題按照網上的方法最后我也沒成功納入spring管理。。。）

1.通過官網下載quartz ,下載完成是下圖的壓縮包 解壓后相應目錄下有你需要的jar包，自行導入即可（其他的都是依賴jar包，最低情況只需要導入quartz自身的兩個jar就行）

 

 

 

配置一下日志打印（依賴於log4j組件）

  

 2.此處就不講quartz怎么使用了，結合網上的分享，這里提供一個工具類方便直接調用

/**
 * @author 
 * @Time 2020-07-06 17:00
 */
public class SchedulerUtil {
    private static Logger logger = Logger.getLogger(SchedulerUtil.class);// log4j記錄日志
    /**
     * [簡單任務調度:每次執行間隔為多少毫秒，執行多少次] <br>
     * @param jobName 任務名字
     * @param jobGroupName 任務組名字
     * @param triggerName 觸發器名字
     * @param triggerGroupName 觸發器組名字
     * @param jobClass 任務類
     * @param time 時間間隔
     * @param count 執行幾次<br>
     */
    public static void handleSimpleTrigger(String jobName, String jobGroupName,
                                           String triggerName, String triggerGroupName, Class jobClass,
                                           int time, int count) {28         // 通過schedulerFactory獲取一個調度器
        SchedulerFactory schedulerfactory = new StdSchedulerFactory();
        Scheduler scheduler = null;
        try {
            // 通過schedulerFactory獲取一個調度器
            scheduler = schedulerfactory.getScheduler();
            // 創建jobDetail實例，綁定Job實現類
            // 指明job的名稱，所在組的名稱，以及綁定job類
            JobDetail job = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();
            // 定義調度觸發規則
            //使用simpleTrigger規則
            Trigger trigger=TriggerBuilder.newTrigger().withIdentity(triggerName,triggerGroupName)
                    .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(time).withRepeatCount(count))
                    .build();
            // 把作業和觸發器注冊到任務調度中
            scheduler.scheduleJob(job, trigger);
            // 啟動調度
            scheduler.start();
        } catch (Exception e) {48             logger.error("執行"+jobName+"組"+jobName+"任務出現異常E:["+ e.getMessage() + "]");
        }
    }
    /**
     * [復雜任務調度：每天幾點幾分幾秒定時執行任務] <br>
     * @param jobName 任務名字
     * @param jobGroupName 任務組名字
     * @param triggerName 觸發器名字
     * @param triggerGroupName 觸發器組名字
     * @param jobClass 任務類
     * @param cron 觸發規則<br>
     */
    /**
     *
     *
     */
    public static void hadleCronTrigger(String jobName, String jobGroupName,
                                        String triggerName, String triggerGroupName, Class jobClass,String cron) {73         // 通過schedulerFactory獲取一個調度器
        SchedulerFactory schedulerfactory = new StdSchedulerFactory();
        Scheduler scheduler = null;
        try {
            // 通過schedulerFactory獲取一個調度器
            scheduler = schedulerfactory.getScheduler();
            // 創建jobDetail實例，綁定Job實現類
            // 指明job的名稱，所在組的名稱，以及綁定job類
            JobDetail job = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();
            // 定義調度觸發規則
            //使用cornTrigger規則  每天18點30分
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity(triggerName, triggerGroupName)
                    .withSchedule(CronScheduleBuilder.cronSchedule(cron))
                    .build();
            // 把作業和觸發器注冊到任務調度中
            scheduler.scheduleJob(job, trigger);
            // 啟動調度
            scheduler.start();
        } catch (Exception e) {93             logger.error("執行" + jobName + "組" + jobName + "任務出現異常E:[" + e.getMessage() + "]");
        }
    }
}

3.方式一  ：創建自己的job類，然后通過@PostConstruct注解在項目啟動后調用（配合第二條使用）

/**
 * @author 
 * @Time 2020-07-06 17:40
 */
@DisallowConcurrentExecution //不允許job並發執行，防止重復調用，只對於同一實例有效，不同jobDetails引用同一個job時不起作用
public class TPersonFollowUpJob implements Job {

    @Autowired
    private TestService testService;

    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {

//因為沒有被納入spring管理，所以這里通過這個方法實現調用spring管理的組件讓該頁面的@Autowired 注解生效   SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
        //自己要實現的方法
        testService.XXX();
        System.out.println("哈哈哈哈");
    }
}

下面是調用方法

//該注解保證了該方法可以在程序啟動后自動調用執行一次    
@PostConstruct
    public void start(){
        //這里使用我們前面定義好的工具類來調用我們的Job方法類，這里的cron表達式支持最多7位參數    
        SchedulerUtil.hadleCronTrigger("任務名字", "任務組名字","觸發器名字", "觸發器組名字", TPersonFollowUpJob.class,"0 0/1 * * * ? *");
    }

4.方式二  ：直接通過spring的xml配置完成（在web.xml的<context-param>標簽下的ApplicationContext.xml中進行配置，別的位置會報錯），獨立使用

<!--定時器任務配置（開始） -->
    <!--配置JOB -->
    <!--TPersonFollowUpTasksService這個bean是為了指定你早已經寫好的為了定時執行的方法所在的實現類 -->
    <bean id="TPersonFollowUpTasksService" class="com.msunsoft.service.personMana.Impl.TPersonFollowUpTasksServiceImpl"></bean>
    <bean id="JobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject">
            <ref bean="TPersonFollowUpTasksService" />
        </property>
        <property name="targetMethod">
<!--在這里指定需要定時執行的方法名-->
            <value>createFollowUpTasks</value>
        </property>
        <property name="concurrent">
            <value>false</value>
        </property>
    </bean>
    <!--配置Trigger -->
    <bean id="deleteDataTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <ref bean="JobDetail" />
        </property>
        <property name="cronExpression">
            <!-- 這里支持7個參數的corn表達式  每個小時的每分鍾執行一次 -->
            <value>0 0/1 * * * ? *</value>
        </property>
    </bean>
    <!--配置Scheduler -->
    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean" lazy-init="false" autowire="no">
        <property name="triggers">
            <list>
                <ref bean="deleteDataTrigger" />
            </list>
        </property>
        <property name="autoStartup">
            <value>true</value>
        </property>
    </bean>
    <!--定時器任務配置（結束） -->