基于Spring Task框架的定时任务处理

发布时间:2024年01月12日

1.1 介绍

Spring Task 是Spring框架提供的任务调度工具,可以按照约定的时间自动执行某个代码逻辑。

  • 定位:定时任务框架

  • 作用:定时自动执行某段Java代码

  • 应用场景:

1). 信用卡每月还款提醒

2). 银行贷款每月还款提醒

3). 火车票售票系统处理未支付订单

强调:只要是需要定时处理的场景都可以使用Spring Task

1.2 cron表达式

cron表达式其实就是一个字符串,通过cron表达式可以定义任务触发的时间

构成规则:分为6或7个域,由空格分隔开,每个域代表一个含义

每个域的含义分别为:秒、分钟、小时、日、月、周、年(可选)

举例:

2022年10月12日上午9点整 对应的cron表达式为:0 0 9 12 10 ? 2022

说明:一般的值不同时设置,其中一个设置,另一个用?表示。

比如:描述2月份的最后一天,最后一天具体是几号呢?可能是28号,也有可能是29号,所以就不能写具体数字。

为了描述这些信息,提供一些特殊的字符。这些具体的细节,我们就不用自己去手写,因为这个cron表达式,它其实有在线生成器。

cron表达式在线生成器:在线Cron表达式生成器

可以直接在这个网站上面,只要根据自己的要求去生成corn表达式即可。所以一般就不用自己去编写这个表达式。

通配符:

* 表示所有值;

? 表示未说明的值,即不关心它为何值;

- 表示一个指定的范围;

, 表示附加一个可能值;

/ 符号前表示开始时间,符号后表示每次递增的值;

cron表达式案例:

*/5 * * * * ? 每隔5秒执行一次

0 */1 * * * ? 每隔1分钟执行一次

0 0 5-15 * * ? 每天5-15点整点触发

0 0/3 * * * ? 每三分钟触发一次

0 0-5 14 * * ? 在每天下午2点到下午2:05期间的每1分钟触发

0 0/5 14 * * ? 在每天下午2点到下午2:55期间的每5分钟触发

0 0/5 14,18 * * ? 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发

0 0/30 9-17 * * ? 朝九晚五工作时间内每半小时

0 0 10,14,16 * * ? 每天上午10点,下午2点,4点

1.3 入门案例

1.3.1 Spring Task使用步骤

1). 导入maven坐标 spring-context

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

2). 启动类添加注解 @EnableScheduling 开启任务调度

3). 自定义定时任务类

1.3.2 代码开发(例子*)

编写定时任务类:

进入xxx-server模块中

自定义定时任务类MyTask

package com.xxx.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 {
?
 ? ?/**
 ? ? * 定时任务 每隔5秒触发一次
 ? ? */
 ? ?@Scheduled(cron = "0/5 * * * * ?")
 ? ?public void executeTask(){
 ? ? ? ?log.info("定时任务开始执行:{}",new Date());
 ?  }
}

开启任务调度:

启动类添加注解 @EnableScheduling

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.transaction.annotation.EnableTransactionManagement;
?
@SpringBootApplication
@EnableTransactionManagement //开启注解方式的事务管理
@Slf4j
@EnableCaching
@EnableScheduling //开启任务调度
public class SkyApplication {
 ? ?public static void main(String[] args) {
 ? ? ? ?SpringApplication.run(SkyApplication.class, args);
 ? ? ? ?log.info("server started");
 ?  }
}

1.3.3 功能测试

启动服务,查看日志

每隔5秒执行一次。

二、实例代码(订单业务自动处理)

需求:待付款,超时自动取消,需求代码开发

