springboot 使用 @Scheduled 注解实现任务调度 以及相关踩坑记录

关于spring boot 实现任务调度的方法有不少种，这里再也不赘述。

首先pom只需引入

<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.2.1</version>
</dependency>

而后application开启@EnableScheduling

@SpringBootApplication
@EnableAsync
@EnableScheduling
public class Application extends SpringBootServletInitializer {

    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
        return application.sources(Application.class);
    }

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


}

以后用嘛就很简单了

@Component
@Configurable
public class TestONE {
    private Logger logger = (Logger) LoggerFactory.getLogger(TestONE.class);

    @Scheduled(cron = "0/5 * * * * ? ")
//    @Async
    public  void test1() {
        logger.error("任务1--开始");
        try {
            Thread.sleep(20000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.error("任务1---结束");
    }

========分隔线=========

首先大体说下遇到过的问题

Q1:启动后修改本地时间可是调度任务再也不执行

  A：以前大体看了一下这块的介绍，其实启动以后虚拟机内维持一个时间计数器，这个是启动时与系统时间同步过的，当让会有一个专门管理调度任务的，按照虚拟机时间以及系统时间核对（若是这出现不一致确定不执行了），若是一致那么也知足cron规则就开启执行。

Q2:出现漏执行的状况

A：我目前了解到其实spring的@Scheduled默认是单线程的，也就是说一次只能执行一个定时任务，若是一但任务是耗时的那么后面的自动进入线程的挂起等待队列，固然这个队列也是有大小限制，若是执行中任务特别耗时挂起的超过限制那么后面的任务都不会执行。

        不少大企是很注重调度任务的可用性，由于毕竟对于任务调度这个事情来讲里面涉及到的业务确定都是有价值甚至很重要的。特别公司发展的必定程度调度任务的重要性很是的高。因此若是仍是单节点的架构的调度的话建议仍是上高可用的调度吧，那么关于高可用的调度任务网上仍是有好几个解决方案以供选择，其实最核心的一点哪怕是多节点调度也是单一机器去执行调度任务，也就要求作到分布式锁，通常来说redis 或者 zookeeper就能够很好的实现这块。固然还有一个很重要的事儿就是关于调度任务失败的重调。我的推荐elastic-job这个组件，能够自行研究对比后选择适合本身公司业务的。

        针对以上调度线程是单线程问题其实也能够经过，设置执行线程数目，建议开启的线程池核心线程不要太高，毕竟cpu也就那么多个核心，线上项目又确定不是本身一个的。况且还有维护系统其余组件等的线程。我的感受视本身项目里调度数量和执行时间决定。单一时间段内不会出现跑满便可。

/**
 * @author qiaolu
 */
@Configuration
public class ScheduledConfig implements SchedulingConfigurer {

    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        scheduledTaskRegistrar.setScheduler(setTaskExecutors());
    }

    @Bean
    public Executor setTaskExecutors() {
        return newScheduledThreadPool(2);
    }
}

固然针对耗时较长的调度任务其实完成能够这样解决：加上 @Async

spring会把这个方法另开启一个线程去处理，以达到异步处理的效果，这样调度任务也会快速。固然不必给全部调度都这么加。

@Scheduled(cron = "0/5 * * * * ? ")
@Async
public  void test1() {
    logger.error("任务1--开始");
    try {
        Thread.sleep(20000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    logger.error("任务1---结束");
}

好了 大体就是以上的几点，基本也就知足中小企业遇到的调度问题。固然也可能有描述不许确或者不全面的地方，欢迎指正，哈哈。