浅析java中常用的定时任务框架-单体
作者：小伙子vae
这篇文章主要带大家了解常用的单体应用定时任务框架以及掌握定时任务在单体中如何使用，文中的示例代码讲解详细，感兴趣的小伙伴可以跟随小编一起学习一下
一、阅读收获
1. 了解常用的单体应用定时任务框架
2. 掌握定时任务在单体中如何使用
二、本章源码下载
三、Timer+TimerTask
- 这是jdk自带的java.util.Timer类，这个类允许你调度一个java.util.TimerTask任务。
- 使用这种方式可以让你的程序按照某一个频度执行，但不能在指定时间运行,一般用的较少。
/**
* @Description: 1. Timer+TimerTask：（jdk自带）
* 这是java自带的java.util.Timer类，这个类允许你调度一个java.util.TimerTask任务。
* 使用这种方式可以让你的程序按照某一个频度执行，但不能在指定时间运行。一般用的较少。
* @Author: jianweil
* @date: 2021/12/14 13:36
*/
public class TimerTest {
public static void main(String[] args) {
TimerTask timerTask = new TimerTask() {
@Override
public void run() {
System.out.println("task run:" + new Date());
}
};
TimerTask timerTask2 = new TimerTask() {
@Override
public void run() {
System.out.println("task2 run:" + new Date());
//多线程并行处理定时任务时，Timer运行多个TimeTask时，只要其中之一没有捕获抛出的异常，其它任务便会自动终止运行，使用ScheduledExecutorService则没有这个问题。
int i = 1/0;
}
};
//idea会提示：使用ScheduledExecutorService代替Timer吧
Timer timer = new Timer();
System.out.println("begin:" + new Date());
//安排指定的任务在指定的时间开始进行重复的固定延迟执行。这里是延迟5秒开始执行，之后每3秒执行一次
timer.schedule(timerTask, 5000, 3000);
timer.schedule(timerTask2, 5000, 3000);
}
}
多线程并行处理定时任务时，Timer运行多个TimeTask时，只要其中之一没有捕获抛出的异常，其它任务便会自动终止运行，使用ScheduledExecutorService则没有这个问题。
四、ScheduledExecutorService
ScheduledExecutorService也是jdk自带的定时类，可以替代Timer
package com.ljw.springboottimer.scheduledExecutorservice;
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
import java.util.Date;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* @Description: 2. ScheduledExecutorService代替Timer（jdk自带）
* 多线程并行处理定时任务时，Timer运行多个TimeTask时，只要其中之一没有捕获抛出的异常，其它任务便会自动终止运行，
* 使用ScheduledExecutorService则没有这个问题。
* @Author: jianweil
* @date: 2021/12/14 13:42
*/
public class ScheduledExecutorServiceTest {
public static void main(String[] args) throws InterruptedException {
//当所有的非守护线程结束时，程序也就终止了，同时会杀死进程中的所有守护线程。反过来说，只要任何非守护线程还在运行，程序就不会终止。
ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1,
new BasicThreadFactory.Builder().namingPattern("example-schedule-pool-%d").daemon(false).build());
System.out.println("begin:" + new Date());
// 参数：1、任务体 2、首次执行的延时时间 3、任务执行间隔 4、间隔时间单位
//延迟5秒执行，之后每3秒执行一次
executorService.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
//do something
System.out.println("begin:" + new Date());
}
}, 5, 3, TimeUnit.SECONDS);
}
}
五、Spring Task
spring提供的类，可引入依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
开启定时任务：@EnableScheduling
使用：在相应的任务方法前加上注解@Scheduled即可
5.1 单线程串行执行-@Scheduled
@Scheduled注解默认使同一个线程中串行执行，如果只有一个定时任务，这样做肯定没问题，当定时任务增多，如果一个任务卡死，会导致其他任务也无法执行。
业务测试：
@Component
@EnableScheduling
public class SpringTaskTest {
@Scheduled(cron = "0/5 * * * * *")
public void run() throws InterruptedException {
System.out.println(Thread.currentThread().getName() + "=====>>>>>使用cron {}" + (System.currentTimeMillis() / 1000));
}
}
5.2 多线程并发运行-@Scheduled+配置定时器的程池（推荐）
- 解决单线程串行执行任务的问题，需要配置定时器的程池，推荐这种方法
- 配置并注入一个TaskScheduler类bean即可
- 配置定时器的线程池类如下：
package com.ljw.springboottimer.springtask;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
/**
* @Description: 解决单线程串行执行 方式2:@Scheduled+配置定时器的线程池
* @Author: jianweil
* @date: 2021/12/14 14:44
*/
@Configuration
public class TaskSchedulerConfig {
/**
* 初始化了一个线程池大小为 5 的 TaskScheduler, 避免了所有任务都用一个线程来执行
*
* @return
*/
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(5);
taskScheduler.setThreadNamePrefix("TaskSchedulerConfig-ljw");
return taskScheduler;
}
}
业务测试
@Component
@EnableScheduling
public class SpringTaskTest {
@Scheduled(cron = "0/5 * * * * *")
public void run() throws InterruptedException {
System.out.println(Thread.currentThread().getName() + "=====>>>>>使用cron {}" + (System.currentTimeMillis() / 1000));
}
@Scheduled(fixedRate = 5000)
public void run1() throws InterruptedException {
System.out.println(Thread.currentThread().getName() + "=====>>>>>使用fixedRate {}" + (System.currentTimeMillis() / 1000));
}
}
5.3 多线程并发执行-@Scheduled+@Async+配置异步线程池
解决单线程串行执行任务的问题，也可以结合异步注解@Async实现，但这种方法并不推荐，需要两个注解，代码编写的工作量大
还可以解决fixedRate在遇到某些执行任务时间超过配置的时间隔，下次任务时间到了还要等待上次任务执行完成的情况，这是3.2不能解决的。
配置异步线程池类如下：
package com.ljw.springboottimer.springtask;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
/**
* @Description: 解决单线程串行执行 方式1:@Scheduled+@Async+配置异步线程池
* @Author: jianweil
* @date: 2021/12/14 14:35
*/
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
/**
* 定义@Async默认的线程池
* ThreadPoolTaskExecutor不是完全被IOC容器管理的bean,可以在方法上加上@Bean注解交给容器管理,这样可以将taskExecutor.initialize()方法调用去掉，容器会自动调用
*
* @return
*/
@Override
public Executor getAsyncExecutor() {
int processors = Runtime.getRuntime().availableProcessors();
//常用的执行器
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
//核心线程数
taskExecutor.setCorePoolSize(10);
taskExecutor.setMaxPoolSize(50);
//线程队列最大线程数,默认：50
taskExecutor.setQueueCapacity(100);
//线程名称前缀
taskExecutor.setThreadNamePrefix("AsyncConfig-ljw-");
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
//执行初始化(重要)
taskExecutor.initialize();
return taskExecutor;
}
}
业务测试需要加上@Async注解
@Component
@EnableScheduling
public class SpringTaskTest {
@Scheduled(cron = "0/5 * * * * *")
@Async
public void run() throws InterruptedException {
System.out.println(Thread.currentThread().getName() + "=====>>>>>使用cron {}" + (System.currentTimeMillis() / 1000));
}
@Scheduled(fixedRate = 5000)
@Async
public void run1() throws InterruptedException {
System.out.println(Thread.currentThread().getName() + "=====>>>>>使用fixedRate {}" + (System.currentTimeMillis() / 1000));
}
}
如果同时配置了3.2配置定时器的程池和3.3配置异步线程池，并且注解使用了@Scheduled+@Async，则定时任务使用的线程池为：配置异步线程池
5.4 @Scheduled参数解析
cron：通过cron表达式来配置任务执行时间（默认是fixedDelay）
initialDelay ：定义该任务延迟多少时间才开始第一次执行
fixedRate：定义一个按一定频率执行的定时任务。fixedRate 每次任务结束后会从任务编排表中找下一次该执行的任务，判断是否到时机执行，fixedRate的任务某次执行时间再长也不会造成两次任务实例同时执行，也要等到上次任务完成，判断是否到时机执行，到就立即执行，与线程池无关，除非用了@Async注解，使方法异步，即是使用5.3步骤的配置。（5.2是配置线程池，达不到效果）
fixedDelay：定义一个按一定频率执行的定时任务。fixedDelay总是在前一次任务完成后，延时固定时间长度然后再执行下一次任务
六、Quartz
在开发Quartz相关应用时，只要定义了Job（任务），JobDetail（任务描述），Trigger（触发器）和Scheduler（调度器），即可实现一个定时调度能力。
如果SpringBoot版本是2.0.0以后的，则在spring-boot-starter中已经包含了quart的依赖，则可以直接引入依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
6.1. 创建任务类
方式1：实现Job类的execute方法即可实现一个任务（推荐）
任务1如下：
package com.ljw.springboottimer.quartz.do1;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.util.Date;
/**
* @Description: 我的定时任务-方法1
* @Author: jianweil
* @date: 2021/12/14 16:06
*/
public class MyTaskService1 implements Job {
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
System.out.println(Thread.currentThread().getName() + "------ Job ------" + new Date());
}
}
方式2：继承QuartzJobBean类重写方法即可实现一个任务
任务2如下：
package com.ljw.springboottimer.quartz.do1;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;
import java.util.Date;
/**
* @Description: 我的定时任务-方法2
* @Author: jianweil
* @date: 2021/12/14 16:06
*/
public class MyTaskService2 extends QuartzJobBean {
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
System.out.println(Thread.currentThread().getName() + "---QuartzJobBean-----" + new Date());
}
}
6.2. 配置任务描述和触发器
配置类要分别要为每个任务声明两个bean
- 1.JobDetail（任务描述）
- 2.Trigger（触发器）
配置调度器信息使用SimpleScheduleBuilder或者CronScheduleBuilder
package com.ljw.springboottimer.quartz.do1;
import org.quartz.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.Date;
/**
* @Description: 每个任务都要两步配置
* 1.配置任务描述JobDetail 2. 配置触发器Trigger
* @Author: jianweil
* @date: 2021/12/14 16:08
*/
@Configuration
public class QuartzConfig {
/**
* 创建任务1的 JobDetail1
*
* @return
*/
@Bean
public JobDetail teatQuartzDetail1() {
return JobBuilder.newJob(MyTaskService1.class)
//job的描述
.withDescription("this is a job1")
//job 的name和group
.withIdentity("myTrigger1", "myTriggerGroup1")
.storeDurably().build();
}
/**
* 创建任务2的 JobDetail2
*
* @return
*/
@Bean
public JobDetail teatQuartzDetail2() {
return JobBuilder.newJob(MyTaskService2.class)
//job的描述
.withDescription("this is a job2")
//job 的name和group
.withIdentity("myTrigger2", "myTriggerGroup2")
.storeDurably().build();
}
/**
* 创建任务1的 Trigger1
*
* @return
*/
@Bean
public Trigger testQuartzTrigger1() {
//使用SimpleScheduleBuilder或者CronScheduleBuilder
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
//设置时间周期单位秒
.withIntervalInSeconds(10)
.repeatForever();
//两秒执行一次，Quartz表达式，支持各种牛逼表达式
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/3 * * * * ?");
//任务运行的时间，SimpleSchedle类型触发器有效，3秒后启动任务
long time = System.currentTimeMillis() + 3 * 1000L;
Date statTime = new Date(time);
return TriggerBuilder.newTrigger()
.withDescription("")
.forJob(teatQuartzDetail1())
.withIdentity("myTrigger1", "myTriggerGroup1")
//默认当前时间启动
.startAt(statTime)
.withSchedule(cronScheduleBuilder)
//.withSchedule(scheduleBuilder)
.build();
}
/**
* 创建任务2的 Trigger2
*
* @return
*/
@Bean
public Trigger testQuartzTrigger2() {
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
//设置时间周期单位秒
.withIntervalInSeconds(10)
.repeatForever();
return TriggerBuilder.newTrigger()
.forJob(teatQuartzDetail2())
.withIdentity("myTrigger2", "myTriggerGroup2")
.withSchedule(scheduleBuilder)
.build();
}
}
以上就是浅析java中常用的定时任务框架-单体的详细内容，更多关于java定时任务框架的资料请关注脚本之家其它相关文章！