深圳企业高端网站建设,淘宝怎么提高关键词搜索排名,网站建设平台一般多少钱,心理网站模板文章目录 #x1f339;概述#x1f33a;应用场景#x1f384;cron表达式#x1f6f8;入门案例#x1f38d;实际应用 #x1f339;概述
Spring Task 是 Spring 框架提供的一种任务调度和异步处理的解决方案。可以按照约定的时间自动执行某个代码逻辑它可以帮助开发者在 S… 文章目录 概述应用场景cron表达式入门案例实际应用 概述
Spring Task 是 Spring 框架提供的一种任务调度和异步处理的解决方案。可以按照约定的时间自动执行某个代码逻辑它可以帮助开发者在 Spring 应用中轻松地实现定时任务、异步任务等功能提高应用的效率和可维护性。
Spring Task 的主要特点包括
简单易用Spring Task 提供了简洁的注解和配置方式使得任务调度和异步处理变得非常容易上手。内置支持Spring Task 内置于 Spring 框架中无需额外的依赖开发者可以直接在 Spring 应用中使用。灵活的任务调度Spring Task 支持基于 cron 表达式的定时任务调度能够满足各种复杂的调度需求。异步任务支持除了定时任务Spring Task 也支持异步任务的处理能够在后台线程中执行耗时操作提高系统的响应速度。集成注解Spring Task 提供了 Scheduled 注解用于标识定时任务的方法以及 Async 注解用于标识异步任务的方法使用起来非常方便。监控和管理Spring Task 支持任务的监控和管理可以通过 JMX 或者 Spring Boot Actuator 进行任务的查看和控制。
应用场景 信用卡每月还款提醒 银行贷款每月还款提醒 自动续费短信提醒 火车票售票系统处理未支付订单 入职纪念日为用户发送通知
下面我们来学习cron表达式通过cron表达式可以定义任务的触发时间
cron表达式
cron其实就是一个字符串可以用来定义任务触发的时间 (之前讲Linux的文章中有提到cron表达式crond的基本操作) 其实我们不用自己手写cron表达式 我们可以通过在线生成器来生成cron表达式https://cron.qqe2.com/
入门案例 使用的是黑马程序员的《苍穹外卖》项目的代码来进行学习 在启动类中加上EnableScheduling 新建一个task包和MyTask类 package com.sky.task;import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;import java.util.Date;Component
Slf4j
public class MyTask {//定时任务Scheduled(cron 0/5 * * * * ?)public void executeTask(){log.info(定时任务执行{},new Date());}
} 每隔5秒触发一次 上面我们完成了SpringTask入门案例的编写下面我们来讲解在《苍穹外卖》中的应用 实际应用 我们新创建一个类OrderTask package com.sky.task;import com.sky.entity.Orders;
import com.sky.mapper.OrderMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;import java.time.LocalDateTime;
import java.util.List;Component
Slf4j
public class OrderTask {Autowiredprivate OrderMapper orderMapper;//处理超时订单的方法Scheduled(cron 0 * * * * ? )//每分钟触发一次public void processTimeoutOrder(){log.info(定时处理超时订单{}, LocalDateTime.now());//获取当前时间并在当前时间的基础上减去 15 分钟LocalDateTime timeLocalDateTime.now().plusMinutes(-15);ListOrders ordersListorderMapper.getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT,time);if (ordersList!nullordersList.size()0){for (Orders orders:ordersList){orders.setStatus(Orders.CANCELLED);orders.setRejectionReason(订单超时已取消);orders.setCancelTime(LocalDateTime.now());orderMapper.update(orders);}}}//处理一直处于派送中状态的订单Scheduled(cron 0 0 1 * * ?)//每天凌晨一点触发一次public void processDeliveryOrder(){log.info(定时处理处于派送中的订单{},LocalDateTime.now());//获取当前时间并在当前时间的基础上减去 60 分钟LocalDateTime timeLocalDateTime.now().plusMinutes(-60);ListOrdersordersList orderMapper.getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS,time);if (ordersList!nullordersList.size()0){for (Orders orders:ordersList){orders.setStatus(Orders.CANCELLED);orderMapper.update(orders);}}}
} 进入OrderMapper接口里面编写sql 根据订单状态和下单时间查询订单 这样子我们就完成了
