1、添加依赖:
在pom.xml
文件中添加Spring Boot的定时任务依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
2、创建定时任务类:
创建一个Java类,用于定义定时任务的逻辑。在该类中使用@Scheduled
注解指定定时任务的执行时间,并编写批量新增的逻辑。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component // 表明这是一个Spring组件
public class BatchAddTask {
@Autowired
private YourService yourService; // 注入批量新增的服务
// 每天凌晨1点执行一次批量新增任务
@Scheduled(cron = "0 0 1 * * ?")
public void batchAdd() {
// 调用服务类的方法执行批量新增操作
yourService.performBatchAdd();
}
}
3、编写批量新增逻辑:
在服务类中编写批量新增的逻辑。
import org.springframework.stereotype.Service;
@Service // 声明这是一个服务类
public class YourService {
public void performBatchAdd() {
// 执行批量新增操作的逻辑
// 可以从数据库或其他数据源获取数据,并进行批量插入操作
// 示例代码:
// yourRepository.batchInsert(yourDataList);
}
}
4、@Scheduled属性
在使用Spring的定时任务时,可以通过@Scheduled
注解的属性来配置定时任务的执行时间。以下是常用的@Scheduled
注解属性:
cron:用于配置Cron表达式,指定定时任务的执行时间规则。Cron表达式由6或7个空格分隔的字段组成,分别表示秒、分、小时、日期、月份、星期和年份(可选)。例如,
cron = "0 0 1 * * ?"
表示每天凌晨1点执行一次任务。fixedDelay:用于指定两次任务执行之间的固定延迟时间,单位为毫秒。例如,
fixedDelay = 5000
表示当前任务执行完成后,等待5秒后再执行下一次任务。fixedRate:用于指定两次任务开始执行的固定时间间隔,单位为毫秒。例如,
fixedRate = 60000
表示每隔1分钟执行一次任务,不论任务的执行时间。initialDelay:用于指定定时任务首次执行的延迟时间,单位为毫秒。例如,
initialDelay = 10000
表示首次执行任务前等待10秒。zone:用于指定时区,影响Cron表达式的解析和定时任务的执行时间。默认情况下,定时任务使用服务器的时区。
这些属性可以根据实际需求组合使用,以满足不同场景下的定时任务需求。例如,可以使用cron
属性配置复杂的定时任务规则,而使用fixedDelay
或fixedRate
属性配置简单的周期性任务。
5、优化方案
当前实现是单线程的,如果批量新增的数据量很大,可能会导致定时任务执行时间过长,影响系统的响应性能。可以考虑使用多线程或异步任务来提高批量新增的效率。
配合线程池使用
当实现SchedulingConfigurer
接口时,您可以对Spring的定时任务进行更加细致和定制化的配置。以下是一些更详细的用法示例:
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
@Configuration
public class CustomSchedulingConfigurer implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(taskScheduler());
}
public Executor taskScheduler() {
// 创建一个自定义的线程池,可根据需求设置线程池大小、线程名称等属性
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5); // 设置核心线程数
executor.setMaxPoolSize(10); // 设置最大线程数
executor.setThreadNamePrefix("custom-task-executor-"); // 设置线程名称前缀
executor.setQueueCapacity(100); // 设置任务队列容量
executor.initialize();
return executor;
}
}