玩转 Spring Boot 集成篇（@Scheduled静态动态定时任务）

Posted 2022-02-14 一猿小讲

public static void main(String[] args) SpringApplication.run(DemoApplication.class, args); private static final Log logger = LogFactory.getLog(DownLoadTask.class); @Scheduled(cron = "0 0/5 * * * ?") public void justDoIt() logger.info("开始下载银行对账文件"); logger.info("银行对账文件下载完成，进行解密操作"); logger.info("银行对账文件下载解密完成"); private static final Log logger = LogFactory.getLog(DownLoadTask.class); @Scheduled(cron = "0/1 * * * * ?") public void justDoItA() logger.info("开始下载银行 A 的对账文件"); logger.info("银行 A 对账文件下载完成，进行解密操作"); logger.info("银行 A 对账文件下载解密完成"); @Scheduled(cron = "0/1 * * * * ?") public void justDoItB() logger.info("开始下载银行 B 的对账文件"); logger.info("银行 B 对账文件下载完成，进行解密操作"); logger.info("银行 B 对账文件下载解密完成"); @Bean(name = "bankThreadPool") public Executor bankExecutor() ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); // 设置核心线程数为 3 executor.setCorePoolSize(3); // 最大线程数为10 executor.setMaxPoolSize(10); // 任务队列的大小 executor.setQueueCapacity(3); // 线程前缀名 executor.setThreadNamePrefix("bankExecutor-"); // 线程存活时间 executor.setKeepAliveSeconds(30); // 初始化 executor.initialize(); return executor; private static final Log logger = LogFactory.getLog(DownLoadTask.class); @Async("bankThreadPool") @Scheduled(cron = "0/1 * * * * ?") public void justDoIt() logger.info("开始下载银行 A 的对账文件"); logger.info("银行 A 对账文件下载完成，进行解密操作"); logger.info("银行 A 对账文件下载解密完成"); @Async("bankThreadPool") @Scheduled(cron = "0/1 * * * * ?") public void justDoIt2() logger.info("开始下载银行 B 的对账文件"); logger.info("银行 B 对账文件下载完成，进行解密操作"); logger.info("银行 B 对账文件下载解密完成"); * 动态定时任务实现步骤* 步骤1：定义定时任务 DownLoadTaskV3 类实现 SchedulingConfigurer 接口；* 步骤2：编写定时任务要执行的业务逻辑；* 步骤3：数据库中配置任务执行的具体时间规则，记住任务名称* 步骤4：根据任务名称从数据库获取 Cron 参数，设置任务触发器，触发任务执行。* （仅抛砖引玉，可作进一步的抽象）*/ Log logger = LogFactory.getLog(DownLoadTaskV3.class); TaskInfoRepository taskInfoRepository; Runnable task = Runnable() logger.info( logger.info( logger.info( ; Trigger trigger = Trigger() * 每一次任务触发，都会调用一次该方法 * 然后重新获取下一次的执行时间 */ Date TaskInfo taskInfo = TaskInfo(); taskInfo.setJobName( Optional<TaskInfo> taskInfoOptional = taskInfoRepository.findOne(Example.of(taskInfo)); String cron = taskInfoOptional.get().getCron(); CronTrigger trigger = CronTrigger(cron); trigger.nextExecutionTime(triggerContext); ; taskRegistrar.addTriggerTask(task, trigger); ( AUTO_INCREMENT datetime datetime PRIMARY ((TaskInfo Serializable Integer id; cron; jobName; status; createTime; updateTime; JpaRepository<TaskInfo, Integer>