开发步骤:

  • 定义触发时间

  • 明确查询条件

  • 获取查询数据

  • 将满足条件的数据更新

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 {
?
 ? ?@Autowired
 ? ?private OrderMapper orderMapper;
?
 ? ?/**
 ? ? * 处理超时订单的方法
 ? ? */
 ? ?@Scheduled(cron = "0 * * * * ? ") //每分钟触发一次
 ? ?public void processTimeoutOrder(){
 ? ? ? ?log.info("定时处理超时订单:{}", LocalDateTime.now());
 ? ? ? ? 
 ? ? ? ?//获得当前时间15分钟前的时间
 ? ? ? ?LocalDateTime time = LocalDateTime.now().plusMinutes(-15);
?
 ? ? ? ?// select * from orders where status = ? and order_time < (当前时间 - 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 * * ?") //每天凌晨1点触发一次
 ? ?public void processDeliveryOrder(){
 ? ? ? ?log.info("定时处理处于派送中的订单:{}",LocalDateTime.now());
?
 ? ? ? ?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);
 ? ? ? ? ?  }
 ? ? ?  }
 ?  }
}

mapper查询订单数据

 ?  
/**
 ? ? * 根据订单状态和下单时间查询订单
 ? ? * @param status
 ? ? * @param orderTime
 ? ? * @return
 ? ? */
 ?  @Select("select * from orders where status = #{status} and order_time < #{orderTime}")
 ?  List<Orders> getByStatusAndOrderTimeLT(Integer status, LocalDateTime orderTime);

订单数据库对象

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
?
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalDateTime;
?
/**
 * 订单
 */
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class Orders implements Serializable {
?
 ? ?/**
 ? ? * 订单状态 1待付款 2待接单 3已接单 4派送中 5已完成 6已取消
 ? ? */
 ? ?public static final Integer PENDING_PAYMENT = 1;
 ? ?public static final Integer TO_BE_CONFIRMED = 2;
 ? ?public static final Integer CONFIRMED = 3;
 ? ?public static final Integer DELIVERY_IN_PROGRESS = 4;
 ? ?public static final Integer COMPLETED = 5;
 ? ?public static final Integer CANCELLED = 6;
?
 ? ?/**
 ? ? * 支付状态 0未支付 1已支付 2退款
 ? ? */
 ? ?public static final Integer UN_PAID = 0;
 ? ?public static final Integer PAID = 1;
 ? ?public static final Integer REFUND = 2;
?
 ? ?private static final long serialVersionUID = 1L;
?
 ? ?private Long id;
?
 ? ?//订单号
 ? ?private String number;
?
 ? ?//订单状态 1待付款 2待接单 3已接单 4派送中 5已完成 6已取消 7退款
 ? ?private Integer status;
?
 ? ?//下单用户id
 ? ?private Long userId;
?
 ? ?//地址id
 ? ?private Long addressBookId;
?
 ? ?//下单时间
 ? ?private LocalDateTime orderTime;
?
 ? ?//结账时间
 ? ?private LocalDateTime checkoutTime;
?
 ? ?//支付方式 1微信,2支付宝
 ? ?private Integer payMethod;
?
 ? ?//支付状态 0未支付 1已支付 2退款
 ? ?private Integer payStatus;
?
 ? ?//实收金额
 ? ?private BigDecimal amount;
?
 ? ?//备注
 ? ?private String remark;
?
 ? ?//用户名
 ? ?private String userName;
?
 ? ?//手机号
 ? ?private String phone;
?
 ? ?//地址
 ? ?private String address;
?
 ? ?//收货人
 ? ?private String consignee;
?
 ? ?//订单取消原因
 ? ?private String cancelReason;
?
 ? ?//订单拒绝原因
 ? ?private String rejectionReason;
?
 ? ?//订单取消时间
 ? ?private LocalDateTime cancelTime;
?
 ? ?//预计送达时间
 ? ?private LocalDateTime estimatedDeliveryTime;
?
 ? ?//配送状态  1立即送出  0选择具体时间
 ? ?private Integer deliveryStatus;
?
 ? ?//送达时间
 ? ?private LocalDateTime deliveryTime;
?
 ? ?//打包费
 ? ?private int packAmount;
?
 ? ?//餐具数量
 ? ?private int tablewareNumber;
?
 ? ?//餐具数量状态  1按餐量提供  0选择具体数量
 ? ?private Integer tablewareStatus;
}
?
文章来源:https://blog.csdn.net/qq_63535554/article/details/135533921
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。