在我们平时开发的项目中,定时任务基本属于必不可少的功能,那大家都是怎么做的呢?但我知道的大多都是静态定时任务实现。

基于注解来创建定时任务非常简单,只需几行代码便可完成。实现如下:

@Configuration
@EnableScheduling
public class SimpleScheduleTask {

    //10秒钟执行一次
    @Scheduled(cron = "0/10 * * * * ?")
    private void tasks() {
        System.out.println("【定时任务】 每10秒执行一次!");
    }
}

Cron表达式参数分别表示(从左到右):
秒(0~59) 如0/5表示每5秒
分(0~59)
时(0~23)
日(0~31) 月的某一天
月(0~11)
周几( 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT)

就上面几行代码,就能搞定一个定时任务。显然,使用Scheduled 确实特别的方便,但有很大的缺点和局限,就是当我们调整了执行计划的时间时,需要重启服务才能生效,这就有些不方便。为了达到实时生效的效果,可以通过数据库来动态实现定时任务。

 

基于数据库的动态定时任务实现

将定时任务配置在数据库,启动项目的时候,用mybatis读取数据库,实例化对象,并设定定时任务。如果需要新增,减少,修改定时任务,仅需要修改数据库资料,并重启项目即可,无需改代码。

@Lazy(value = false)
@Component
public class ScheduleTask implements SchedulingConfigurer {
 
    protected static Logger logger = LoggerFactory.getLogger(ScheduleTask.class);
    private SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 
    @Autowired
    private ScheduleTaskMapper scheduleTaskMapper;
 
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        List<ScheduleTask> tasks = getAllScheduleTasks();
        logger.info("【定时任务启动】 启动任务数:"+tasks.size()+"; time="+sdf.format(new Date()));
 
        //校验数据
        checkDataList(tasks);
        //通过校验的数据执行定时任务
        int count = 0;
        if(tasks.size()>0) {
            for (int i = 0; i < tasks.size(); i++) {
                try {
                    taskRegistrar.addTriggerTask(getRunnable(tasks.get(i)), getTrigger(tasks.get(i)));
                    count++;
                } catch (Exception e) {
                    logger.error("task start error:" + tasks.get(i).getClassName() + ";" + tasks.get(i).getMethodName() + ";" + e.getMessage());
                }
            }
        }
        logger.info("started task number="+count+"; time="+sdf.format(new Date()));
    };
 
  /**
  * 获取要执行的所有任务
  * @return
  */
    private List<ScheduleTask> getAllScheduleTasks() {
        ScheduleTaskExample example=new ScheduleTaskExample();
        example.createCriteria().andIsDeleteEqualTo((byte) 0);
        return scheduleTaskMapper.selectByExample(example);
    }
  
  /**
  * 获取Runnable
  *
  * @param task
  * @return
  */
    private Runnable getRunnable(ScheduleTask task
版权声明:本文为lyn20141231原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/lyn20141231/p/12105211.html