亲宝软件园·资讯

展开

SpringBoot 任务调度动态设置

飞飞吹泡泡 人气:2

SpringBoot 任务调度动态设置

1.初始化入口(注解 @PostConstruct)

@PostConstruct
private void initTimedTask() {
    //初始化任务调度器cron,可以从数据库中查询到cron值
    List<Tweek> tweeks=tweekService.listAll(new Tweek());
    String cron=tweeks.get(0).getCron();
    if("".equals(cron)){
    }else{
        //启动
        setTaskTimedCron(cron);
    }
}
TimedTask taskt;
public void setTaskTimedCron(String cron) {
    if (null == taskt) {
        taskt= new TimedTask ();
    }
    taskt.restart(cron);
}

2.任务调度类

public class TimedTask implements Runnable{
    Logger logger = Logger.getLogger(TimedTask .class);
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;
    @Override
    public void run() {
    
        logger.info("每月最后一天定时发送彩信任务启动准备发送!");
        //业务逻辑
    }
    /**
     * 设置cron并启动
     * @param  cron值
     */
    public void restart(String cron) {
        if (null != this.threadPoolTaskScheduler) {
            ScheduledExecutorService scheduledExecutorService = this.threadPoolTaskScheduler.getScheduledExecutor();
            if (!scheduledExecutorService.isShutdown()) {
                scheduledExecutorService.shutdownNow();
            }
            this.threadPoolTaskScheduler.destroy();
        }
        if (null != cron&& cron.trim().length() > 0) {
            this.threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
            this.threadPoolTaskScheduler.setThreadNamePrefix("timedTask ");
            this.threadPoolTaskScheduler.initialize();
            this.threadPoolTaskScheduler.schedule(this, new CronTrigger(cron));
        }
    }
}

SpringBoot 调度任务

1.首先需要用@EnableScheduling

注解到*applicatin.java,用来检测是否有调度任务。

2.@Scheduled 注解用于标注

这个方法是一个定时任务的方法。Spring会自动扫描这个注解,启动调度任务。

package com.david.translate.quartz;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import com.david.translate.service.SysUserService;
@Component
public class TimeQuartz {
    @Autowired
    private SysUserService userService;
    /**
     * 一分钟执行一次
     */
    @Scheduled(cron="0 0/1 * * * ?") 
    public void executeFileDownLoadTask() {
        System.out.println(">>>>>>>>>>>>>>>>>>>任务执行 "+userService.findAll().size());
    }
}

调度任务的时间配置用的是cron表达式,推荐一个在线生成表达式的网站,如果自己不会写或者不愿意自己写,可以用这个网站直接生成:

http://cron.qqe2.com/

截图如下:

这里写图片描述

一些常用的任务表达式

例子:

以上为个人经验,希望能给大家一个参考,也希望大家多多支持。

加载全部内容

相关教程
猜你喜欢
用户评论