spring task任务调度 - wtdig/study GitHub Wiki

spring task使用

一、注解配置

1、pom文件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>cn.wt.springtask</groupId>
    <artifactId>springtaskdemoannotation</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.5.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.0.2.RELEASE</version>
        </dependency>
    </dependencies>
</project>

2、配置文件applicationcontext.xml

<?xml version="1.0" encoding="UTF-8"?>
<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:task="http://www.springframework.org/schema/task"
    xsi:schemaLocation="
            http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd
            http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd">

    <context:annotation-config />
    <!-- 配置注解扫描 -->
    <context:component-scan base-package="cn.wt.springtask" />
    <!-- 开启这个配置，spring才能识别@Scheduled注解 -->
    <task:annotation-driven /> 
</beans>

3、代码

package cn.wt.springtask;

import java.time.LocalDateTime;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

/**
 * @author wb-wt261136
 * @version 2017年8月11日 上午11:16:20
 */
@Component("mytask")
public class MyTask {

    // 每半分钟触发任务
    @Scheduled(cron = "30 * * * * ?")
    public void execute1() {
        System.out.printf("Task: %s, Current time: %s\n", 1, LocalDateTime.now());
    }

    // 每15秒、30秒、45秒时触发任务
    @Scheduled(cron = "15,30,45 * * * * ?")
    public void execute2() {
        System.out.printf("Task: %s, Current time: %s\n", 2, LocalDateTime.now());
    }

}


package cn.wt.springtask.test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * @author wb-wt261136
 * @version 2017年8月11日 上午11:23:30
 */
public class SpringTaskTest {

    @SuppressWarnings({ "resource", "unused" })
    public static void main(String[] args) {

        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationcontext.xml");
    }
}

二、xml配置

1、pom文件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>cn.wt.springtask</groupId>
    <artifactId>springtaskdemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.5.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.0.2.RELEASE</version>
        </dependency>
    </dependencies>
</project>

2、配置文件applicationcontext.xml

<?xml version="1.0" encoding="UTF-8"?>
<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:task="http://www.springframework.org/schema/task"
    xsi:schemaLocation="
            http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd
            http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd">

    <!-- 配置注解扫描 -->
    <context:component-scan base-package="cn.wt.springtask" />

    <task:scheduler id="taskScheduler" pool-size="100" />

    <task:scheduled-tasks scheduler="taskScheduler">
        <!-- 每半分钟触发任务 -->
        <task:scheduled ref="mytask" method="execute1"
            cron="30 * * * * ?" />
        <!-- 每小时的10分30秒触发任务 -->
        <task:scheduled ref="mytask" method="execute2"
            cron="30 10 * * * ?" />
        <!-- 每天1点10分30秒触发任务 -->
        <task:scheduled ref="mytask" method="execute3"
            cron="30 10 1 * * ?" />
        <!-- 每月20号的1点10分30秒触发任务 -->
        <task:scheduled ref="mytask" method="execute4"
            cron="30 10 1 20 * ?" />
        <!-- 每年10月20号的1点10分30秒触发任务 -->
        <task:scheduled ref="mytask" method="execute5"
            cron="30 10 1 20 10 ?" />
        <!-- 每15秒、30秒、45秒时触发任务 -->
        <task:scheduled ref="mytask" method="execute6"
            cron="15,30,45 * * * * ?" />
        <!-- 15秒到45秒每隔1秒触发任务 -->
        <task:scheduled ref="mytask" method="execute7"
            cron="15-45 * * * * ?" />
        <!-- 每分钟的每15秒时任务任务，每隔5秒触发一次 -->
        <task:scheduled ref="mytask" method="execute8"
            cron="15/5 * * * * ?" />
        <!-- 每分钟的15到30秒之间开始触发，每隔5秒触发一次 -->
        <task:scheduled ref="mytask" method="execute9"
            cron="15-30/5 * * * * ?" />
        <!-- 每小时的0分0秒开始触发，每隔3分钟触发一次 -->
        <task:scheduled ref="mytask" method="execute10"
            cron="0 0/3 * * * ?" />
        <!-- 星期一到星期五的10点15分0秒触发任务 -->
        <task:scheduled ref="mytask" method="execute11"
            cron="0 15 10 ? * MON-FRI" />
    </task:scheduled-tasks>
</beans>

3、代码

package cn.wt.springtask;

import java.time.LocalDateTime;

import org.springframework.stereotype.Component;

/**
 * @author wb-wt261136
 * @version 2017年8月11日 上午11:16:20
 */
@Component("mytask")
public class MyTask {

    public void execute1() {
        System.out.printf("Task: %s, Current time: %s\n", 1, LocalDateTime.now());
    }

    public void execute2() {
        System.out.printf("Task: %s, Current time: %s\n", 2, LocalDateTime.now());
    }

    public void execute3() {
        System.out.printf("Task: %s, Current time: %s\n", 3, LocalDateTime.now());
    }

    public void execute4() {
        System.out.printf("Task: %s, Current time: %s\n", 4, LocalDateTime.now());
    }

    public void execute5() {
        System.out.printf("Task: %s, Current time: %s\n", 5, LocalDateTime.now());
    }

    public void execute6() {
        System.out.printf("Task: %s, Current time: %s\n", 6, LocalDateTime.now());
    }

    public void execute7() {
        System.out.printf("Task: %s, Current time: %s\n", 7, LocalDateTime.now());
    }

    public void execute8() {
        System.out.printf("Task: %s, Current time: %s\n", 8, LocalDateTime.now());
    }

    public void execute9() {
        System.out.printf("Task: %s, Current time: %s\n", 9, LocalDateTime.now());
    }

    public void execute10() {
        System.out.printf("Task: %s, Current time: %s\n", 10, LocalDateTime.now());
    }

    public void execute11() {
        System.out.printf("Task: %s, Current time: %s\n", 11, LocalDateTime.now());
    }
}


package cn.wt.springtask.test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * @author wb-wt261136
 * @version 2017年8月11日 上午11:23:30
 */
public class SpringTaskTest {

    @SuppressWarnings({ "resource", "unused" })
    public static void main(String[] args) {

        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationcontext.xml");
    }
}

-by wt

⚠️ **GitHub.com Fallback** ⚠️