百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

一分钟看懂Springboot整合Quartz实现任务调度

yuyutoo 2024-11-01 15:55 4 浏览 0 评论

1、pom中导入quartz的依赖

<dependency>     
  <groupId>org.springframework.boot</groupId>     
  <artifactId>spring-boot-starter-quartz</artifactId>     
  <version>2.1.17.RELEASE</version>    
</dependency>

版本号和你导入的boot的版本一直即可。

2、编写Quartz的执行类

编写一个类继承QuartzJobBean,其关键对象分为三个:

1、调度工作类:org.springframework.scheduling.quartz.JobDetailBean,该对象通过jobClass属性指定调度工作类;

2、调度触发器:org.springframework.scheduling.quartz.CronTriggerBean,该对象通过jobDetail属性指定工作类,通过cronExpression属性指定调度频率;

3、调度工厂类:org.springframework.scheduling.quartz.SchedulerFactoryBean,该对象通过triggers属性指定单个或多个触发器。

以下为我自己编写的取消订单的定时器类:

public class CancelOrderJob  extends QuartzJobBean implements Serializable {

    private static Logger logger = LoggerFactory.getLogger(CancelOrderJob.class);
    private IUserOrderService userOrderService;

    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        Date date=new  Date();
        logger.info("取消未支付订单定时器开始执行了,开始时间:"+date.getTime());
        try {
            userOrderService = SpringUtils.getBean(IUserOrderService.class);
            userOrderService.cancelOrderJob();
            logger.info("取消未支付订单的定时器执行结束了,结束时间:"+new Date());
        } catch (BeansException e) {
            e.printStackTrace();
        }
    }
}

自定义CancelOrderJob类实现了QuartzJobBean 然后重新其executeInternal方法, 使用SpringUtils工具类来获取你要操作的接口类对象,然后调用方法即可。

3、编写QuartzConfig配置类

主要配置以上说的三个对象,

@Configuration
public class QuartzConfig {
}

一定要记得在你的配置类上添加@Configuration注解,否则无法生效。

@Bean
public JobDetail cancelOrderJobDetail(){
    return JobBuilder.newJob(CancelOrderJob.class)//PrintTimeJob我们的业务类
            .withIdentity("cancelOrderJob")//可以给该JobDetail起一个id
            .storeDurably()//即使没有Trigger关联时,也不需要删除该JobDetail
            .build();
}

@Bean
public Trigger cancelOrderJobTrigger() {
    CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0 */1 * * * ?");
    return TriggerBuilder.newTrigger()
            .forJob(cancelOrderJobDetail())//关联上述的JobDetail
            .withIdentity("cancelOrderTrigger")//给Trigger起个名字
            .withSchedule(cronScheduleBuilder)
            .build();
}

cancelOrderJobDetail 创建具体的工作任务对象。

cancelOrderJobTrigger 创建该工作的触发器并绑定工作任务对象和触发的时间cron表达式。

4、导入数据库表

因为需要和数据库一起使用在配置好这些后一定要记得数据库导入quartz对应的11张表。

5、cron表达式

Cron表达式是一个字符串,字符串以5或6个空格隔开,分为6或7个域,每一个域代表一个含义,Cron有如下两种语法格式:

Seconds Minutes Hours DayofMonth Month DayofWeek Year
Seconds Minutes Hours DayofMonth Month DayofWeek


Seconds:可出现",- * /"四个字符,有效范围为0-59的整数
Minutes:可出现", - * /"四个字符,有效范围为0-59的整数
Hours:可出现", - * /"四个字符,有效范围为0-23的整数
DayofMonth:可出现", - * / ? L W C"八个字符,有效范围为0-31的整数
Month:可出现", - * /"四个字符,有效范围为1-12的整数或JAN-DEc
DayofWeek:可出现", - * / ? L C #"四个字符,有效范围为1-7的整数或SUN-SAT两个范围。1表示星期天,2表示星期一, 依次类推
Year:可出现", - * /"四个字符,有效范围为1970-2099年

6、Cron表达式范例:

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

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

每天23点执行一次:0 0 23 * * ?

每天凌晨1点执行一次:0 0 1 * * ?

