深入浅出，SpringBoot整合Quartz实现定时任务与Redis健康检测（一）

目录

前言

环境配置

Quartz

什么是Quartz？

应用场景

核心组件

Job

JobDetail

Trigger

CronTrigger

SimpleTrigger

Scheduler

任务存储

RAM

JDBC

导入依赖

 定时任务

销量统计

Redis检测

使用

注意事项

前言

在悦享校园1.0中引入了Quartz框架实现了对于商家每日的销量统计功能，而目前项目已升级到SpringBoot版本，因此需要进行对应的代码进行调整。除此之外考虑到若Redis出现故障时或使用该项目不想要配置Redis时如何保证该项目正常启动呢？即当Redis出现故障时如何无缝切换到数据库查询数据而不是抛出错误信息？由于项目中整合Redis的客户端为Lettuce，因此可以考虑使定时任务实现对Redis服务的监测从而无感切换数据查询操作。

环境配置

JDK 1.8

Spring Boot 2.7.12

lettuce 6.1.10(包含在Spring-Boot-Starter-Data-Redis中)

Quartz 2.3.2

Quartz

什么是Quartz？

根据官方文档描述，Quartz 是一种功能丰富的，开放源码的作业调度库，可以在集成在任何的Java应用程序中，小到独立的应用程序，大到复杂的电子商务系统。 Quartz可以用来创建简单或复杂的日程安排执行几十，几百，甚至数以万计的作业数，作业被定义为标准的Java组件，可以通过编程使其执行。

应用场景

如文章开头所述，当我们需要统计店铺的每日销量或者每周销量时，可以通过一个定时任务来执行相应的操作。以及Redis由于长时间不使用时可能会造成客户端除此之外，也可以将Quartz使用到如定期发送消息通知，如获取每日天气进行邮件推送到指定客户等其它的操作。这些都可通过Quartz来实现。除此之外Quartz还能完成其它复杂的任务。

核心组件

Job

用于存放真正需要定时执行的任务逻辑

JobDetail

用于对任务信息的相关描述，如任务名称、任务分组等。需要注意的是，JobDetail中含有一个Key属性，该属性将通过传入的任务名称和分组名称构建Key，若参数为空时则通过UUID来构建，从而确保该Key是唯一的。因此相同的任务名称和组名会覆盖之前的任务，这一点是需要注意的。

使用JobDetail+Job方式的设计，可以避免在并发情况下，对同一个实例的访问问题。

可以通过JobDataMap将数据存储并将数据传给Job实例。

Trigger

Trigger即为触发器，用于指定将以何种方式执行定时任务，注意Trigger与JobDetail一一对应，即一个触发器只做用于一个定义任务上。以下为两种常用的触发器：

CronTrigger

其核心在于使用Cron表达式进行任务的构建，如下是一个表示每月最后一天执行任务的Cron表达式：

# 每月的最后1天0 0 L * * *说明：Linux*    *    *    *    *-    -    -    -    -|    |    |    |    ||    |    |    |    +----- day of week (0 - 7) (Sunday=0 or 7) OR sun,mon,tue,wed,thu,fri,sat|    |    |    +---------- month (1 - 12) OR jan,feb,mar,apr ...|    |    +--------------- day of month (1 - 31)|    +-------------------- hour (0 - 23)+------------------------- minute (0 - 59)

鉴于网上关于Cron表达式的文章非常多，这里不做过多赘述。这里列举几个常用的Cron表达式：

（1）0/2 * * * * ?   表示每2秒 执行任务

（2）0 0/2 * * * ?    表示每2分钟 执行任务

（3）0 0 2 1 * ?   表示在每月的1日的凌晨2点调整任务

（4）0 15 10 ? * MON-FRI   表示周一到周五每天上午10:15执行作业

（5）0 0 10,14,16 * * ?   每天上午10点，下午2点，4点 

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

可以通过Crontab.guru - The cron schedule expression editor 网站来验证Cron表达式。

SimpleTrigger

相比于上述提到的Cron表达式，SimpleTrigger来构建一些指定间隔时间执行的任务更加容易，如每隔75s执行某个任务，则使用SimpleTrigger更佳。

Scheduler

任务调度器，它可以JobDetail与Trigger关联起来，通过任务调度器将启动任务的执行。一个任务调度器中可以包含多个关联的实例。

任务存储

Quartz提供了两种定时任务存储功能，一种为RAM，另一种为JDBC。

RAM

