SpringBoot的定时任务的加强工具,实现定时任务动态管理,完全兼容原生@Scheduled注解,无需对原本的定时任务进行修改
<dependency>
<groupId>com.github.guoyixing</groupId>
<artifactId>spring-boot-starter-super-scheduled</artifactId>
<version>0.3.4</version>
</dependency>
https://keyboard-dog.blog.csdn.net/article/details/106494637
#线程池大小
spring.super.scheduled.thread-pool.poolSize=30
#线程名前缀
spring.super.scheduled.thread-pool.threadNamePrefix=super
#设置是否关闭时等待执行中的任务执行完成
spring.super.scheduled.thread-pool.waitForTasksToCompleteOnShutdown=false
#设置此执行器被关闭时等待的最长时间,用于在其余容器继续关闭之前等待剩余任务执行完成
#需要将waitForTasksToCompleteOnShutdown设置为true,此配置才起作用
spring.super.scheduled.thread-pool.awaitTerminationSeconds=0
#开启执行标志
spring.super.scheduled.plug-in.executionFlag=true
#开启定时任务调度日志,日志文件是存在本地磁盘上的
spring.super.scheduled.plug-in.executionLog=true
#日志存放位置,不设置默认位置为程序同级目录下
spring.super.scheduled.plug-in.logPath=H:/tmp/log-scheduled
#开启基于zookeeper的集群模式
spring.super.scheduled.plug-in.colony=true
#zookeeper集群模式的定时任务服务名,相同名称的定时任务名称服务会被统一管理
spring.super.scheduled.plug-in.colonyName=test
#设置zookeeper地址,zookeeper集群多个地址用英文逗号隔开
spring.super.scheduled.zookeeper.url=127.0.0.1:2181
#设置zookeeper session超时时间
spring.super.scheduled.zookeeper.sessionTimeout=60000
#设置zookeeper连接超时时间
spring.super.scheduled.zookeeper.connectionTimeout=60000
@SpringBootApplication
@EnableScheduling
public class TestApplication {
public static void main(String[] args) {
SpringApplication.run(TestApplication.class, args);
}
}
@Component
public class TestTask {
private DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
@Scheduled(cron = "0/2 * * * * ?")
public void robReceiveExpireTask() {
System.out.println(df.format(LocalDateTime.now()) + "测试测试");
}
}
@RunWith(SpringRunner.class)
@SpringBootTest
public class TestApplicationTests {
//直接注入管理器
@Autowired
private SuperScheduledManager superScheduledManager;
@Test
public void test() {
//获取所有定时任务
List<String> allSuperScheduledName = superScheduledManager.getAllSuperScheduledName();
String name = allSuperScheduledName.get(0);
//终止定时任务
superScheduledManager.cancelScheduled(name);
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("任务名:" + name);
//启动定时任务
superScheduledManager.addCronScheduled(name, "0/2 * * * * ?");
//获取启动汇总的定时任务
List<String> runScheduledName = superScheduledManager.getRunScheduledName();
runScheduledName.forEach(System.out::println);
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
//修改定时任务执行周期
superScheduledManager.setScheduledCron(name, "0/5 * * * * ?");
}
}
List<String> allSuperScheduledName = superScheduledManager.getAllSuperScheduledName();
List<String> runScheduledName = superScheduledManager.getRunScheduledName();
superScheduledManager.cancelScheduled(name);
//以cron模式启动定时任务
superScheduledManager.addCronScheduled(name, "0/2 * * * * ?");
//将定时任务转为cron模式运行,并修改cron的参数值
superScheduledManager.setScheduledCron(name, "0/2 * * * * ?");
//以FixedRate模式启动定时任务
//上一次开始执行之后2秒后再执行,首次运行延迟1秒
superScheduledManager.addFixedRateScheduled(name, 2000L,1000L);
//首次运行不进行延迟
superScheduledManager.addFixedRateScheduled(name, 2000L);
//将定时任务转为FixedRate模式运行,并修改执行间隔的参数值
superScheduledManager.setScheduledFixedRate(name, 2000L);
//以FixedDelay模式启动定时任务
//上一次执行完毕之后2秒后再执行,首次运行延迟1秒
superScheduledManager.addFixedDelayScheduled(name, 2000L,1000L);
//首次运行不进行延迟
superScheduledManager.addFixedDelayScheduled(name, 2000L);
//将定时任务转为FixedDelay模式运行,并修改执行间隔的参数值
superScheduledManager.setScheduledFixedDelay(name, 2000L);
superScheduledManager.runScheduled(name);
superScheduledManager.getScheduledLogFiles();
superScheduledManager.getScheduledLogs(fileName);
只有在每个前置增强器结束之后才会判断是否需要跳过此次运行
superScheduledManager.callOffScheduled(name);
GET
/scheduled/name/all
GET
/scheduled/name/run
POST
/scheduled/{name}/run
DELETE
/scheduled/{name}
POST
/scheduled/cron/{name}/add
参数:text
[cron]
POST
/scheduled/cron/{name}/set
参数:text
[cron]
POST
/scheduled/fixedDelay/{name}/add/{fixedDelay}/{initialDelay}
POST
/scheduled/fixedDelay/{name}/add/{fixedDelay}
POST
/scheduled/fixedDelay/{name}/set/{fixedDelay}
POST
/scheduled/fixedRate/{name}/add/{fixedRate}/{initialDelay}
POST
/scheduled/fixedRate/{name}/add/{fixedRate}
POST
/scheduled/fixedRate/{name}/set/{fixedRate}
GET
/scheduled/log/files
GET
/scheduled/log/{fileName}
只有在每个前置增强器结束之后才会判断是否需要跳过此次运行
POST
/scheduled/{name}/callOff
- 将类注入到spring容器中
- 实现BaseStrengthen接口
- 使用@SuperScheduledOrder(int)注解实现执行优先级控制,int值越大优先级越高,默认值为0
@Component
@SuperScheduledOrder(1)
public class Strong implements BaseStrengthen {
/**
* 前置强化方法
*
* @param bean bean实例(或者是被代理的bean)
* @param method 执行的方法对象
* @param args 方法参数
* @param context 任务线程运行时的上下文
*/
@Override
public void before(Object bean, Method method, Object[] args, ScheduledRunningContext context) {
System.out.println("定时任务执行前运行");
}
/**
* 后置强化方法
*
* @param bean bean实例(或者是被代理的bean)
* @param method 执行的方法对象
* @param args 方法参数
* @param context 任务线程运行时的上下文
*/
@Override
public void after(Object bean, Method method, Object[] args, ScheduledRunningContext context) {
System.out.println("定时任务执行成功后运行");
}
/**
* 异常强化方法
*
* @param bean bean实例(或者是被代理的bean)
* @param method 执行的方法对象
* @param args 方法参数
* @param context 任务线程运行时的上下文
*/
@Override
public void exception(Object bean, Method method, Object[] args, ScheduledRunningContext context) {
System.out.println("定时任务执行异常时运行");
}
/**
* Finally强化方法,出现异常也会执行
*
* @param bean bean实例(或者是被代理的bean)
* @param method 执行的方法对象
* @param args 方法参数
* @param context 任务线程运行时的上下文
*/
@Override
public void afterFinally(Object bean, Method method, Object[] args, ScheduledRunningContext context) {
System.out.println("定时任务执行完成后运行(异常时也运行)");
}
}
更多样例参考:
执行标记增强器:com.gyx.superscheduled.core.RunnableInterceptor.strengthen.ExecutionFlagStrengthen
执行日志增强器:com.gyx.superscheduled.core.RunnableInterceptor.strengthen.LogStrengthen
部署多服务的时候,会限制定时任务的执行,防止同一个任务在多个服务上反复运行
目前不支持设置的指定的定时任务
目前不支持统一的动态管理,只能单个逐一设置
spring.super.scheduled.plug-in.colony=true
#设置zookeeper地址,zookeeper集群多个地址用英文逗号隔开
spring.super.scheduled.zookeeper.url=127.0.0.1:2181
#设置zookeeper session超时时间,默认值为60秒
spring.super.scheduled.zookeeper.sessionTimeout=60000
#设置zookeeper连接超时时间,默认值为60秒
spring.super.scheduled.zookeeper.connectionTimeout=60000
- 只兼容原生@Scheduled注解cron属性
- 完全兼容原生@Scheduled注解
- 完善Manager功能
- 修复大量bug
- 添加api接口
- 添加定时任务线程池配置
- 添加扩展接口
- 添加定时任务调度日志
- 添加任务线程运行时上下文
- 添加跳过当前执行任务的能力
- 添加扩展类的执行优先级
- 添加基于zookeeper的集群模式
- 修复跳过单次运行产生的bug
- 后续加入可视化管理
- 集群任务统一管理