springboot篇章整体栏目:
【二】springboot整合swagger(自定义)(超详细)
【四】springboot整合mybatis-plus(超详细)(上)
【五】springboot整合mybatis-plus(超详细)(下)
【十】springboot整合redis实现启动服务即将热点数据保存在全局以及redis(超详细)
【十一】springboot整合quartz实现定时任务优化(超详细)
【十二】springboot整合线程池解决高并发(超详细,保你理解)
【十三】springboot整合异步调用并获取返回值(超详细)
【十四】springboot整合WebService(超详细)
【十五】springboot整合WebService(关于传参数)(超详细)
【十六】springboot整合WebSocket(超详细)
【十七】springboot整合WebSocket实现聊天室(超详细)
介绍:接下来我会把学习阶段学到的框架等知识点进行整合,每一次整合是在前一章的基础上进行的,所以后面的整合不会重复放前面的代码。每次的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
demo地址:studydemo/整合swagger at main · zrc11/studydemo · GitHub
码字不易,若帮到各位,帮忙三连,感谢
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/12805.html