默认情况下Quartz会将任务数据存储到内存中，优点为任务读取速度快，简单易用。但缺点是随着服务重启会导致任务丢失。(本文采用该方式）

JDBC

Quartz提供了对定时任务持久化的功能，可以通过创建对应的数据表将定时任务持久化到数据库中，如此一来可以确保任务不会因为服务重启而丢失，可以更好的管理任务。缺点是需要额外的进行数据库表创建。本文采用默认的RAM方式存储，可以自行通过具体需求场景来选择。

导入依赖

由于本文项目使用了SpringBoot，因此导入如下依赖即可

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

 定时任务

任务创建可以通过继承 QuartzJobBean 类并重写其excuteInternal方法，或实现 Job 接口的excute方法，从QuartzJobBean的源码可知，其实现了Job接口，因此以上的创建方式任选其一即可。  

销量统计

销量统计任务类，此处仅使用日志打印体现，具体的业务逻辑可自行编写

@Slf4j
public class SellDailyJob extends QuartzJobBean {@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {log.info("这是每日销量统计定时任务。。。");}
}

执行规则配置类

@Configuration
public class SellDailyConfig{@Bean("sellDailyJob")public JobDetail jobDetail(){// 指定任务执行的类return JobBuilder.newJob(SellDailyJob.class)// 任务名称和分组名,不可重复.withIdentity("sellDailyJob", "group").withDescription("任务描述：内存方式运行").storeDurably().build();}@Bean("sellDailyTrigger")public Trigger trigger() {return TriggerBuilder.newTrigger()// 触发器名和分组名,不可重复.withIdentity("trigger", "group").forJob(jobDetail()).startNow()// 使用Cron表达式构建执行事件 每5s执行一次.withSchedule(CronScheduleBuilder.cronSchedule("0/5 * * * * ?")).build();}}

Redis检测

Redis健康检测定时任务类，构建方法同上

@Slf4j
public class RedisCheckJob extends QuartzJobBean {@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {log.info("这是Redis定时心跳任务");}
}

执行规则配置类

@Configuration
@Slf4j
public class RedisCheckConfig {// 指定生成的Bean实例对象名称@Bean("redisCheck")public JobDetail jobDetail() {return JobBuilder.newJob(RedisCheckJob.class)// 任务名和任务分组.withIdentity("RedisCheckJob", "group").withDescription("任务描述：内存方式运行").storeDurably().build();}@Bean("redisTrigger")public Trigger trigger() {return TriggerBuilder.newTrigger()// 触发器名称和分组.withIdentity("redisCheck", "group").forJob(jobDetail()).startNow()// 使用SimpleSchedule构建定时任务.withSchedule(SimpleScheduleBuilder.simpleSchedule()// 每隔10s执行任务.withIntervalInSeconds(10)// 永不过期.repeatForever()).build();}
}

使用

上个部分中分别使用CronTrigger和SimpleTrigger构建了两种定时任务，而根据SpringBoot官方文档中所示，当Quartz可用时，SchedulerFactoryBean会将Scheduler自动装配到容器中，因此在SpringBoot中使用@Configuration+@Bean注解构建定时任务后，无需显式创建Scheduler，SpringBoot会自动加载这些定时任务交由Scheduler调度。

因此配置完成后只需启动应用程序即可，执行结果如下所示。

注意事项

1.以上构建定时任务时需要创建任务类并在其中写入自定义的业务方法。并在配置类newJob中写入对应任务类。jobDetail和Trigger方法使用@Bean注解构建时，需要指定名称且不重复，否则其它配置类无法正常构建Bean实例。

2.jobDetail方法和trigger方法中的withIdentity应分别指定不同任务名和任务分组，需要保证其它配置类中以上两个属性之中至少有一个属性不同，否则同样将造成定时任务无法正常执行。（eg：A配置类中的任务名为work，分组名为group，B中配置与之相同则会导致A服务无法正常运行）

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/125013.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

# Flink的状态

# Flink的状态

1.什么是时状态(state)&#xff1f; 有状态的计算是流处理框架要实现的重要功能&#xff0c;因为稍复杂的流处理场景都需要记录状态&#xff0c;然后在新流入数据的基础上不断更新状态。 例如以下状态都需要使用流处理的状态功能&#xff1a; 数据流中的数据有重复&#xff0c…
阅读更多...
模块化CSS

模块化CSS

1、什么是模块化CSS 模块化CSS是一种将CSS样式表的规则和样式定义封装到模块或组件级别的方法&#xff0c;以便于更好地管理、维护和组织样式代码。这种方法通过将样式与特定的HTML元素或组件相关联&#xff0c;提供了一种更具可维护性、可复用性和隔离性的方式来处理样式。简单…
阅读更多...
【3】c++设计模式——＞UML表示类之间的关联关系

【3】c++设计模式——＞UML表示类之间的关联关系

关联关系 关联&#xff08;Assocition&#xff09;关系是类与类之间最常见的一种关系&#xff0c;它是一种结构化的关系&#xff0c;表示一个对象与另一个对象之间有联系&#xff0c;如汽车和轮胎、师傅和徒弟、班级和学生等。在UML类图中&#xff0c;用&#xff08;带接头或不…
阅读更多...
(一)gitblit安装教程

(一)gitblit安装教程

(一)gitblit安装教程 (二) gitblit用户使用教程 (三) gitblit管理员手册 目录 前言安装1.下载Java Runtime Requirement 2.设置环境变量3.gitblit内容3.1 gitblit文件夹内容3.2 defaults.properties 主要配置选项 4 配置4.1 准备文件4.2 修改gitblit.properties4.3 修改authori…
阅读更多...
zookeeper mac安装

zookeeper mac安装

目录 1.下载zookeeper安装包 2.解压安装包 3.修改配置文件 4.启动服务端 5.启动客户端 这边工作中用到了zookeeper组件&#xff0c;但自己独立安装弄的不太多&#xff0c;这边本机mac装一个做测试使用 以下是安装记录&#xff0c;可以作为参考 从以下链接zookeeper版本列…
阅读更多...
【成像光敏描记图提取和处理】成像-光电容积描记-提取-脉搏率-估计（Matlab代码实现）

【成像光敏描记图提取和处理】成像-光电容积描记-提取-脉搏率-估计（Matlab代码实现）

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…
阅读更多...
Flutter笔记：手写并发布一个人机滑动验证码插件

Flutter笔记：手写并发布一个人机滑动验证码插件

Flutter笔记 手写一个人机滑块验证码 作者&#xff1a;李俊才 &#xff08;jcLee95&#xff09;&#xff1a;https://blog.csdn.net/qq_28550263 邮箱 &#xff1a;291148484163.com 本文地址&#xff1a;https://blog.csdn.net/qq_28550263/article/details/133529459 写 Flut…
阅读更多...
System Generator初体验FIR滤波器

System Generator初体验FIR滤波器

文章目录 前言一、介绍1、目标2、过程 二、步骤 1&#xff1a;在 FPGA 中创建设计1、打开 Lab1_1.slx 文件2、运行仿真3、使用 System Generator 创建 FIR 滤波器<1>、从库浏览器寻找需要的模块<2>、配置系统生成器块<3>、在 FPGA 上实现设计 三、步骤 2&…
阅读更多...
线程的详解

线程的详解

创建状态 就绪状态 阻塞状态 运行状态 死亡状态 常用方法 setPriority(ing newPriority) 更改线程的优先级 sleep(long millis) 在指定的毫秒数内让当前正在执行的线程休眠 join() 等待该线程终止 yield() 暂停当前正在执行的线程对象&#xff0c;并执行其他线程 inte…
阅读更多...
【Linux进行时】进程地址空间

【Linux进行时】进程地址空间

进程地址空间 例子引入&#xff1a; 我们在讲C语言的时候&#xff0c;老师给大家画过这样的空间布局图&#xff0c;但是我们对它不了解 我们写一个代码来验证Linux进程地址空间 #include<stdio.h> #include<assert.h> #include<unistd.h> int g_value100; …
阅读更多...
Chrome之解决DevTools: Failed to load data:No resource with given identifier found

Chrome之解决DevTools: Failed to load data:No resource with given identifier found

问题 使用DevTools抓包时候, 有些跨域请求无法在加载出来, 提示 Failed to load data:No resource with given identifier found 解决办法 换其他浏览器 下断点 打开DevTools, 选择源代码/来源/Sources,找到事件监听器断点/Event Listener Breakpoints, 找到加载/Load下面…
阅读更多...
＜学习笔记＞从零开始自学Python-之-常用库篇（十二）Matplotlib

＜学习笔记＞从零开始自学Python-之-常用库篇（十二）Matplotlib

Matplotlib 是Python中类似 MATLAB的绘图工具&#xff0c;Matplotlib是Python中最常用的可视化工具之一&#xff0c;可以非常方便地创建2D图表和一些基本的3D图表&#xff0c;可根据数据集&#xff08;DataFrame&#xff0c;Series&#xff09;自行定义x,y轴&#xff0c;绘制图…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023