前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >CMS-Spring Task定时任务

CMS-Spring Task定时任务

作者头像
cwl_java
修改2020-01-14 14:45:48
3840
修改2020-01-14 14:45:48
举报
文章被收录于专栏:cwl_Java

3 Spring Task定时任务

3.1需求分析

根据分布式事务的研究结果,订单服务需要定时扫描任务表向MQ发送任务。本节研究定时任务处理的方案,并实 现定时任务扫描任务表并向MQ发送消息。

实现定时任务的方案如下:

  1. 使用jdk的Timer和TimerTask实现 可以实现简单的间隔执行任务,无法实现按日历去调度执行任务。
  2. 使用Quartz实现 Quartz 是一个异步任务调度框架,功能丰富,可以实现按日历调度。
  3. 使用Spring Task实现 Spring 3.0后提供Spring Task实现任务调度,支持按日历调度,相比Quartz功能稍简单,但是在开发基本够用,支持注解编程方式。 本项目使用Spring Task实现任务调度。

3.2 Spring Task串行任务

3.2.1 编写任务类

在Spring boot启动类上添加注解:@EnableScheduling 新建任务测试类TestTask,编写测试方法如下:

代码语言:javascript
复制
@Component
public class ChooseCourseTask {
    
    private static final Logger LOGGER = LoggerFactory.getLogger(ChooseCourseTask.class);

    // @Scheduled(fixedRate = 5000)
    // 上次执行开始时间后5秒执行
    // @Scheduled(fixedDelay = 5000)
    // 上次执行完毕后5秒执行
    // @Scheduled(initialDelay=3000, fixedRate=5000)
    // 第一次延迟3秒,以后每隔5秒执行一次 @Scheduled(cron="0/3 * * * * *")
    // 每隔3秒执行一次
    public void task1() {
        LOGGER.info("===============测试定时任务1开始===============");
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        LOGGER.info("===============测试定时任务1结束===============");
    }
}

测试:

  1. 测试fixedRate和fixedDelay的区别
  2. 测试串行执行的特点

3.2.2 cron表达式

cron表达式包括6部分:

  1. 秒(0~59)
  2. 分钟(0~59)
  3. 小时(0~23)
  4. 月中的天(1~31)
  5. 月(1~12)
  6. 周中的天 (填写MON,TUE,WED,THU,FRI,SAT,SUN,或数字1~7 1表示MON,依次类推)

特殊字符介绍:

  1. “/”字符表示指定数值的增量
  2. “*”字符表示所有可能的值
  3. “-”字符表示区间范围
  4. “,” 字符表示列举
  5. “?”字符仅被用于月中的天和周中的天两个子表达式,表示不指定值

例子:

  1. 0/3 * * * * * 每隔3秒执行
  2. 0 0/5 * * * * 每隔5分钟执行
  3. 0 0 0 * * * 表示每天0点执行
  4. 0 0 12 ? * WEN 每周三12点执行
  5. 0 15 10 ? * MON-FRI 每月的周一到周五10点 15分执行
  6. 0 15 10 ? * MON,FRI 每月的周一和周五10点 15分执行

3.2.3 串行任务测试

参考 task1方法的的定义方法,再定义task2方法,此时共用两个任务方法。

代码语言:javascript
复制
    @Scheduled(fixedRate = 3000)
    //上次执行开始时间后5秒执行 
    public void task2() {
        LOGGER.info("===============测试定时任务2开始===============");
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        LOGGER.info("===============测试定时任务2结束===============");
    }

通过测试发现,两个任务方法由一个线程串行执行,task1方法执行完成task2再执行。

3.3 Spring Task并行任务

3.3.1 需求分析

在项目通常是需要多个不同的任务并行去执行。 本节实现Spring Task并行执行任务的方法。

3.3.2 配置异步任务

创建异步任务配置类,需要配置线程池实现多线程调度任务。

代码语言:javascript
复制
@Configuration
@EnableScheduling
public class AsyncTaskConfig implements SchedulingConfigurer, AsyncConfigurer {
    //线程池线程数量 
    private int corePoolSize = 5;

    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.initialize();
        //初始化线程池 
        scheduler.setPoolSize(corePoolSize);
        //线程池容量 
        return scheduler;
    }

    @Override
    public Executor getAsyncExecutor() {
        Executor executor = taskScheduler();
        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        scheduledTaskRegistrar.setTaskScheduler(taskScheduler());
    }
}

@EnableScheduling添加到此配置类上,SpringBoot启动类上不用再添加@EnableScheduling

3.3.3 测试

通过测试发现两个任务由不同的线程在并行执行,互不影响。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 3 Spring Task定时任务
    • 3.1需求分析
      • 3.2 Spring Task串行任务
        • 3.2.1 编写任务类
        • 3.2.2 cron表达式
        • 3.2.3 串行任务测试
      • 3.3 Spring Task并行任务
        • 3.3.1 需求分析
        • 3.3.2 配置异步任务
        • 3.3.3 测试
    相关产品与服务
    领券
    问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档