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 {@Autowiredprivate 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 {@Overridepublic 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;}
}