每月1号凌晨1点执行一次:0 0 1 1 * ?

每月最后一天23点执行一次:0 0 23 L * ?

每周星期天凌晨1点实行一次:0 0 1 ? * L

在26分、29分、33分执行一次:0 26,29,33 * * * ?

每天的0点、13点、18点、21点都执行一次:0 0 0,13,18,21 * * ?

相关推荐

【Socket】解决UDP丢包问题

一、介绍UDP是一种不可靠的、无连接的、基于数据报的传输层协议。相比于TCP就比较简单,像写信一样,直接打包丢过去,就不用管了,而不用TCP这样的反复确认。所以UDP的优势就是速度快,开销小。但是随之...

深入学习IO多路复用select/poll/epoll实现原理

Linux服务器处理网络请求有三种机制,select、poll、epoll,本文打算深入学习下其实现原理。0.结论...

25-1-Python网络编程-基础概念

1-网络编程基础概念1-1-基本概念1-2-OSI七层网络模型OSI(开放系统互联)七层网络模型是国际标准化组织(ISO)提出的网络通信分层架构,用于描述计算机网络中数据传输的过程。...

Java NIO多路复用机制

NIO多路复用机制JavaNIO(Non-blockingI/O或NewI/O)是Java提供的用于执行非阻塞I/O操作的API,它极大地增强了Java在处理网络通信和文件系统访问方面的能力。N...

Python 网络编程完全指南:从零开始掌握 Socket 和网络工具

Python网络编程完全指南:从零开始掌握Socket和网络工具在现代应用开发中,网络编程是不可或缺的技能。Python提供了一系列高效的工具和库来处理网络通信、数据传输和协议操作。本指南将从...

Rust中的UDP编程:高效网络通信的实践指南

在实时性要求高、允许少量数据丢失的场景中,UDP(用户数据报协议)凭借其无连接、低延迟的特性成为理想选择。Rust语言凭借内存安全和高性能的特点,为UDP网络编程提供了强大的工具支持。本文将深入探讨如...

Python 网络编程的基础复习:理解Socket的作用

计算机网络的组成部分在逻辑上可以划分为这样的结构五层网络体系应用层:应用层是网络协议的最高层,解决的是具体应用问题...

25-2-Python网络编程-TCP 编程示例

2-TCP编程示例应用程序通常通过“套接字”(socket)向网络发出请求或者应答网络请求,使主机间或者一台计算机上的进程间可以通信。Python语言提供了两种访问网络服务的功能。...

linux下C++ socket网络编程——即时通信系统(含源码)

一:项目内容本项目使用C++实现一个具备服务器端和客户端即时通信且具有私聊功能的聊天室。目的是学习C++网络开发的基本概念,同时也可以熟悉下Linux下的C++程序编译和简单MakeFile编写二:需...

Python快速入门教程7:循环语句

一、循环语句简介循环语句用于重复执行一段代码块,直到满足特定条件为止。Python支持两种主要的循环结构:for循环和while循环。...

10分钟学会Socket通讯,学不会你打我

Socket通讯是软硬件直接常用的一种通讯方式,分为TCP和UDP通讯。在我的职业生涯中,有且仅用过一次UDP通讯。而TCP通讯系统却经常写,正好今天写了一个TCP通讯的软件。总结一下内容软件使用C#...

Python 高级编程之网络编程 Socket(六)

一、概述Python网络编程是指使用Python语言编写的网络应用程序。这种编程涉及到网络通信、套接字编程、协议解析等多种方面的知识。...

linux网络编程Socket之RST详解

产生RST的三个条件:1.目的地为某端口的SYN到达,然而该端口上没有正在监听的服务器;2.TCP想取消一个已有的连接;3.TCP接收到一个根本不存在的连接上的分节;现在模拟上面的三种情况:cl...

ABB机器人编程实用技巧,多项案例

...

Python中实现Socket通讯(附详细代码)

套接字(socket)是一种在计算机网络中进行进程间通信的方法,它允许不同主机上的程序通过网络相互通信。套接字是网络编程的基础,几乎所有的网络应用程序都使用某种形式的套接字来实现网络功能。套接字可以用...

取消回复欢迎 发表评论: