java spring动态生成定时任务

入口类 DemoApplication.java

package com.example.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

}

方式一：

使用SchedulingConfigurer接口

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

@Component
public class ScheduleTask implements SchedulingConfigurer {
    @Autowired
    private JdbcTemplate jdbcTemplate;


    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        /**
         *  模拟从数据库记录中生成相应的定时任务
         */
        List<String> tasks = new ArrayList<>();
        jdbcTemplate.query("select * from demo", rs -> {
            System.out.println(rs.getString("msg"));
            tasks.add(rs.getString("msg"));
        });
        System.out.println(".... task....");
        tasks.forEach(s -> {
            System.out.println(s);
            scheduledTaskRegistrar.addCronTask(() -> {
                System.out.println(s);
            }, "0/5 * * * * ?");
        });

    }
}

方式二：

使用ThreadPoolTaskScheduler类

package com.example.demo;

import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;

import java.util.concurrent.ScheduledFuture;


/*
 * 启动时初始化/准备
 * Runtime.getRuntime().exec("shutdown -s -t 60")
 * InetAddress.getByName("192.168.3.240").isReachable(6000)
 */
@Component
@Order(1)
public class CommonStarting implements CommandLineRunner {
    @Override
    public void run(String... args) throws Exception {
        System.out.println("<<<<<<<<<<<<<<<<<starting application...<<<<<<<<<<<<<<<");

        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.initialize();
        final ScheduledFuture<?> future = scheduler.schedule(() -> {
            System.out.println("hello..... from threadPoolTaskScheduler");
        }, new CronTrigger("*/10 * * * * *"));

    }
}