在企业应用中,Spring Task作为Spring框架的内置功能,提供了简便的注解驱动定时任务调度,适合处理轻量级、简单的调度需求,如定期数据同步或清理临时文件。它与Spring生态无缝集成,减少了外部依赖,但对于高并发或复杂调度场景略显不足,可能需要结合更专业的调度工具使用
目录
Spring Task简介
Spring Task特性
Spring Boot集成Spring Task
首先,第一步,引入依赖
第二步,配置启用定时任务
第三步,创建定时任务
应用场景举例
注意事项
应用场景分析
Spring Task简介
Spring Task 是 Spring 框架提供的一个轻量级的任务调度工具,它使得在 Spring 应用中执行定时任务变得简单。Spring Task 可以很好地集成到 Spring 的环境中,利用 Spring IoC 容器的优势来管理任务的生命周期和依赖关系。
Spring Task特性
- 注解驱动:通过使用
@Scheduled
注解,可以很方便地定义定时任务。 - 灵活的调度配置:支持基于固定速率、固定延迟以及 Cron 表达式的调度方式。
- 线程池支持:可以通过配置
TaskScheduler
或者Executor
来自定义调度任务的线程池,从而控制并发度和资源使用情况。 - 与Spring环境无缝集成:作为Spring框架的一部分,能够轻松与其他Spring功能(如依赖注入)结合使用。
Spring Boot集成Spring Task
首先,第一步,引入依赖
事实上,在Spring Boot项目中,只要起步依赖即可,因为如下图所示:
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency>
Spring-Context已经被集成在spring-boot-starter中了
第二步,配置启用定时任务
在 Spring Boot 应用程序中,只需在主类或配置类上添加 @EnableScheduling
注解即可开启对定时任务的支持:
@EnableScheduling//开启任务调度
public class SkyApplication {public static void main(String[] args) {SpringApplication.run(SkyApplication.class, args);log.info("server started");}
}
第三步,创建定时任务
创建一个普通的 Spring Bean,并在其中定义方法,然后使用 @Scheduled
注解来指定该方法应何时执行。
/*** 自定义定时任务类*/
@Component
@Slf4j
public class MyTask {@Scheduled(cron = "0/5 * * * * ?")public void executeTask(){log.info("定时任务开始执行:{}",new Date());}
}
执行结果如下:(每隔五秒执行一次)
在@Scheduled
注解中配置的是cron表达式,如果你不会也没关系,描述需求,然后让Al生成即可。
应用场景举例
以下代码是苍穹外卖的处理订单的状态的定时任务类。有两个方法,分别是处理超时订单的方法和处理一直处于派送中的订单方法。
需求分别是:
1.要求用户下单15分钟后修改订单的状态,如果用户下单15分钟后还是待付款,就修改为已取消。
2.要求处理上一天的订单,即凌晨一点就把所有订单状态在派送中修改为已完成。
需求分析:都需要在规定时间中或定时区间中处理业务,所以可以采取Spring Task任务调度工具。
代码实现:
/*** 定时任务类 定时处理订单状态*/@Component
@Slf4j
public class OrderTask {@Autowiredprivate OrderMapper orderMapper;/*** 处理超时订单的方法*///@Scheduled(cron = "0 * * * * ?")//每分钟触发一次//@Scheduled(cron = "1/5 * * * * ?")public void processTimeoutOrder(){log.info("定时处理超时订单:{}", LocalDateTime.now());LocalDateTime time = LocalDateTime.now().plusMinutes(-15);// 超时的订单 下单时间 < 当前时间 - 15分钟List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT, time);if (ordersList == null && ordersList.size() > 0){for (Orders orders : ordersList) {orders.setStatus(Orders.CANCELLED);orders.setCancelReason("订单超时,自动取消");orders.setCancelTime(LocalDateTime.now());orderMapper.update(orders);}}}/*** 处理一直处于派送中的订单*/// @Scheduled(cron = "0 0 1 * * ?")//每天凌晨一点触发一次// @Scheduled(cron = "0/5 * * * * ?")public void processDeliveryOrder(){log.info("定时处理处于派送中的订单:{}",LocalDateTime.now());// 一直处于派送中的订单 下单时间 < 当前时间 - 60分钟LocalDateTime time = LocalDateTime.now().plusMinutes(-60);List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS, time);if(ordersList != null && ordersList.size() > 0){for (Orders orders : ordersList) {orders.setStatus(Orders.COMPLETED);orderMapper.update(orders);}}}
}
注意事项
- 并发问题:默认情况下,Spring Task 并不保证方法调用之间的顺序,如果定时任务之间存在共享资源的竞争,需考虑适当的同步机制。
- 异常处理:如果定时任务抛出未捕获的异常,默认情况下它将停止运行。可以考虑使用 try-catch 块来捕获异常并进行适当处理。
- 自定义线程池(可选):可以通过配置
TaskScheduler
或者Executor
来自定义任务执行的线程池大小、队列容量等参数,以更好地控制资源使用情况。
应用场景分析
- 定时数据同步:比如每天凌晨从第三方API获取最新的数据并更新到本地数据库中。
- 定期清理过期数据:例如每个月底删除数据库中超过一年未被访问的数据记录。
- 发送定时通知:如每周一早上9点自动发送周报邮件给团队成员。
- 周期性健康检查:对系统中的关键服务进行定时健康检查,并在发现问题时发送告警信息。
- 缓存刷新:根据特定的时间间隔或条件触发缓存的更新操作,确保数据的新鲜度。