java4 -- SpringBoot定时任务调度
作者:互联网
一、定时删除数据库记录
首先,这个是根据业务要求的,比如是业务要求的是删除7天之前的所有记录,只保留近7天的数据,那么首先就先在数据库中修改SQL语句。
由于使用的是springBoot + Mybatis 所以需要修改的就是mappers.xml文件。
<delete id="delete*"
parameterType="com.windaka.suizhi.switchcloudtest.model.*">
delete
from
表
where DATE(time) < DATE(DATE_SUB(NOW(),INTERVAL 7 DAY))
// 代表时间是今天到7天前的时间范围
</delete>
之后,再写一个schedule配置文件
package com.*.schedul;
import com.*.dao.*;
import com.*.dao.*;
import com.*.model.*;
import com.*.model.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
/**
* Created with IntelliJ IDEA.
* 定时任务
* @Author:
* @Date: 2021/12/30/9:42
* @Version 1.0
* @return
* @Description:
*/
@Component
@EnableCaching
@EnableScheduling
@Slf4j
public class ScheduleConfig {
@Autowired
private *Mapper *Mapper;
/**
* 一分钟清理一次 ccar(车辆抓拍) 中多余的信息 防止数据堆积
* @author
* @date 10:09 2021/12/30
* @param
* @return
* @other
**/
//每天中午12点触发一次
@Scheduled(cron = "0 0 12 * * ?")
public void cleanCar() {
try {
*Car *car = new *Car();
*Mapper.delete*(*car);
System.out.println("车辆抓拍记录删除成功!");
}catch (Exception e){
log.error("删除7天前的车辆抓拍记录失败!"+e.getMessage());
}
}
}
注意:该代码只是一个案例,把一些具体的对象以*号表示,不能直接运行。
二、定时调用某个接口/方法
是SpringBoot项目中的定时器 (SpringBoot中的任务调度),如果是springboot项目,针对于某一个方法的调用,使用起来比较方便。
首先,在启动类上添加注解@EnableScheduling
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
@EnableScheduling
public class SwitchCloudOnemachineOnegearApplication {
public static void main(String[] args) {
SpringApplication.run(SwitchCloudOnemachineOnegearApplication.class, args);
}
}
其次在需要使用任务调度的类上面加注解 @Component,使该类被Spring管理
之后在所要定时调度的方法上加上注解@Scheduled(cron=“0 0 0 * * ?”)。以下介绍@scheduled的属性
- cron属性:时间表达式
- fixedRate属性:上一个调用开始后再次调用的延时(再次调用时不需要等上一个调用执行完成)
- fixedDelay属性:上一个调用完成后再次调用的延时(再次调用时需要等上一个调用执行完成)
- initialDelay属性:第一次调用时的延迟时间
案例
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component
public class ScheduleTest {
//每1秒执行一次该方法
@Scheduled(fixedRate = 1000)
public void test1() {
System.out.println("定时调度1------");
}
//每天12点执行一次该方法
@Scheduled("0 0 12 * * ?")
public void test2() {
System.out.println("定时调度2------");
}
}
有时候,如果任务调度需要配合异步功能,那么类上需要加上@EnableAsync注解,该注解是加在类上的
参考来源:https://blog.csdn.net/Eternal_Blue/article/details/94442770
标签:Scheduled,调用,--,springframework,java4,import,org,任务调度,public 来源: https://blog.csdn.net/snwown/article/details/122844148