1. 程式人生 > >spring定時任務的用法(可以用)

spring定時任務的用法(可以用)

Spring Task,可以將它比作一個輕量級的Quartz,而且使用起來很簡單,除spring相關的包外不需要額外的包,而且支援註解和配置檔案兩種.

一、XML配置檔案方式

編寫作業類

就是即普通的Java類,如下, 

  •  定時任務1
import java.text.SimpleDateFormat;
import java.util.Date;

public class TaskJob {
     //定時執行程式碼塊
    public void myMethod() {
        System.out.println((new SimpleDateFormat("yyyy-MM-dd hh:mm:ss")).format(new Date())+ " 我是後臺任務1...");
    }
} 
  • 定時任務2
import java.text.SimpleDateFormat;
import java.util.Date;


public class TaskJob2 {
    //定時任務程式碼塊
	public void myMethod() {
        System.out.println((new SimpleDateFormat("yyyy-MM-dd hh:mm:ss")).format(new Date())+ " 我是後臺任務2...");
    }
}

在spring配置檔案頭中新增名稱空間及描述

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:task="http://www.springframework.org/schema/task" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="  
        http://www.springframework.org/schema/task 
        http://www.springframework.org/schema/task/spring-task-3.0.xsd
        http://www.springframework.org/schema/beans        
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  
        http://www.springframework.org/schema/context                
        http://www.springframework.org/schema/context/spring-context-3.0.xsd">
</beans>

 spring配置檔案中設定具體的任務(與上面程式碼是在同一個xml中)

<!-- 定時任務要執行的方法 -->
<bean id="taskJob" class="com.task.TaskJob" />
<bean id="taskJob2" class="com.task.TaskJob2" />

<!--用於定時任務的執行 -->
<task:scheduled-tasks>
    <!-- 指定要執行的類的方法,每2秒執行一次 -->
    <task:scheduled ref="taskJob" method="myMethod" cron=" 0/2 * * * * ?" />
    <!-- 指定要執行的類的方法,每3秒執行一次 -->
    <task:scheduled ref="taskJob2" method="myMethod" cron=" 0/3 * * * * ?" />
</task:scheduled-tasks>

二、註解的方式

註解@Scheduled的定義

@Target({java.lang.annotation.ElementType.METHOD,java.lang.annotation.ElementType.ANNOTATION_TYPE})  
@Retention(RetentionPolicy.RUNTIME)  
@Documented  
public @interface Scheduled  
{  
  public abstract String cron();  

  public abstract long fixedDelay();  

  public abstract long fixedRate();  
} 

可以看出該註解有三個方法或者叫引數,分別表示的意思是: 
* cron:指定cron表示式 
* fixedDelay:官方文件解釋:An interval-based trigger where the interval is measured from the completion time of the previous task. The time unit value is measured in milliseconds.即表示從上一個任務完成開始到下一個任務開始的間隔,單位是毫秒。 
* fixedRate:官方文件解釋:An interval-based trigger where the interval is measured from the start time of the previous task. The time unit value is measured in milliseconds.即從上一個任務開始到下一個任務開始的間隔,單位是毫秒。

編寫pojo
 

import java.util.Date;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component("taskJob")
public class TaskJob {

    @Scheduled(cron = " 0/2 * * * * ?") // 每兩秒執行一次
    public void myMethod() {
        System.out.println(new Date().toLocaleString() + " 我是基於註解的後臺任務...");
    }
}

新增task相關的配置:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:task="http://www.springframework.org/schema/task" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="  
        http://www.springframework.org/schema/task 
        http://www.springframework.org/schema/task/spring-task-3.0.xsd
        http://www.springframework.org/schema/beans        
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  
        http://www.springframework.org/schema/context                
        http://www.springframework.org/schema/context/spring-context-3.0.xsd">

    <context:annotation-config />
    <!-- spring掃描註解的配置 -->
    <context:component-scan base-package="com.antation" />

    <!-- 開啟這個配置,spring才能識別@Scheduled註解 -->
    <task:annotation-driven scheduler="qbScheduler" mode="proxy" />
    <task:scheduler id="qbScheduler" pool-size="10" />

</beans>

 

說明:理論上只需要加上這句配置就可以了,這些引數都不是必須的。

三、Java測試程式

import org.springframework.context.support.ClassPathXmlApplicationContext;
public class AnnationTaskTest {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext appContext = new ClassPathXmlApplicationContext("applicationContext-task.xml");
        //try catch可以不寫
        try {
            Thread.sleep(Integer.MAX_VALUE);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

執行結果

2018-10-18 10:48:50 我是後臺任務1...
2018-10-18 10:48:51 我是後臺任務2...
2018-10-18 10:48:52 我是後臺任務1...
2018-10-18 10:48:54 我是後臺任務2...
2018-10-18 10:48:54 我是後臺任務1...
2018-10-18 10:48:56 我是後臺任務1...
2018-10-18 10:48:57 我是後臺任務2...
2018-10-18 10:48:58 我是後臺任務1...

原文連結:https://blog.csdn.net/zbw18297786698/article/details/73438014

注意:以上只需要Spring的jar包和3個必須jar包,方可執行(網上下載即可)