【十】springboot整合quartz实现定时任务优化

简介: 【十】springboot整合quartz实现定时任务优化


       介绍:接下来我会把学习阶段学到的框架等知识点进行整合,每一次整合是在前一章的基础上进行的,所以后面的整合不会重复放前面的代码。每次的demo我放在结尾,本次是接着上一章的内容延续的,只增加新增的或者修改的代码。

       上一章是改造整合redis实现启动服务即将热点数据保存在全局以及redis中,方便其他接口使用,本章整合quartz框架,实现定时任务的优化,前面整合的定时任务是使用的spring的Scheduled注解方式实现的,本章整合quartz任务调度框架。

Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的程序。而Scheduled只适合处理简单的计划任务。

Quartz的主要组件有Detail,Trigger,Scheduler以及Job,大概流程就是(我自己的话来说,不一定正确),新建一个Job,在Job里面写自己的逻辑,新建一个配置类,里面建立Detail方法来绑定Job,再新建Trigger方法,在方法里新建一个Scheduler,并在该Trigger方法里绑定Detail和Scheduler,让该Scheduler执行Detail,一个Detail绑定一个Job。

       先展示一下我的目录结构:

       勾选部分为相比上一章新增部分。

第一步:导入Pom依赖

第二步:改造各层代码

       新增了两个方法,一个查询code表中的用户数量(用于测试),一个修改用户数量。

第三步:新增Job

       ps:新增Job类继承QuartzJobBean,并重写QuartzJobBean的executeInternal方法。注意此处的jobExecutionContext参数,在Detail绑定该Job之后,可以传参数过来,通过该参数可以在Job中获取传过来的参数。获取方式如上图。该Job用来修改用户数量。

第四步:新增quartz配置类(编写Trigger和Detail)

@Configuration
public class QuartzConfiguration {
 
    @Bean
    public JobDetail MyJob1JobDetail(){
        return JobBuilder.newJob(MyJob1.class)//PrintTimeJob我们的业务类
                .withIdentity("MyJob1")//可以给该JobDetail起一个id
                //每个JobDetail内都有一个Map,包含了关联到这个Job的数据,在Job类中可以通过context获取
                .usingJobData("MyJob1", "Hello Quartz")//关联键值对
                .storeDurably()//即使没有Trigger关联时,也不需要删除该JobDetail
                .build();
    }
    @Bean
    public Trigger MyJob1JobTrigger() {
        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/30 * * * * ? *");//每30秒执行
        return TriggerBuilder.newTrigger()
                .forJob(MyJob1JobDetail())//关联上述的JobDetail
                .withIdentity("MyJob1JobTrigger")//给Trigger起个名字
                .withSchedule(cronScheduleBuilder)
                .build();
    }
 
    @Bean
    public JobDetail MyJob2JobDetail(){
        return JobBuilder.newJob(MyJob2.class)//PrintTimeJob我们的业务类
                .withIdentity("MyJob2")//可以给该JobDetail起一个id
                //每个JobDetail内都有一个Map,包含了关联到这个Job的数据,在Job类中可以通过context获取
                .usingJobData("MyJob2", "Hello Quartz")//关联键值对
                .storeDurably()//即使没有Trigger关联时,也不需要删除该JobDetail
                .build();
    }
    @Bean
    public Trigger MyJob2JobTrigger() {
        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/30 * * * * ? *");//每30秒执行
        return TriggerBuilder.newTrigger()
                .forJob(MyJob2JobDetail())//关联上述的JobDetail
                .withIdentity("MyJob2JobTrigger")//给Trigger起个名字
                .withSchedule(cronScheduleBuilder)
                .build();
    }
 
}

       ps:不要忘记Configuration注解。下面解释Detail和Trigger的编写。

       newJob是设置需要绑定的Job的类型,withIdentity是给该detail取个名字,usingJobData是给该detail存储数据,可以在绑定的Job中通过Context获取此处绑定的值通过key-value方式获取。

       新建一个CronScheduleBuilder用来维护定时任务环境,并让触发器生效,可以设置cron表达式,forJob设置需要启用的Detail的类,withIdentity是给该Trigger取名,withSchedule是绑定Schedule。

第五步:演示

       操作:启动项目,请求查询用户数量接口,等待30秒再次查询。

       等待30秒。

       控制台打印:

       可以看到在Job中获取Detail传过来的值,获取成功。

       本期整合到此完毕,接下来会继续更新加强整合,尽情期待。

       访问地址:http://localhost:8087/swagger-ui.html或者http://localhost:8087/doc.html

目录
相关文章
|
1月前
|
缓存 监控 Java
|
5月前
|
缓存 监控 Java
优化Spring Boot应用的数据库访问性能
优化Spring Boot应用的数据库访问性能
|
3月前
|
缓存 NoSQL Java
Springboot实战——黑马点评之秒杀优化
【9月更文挑战第27天】在黑马点评项目中,秒杀功能的优化对提升系统性能和用户体验至关重要。本文提出了多项Spring Boot项目的秒杀优化策略,包括数据库优化(如索引和分库分表)、缓存优化(如Redis缓存和缓存预热)、并发控制(如乐观锁、悲观锁和分布式锁)以及异步处理(如消息队列和异步任务执行)。这些策略能有效提高秒杀功能的性能和稳定性,为用户提供更佳体验。
205 6
|
3月前
|
存储 数据采集 Java
Spring Boot 3 实现GZIP压缩优化:显著减少接口流量消耗!
在Web开发过程中,随着应用规模的扩大和用户量的增长,接口流量的消耗成为了一个不容忽视的问题。为了提升应用的性能和用户体验,减少带宽占用,数据压缩成为了一个重要的优化手段。在Spring Boot 3中,通过集成GZIP压缩技术,我们可以显著减少接口流量的消耗,从而优化应用的性能。本文将详细介绍如何在Spring Boot 3中实现GZIP压缩优化。
453 6
|
4月前
|
Java 关系型数据库 MySQL
SpringBoot 集成 Quartz + MySQL
SpringBoot 集成 Quartz + MySQL
126 1
|
4月前
|
缓存 前端开发 Java
"揭秘!SpringBoot携手Nginx,性能飙升秘籍大公开:轻松掌握配置优化,让你的应用快如闪电!"
【8月更文挑战第11天】随着微服务架构的发展,SpringBoot成为构建RESTful API的首选,Nginx则作为高性能的反向代理服务器提升应用性能。本文将探讨两者如何协同工作,包括Nginx的负载均衡策略、静态资源缓存及数据压缩配置;同时讨论SpringBoot的线程池优化、缓存策略及性能监控。通过这些方法,帮助开发者显著提高系统的整体性能和可用性。
195 1
|
6月前
|
存储 NoSQL Java
大事件后端项目34_登录优化----redis_SpringBoot集成redis
大事件后端项目34_登录优化----redis_SpringBoot集成redis
大事件后端项目34_登录优化----redis_SpringBoot集成redis
|
5月前
|
缓存 监控 Java
如何优化Spring Boot应用性能?
【7月更文挑战第16天】如何优化Spring Boot应用性能?
75 2
|
5月前
|
缓存 监控 Java
优化Spring Boot应用的数据库访问性能
优化Spring Boot应用的数据库访问性能
|
5月前
|
缓存 监控 Java
Spring Boot应用的性能监控与优化
Spring Boot应用的性能监控与优化