Quartz简介及应用场景

1. Quartz介绍
核心类介绍
简单触发器
- 创建一个Quartz项目
- pom导入：
- 入门级案例
- 最终执行，是没6秒指定一次，自行三次，触发器设定的。
表达式触发器
- 表达式触发器：定时定点完成。
- 表达式触发器:循某一规定循环执行，不限次数
定时任务参数传递问题
String task Vs Quartz

)

1. Quartz介绍

任务调度框架“Quartz”是OpenSymphony开源组织在Job
scheduling领域又一个开源项目，是完全由java开发的一个开源的任务日程管理系统，
“任务进度管理器”就是一个在预先确定（被纳入日程）的时间到达时，负责执行
（或者通知）其他软件组件的系统。简单来说就是实现“计划(或定时)任务”的系统，例如：订单下单
后未付款，15分钟后自动撤消订单，并自 动解锁锁定的商品

quartz的应用场景大致分为两类
例如：CRM系统：
在凌晨两点将六个月未下单的用户标识为流失客户
分析
将客户标识为流失客户—>就是将表列段修改状态—>必须页面触发

定时定点完成某一操作（数据库操作）

    也就是你不用在前端点击什么操做，而是到时间自动完成操作。

遵循某一规律，循环执行某一操作

       举个例： 快递一个县   1000一个市 1w一个省份  10w340w订单表      340w        订单历史表我们主要是查看订单是否付款成功，查看物流状态，而一查看不可能从340w中看，如果使用，新建一个订单历史表，查看半小时（因为我们通常查询实在半小时之内）的也就是7w，这样就很省时间了。

mysql中复制表的口令： create table t_mvc_book_copy as select *from t_mvc_book where bid<30

注意：类似Quartz这样的还有MyCAT+MySQL的分布式架构。

核心类介绍

三大核心类 Scheduler（调度器），Trigger（触发器），JObDetail（作业类）。Trigger指定JObDetail什么时候发布任务。

quartz相关表达式
在线生成表达式网址: http://cron.qqe2.com/.

简单触发器

创建一个Quartz项目

创建时和整合mybatis一样，不过要多选择一个Quartz。

pom导入：

      <dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz-jobs</artifactId><version>2.2.1</version></dependency>切面依赖<dependency><groupId>org.springframework</groupId><artifactId>spring-aspects</artifactId></dependency>

入门级案例

1.创建一个quarz包，包下Demol.java

Demol.java

 package com.javabz.quartz01.quartz;import com.javabz.quartz01.job.RamJob;import org.quartz.*;import org.quartz.impl.StdSchedulerFactory;import static org.quartz.JobBuilder.newJob;/*** @author因果* @site www.xiaomage.com* @company xxx公司* @create  2020-12-04 10:21*/public class Demol {public static void main(String[] args) throws SchedulerException {//调度器SchedulerFactory schedulerFactory=new StdSchedulerFactory();Scheduler scheduler = schedulerFactory.getScheduler();//作业类JobDetail jobDetail=newJob(RamJob.class).withIdentity("job1","goroup1") //标识，.withDescription("this is a job1").build();//触发器Trigger trigger=(Trigger)TriggerBuilder.newTrigger().withSchedule(SimpleScheduleBuilder.repeatSecondlyForTotalCount(3,6)).withIdentity("trigger1","group1").withDescription("this is a trigger1").build();//调度器组装作业类及触发器//绑定scheduler.scheduleJob(jobDetail,trigger);//启动scheduler.start();}}

2.创建一个job包，包下RamJob

 package com.javabz.quartz01.job;import org.quartz.Job;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;/*** @author因果* @site www.xiaomage.com* @company xxx公司* @create  2020-12-04 10:25*/public class RamJob implements Job {@Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {System.out.println("定时任务具体执行的业务逻辑。。。");}}

最终执行，是没6秒指定一次，自行三次，触发器设定的。

表达式触发器

表达式触发器：定时定点完成。

在简单触发器的基础上修改一下触发器

 //触发器Trigger trigger=(Trigger)TriggerBuilder.newTrigger().withSchedule(CronScheduleBuilder.cronSchedule("0 57 10 * * ?")).withIdentity("trigger1","group1").withDescription("this is a trigger1").build();

效果图：

表达式触发器:循某一规定循环执行，不限次数

         按照上面的代码不变，修改规则.withSchedule(CronScheduleBuilder.cronSchedule("0/10 * * * * ？”))每10秒执行一次。

定时任务参数传递问题

在作业类下设置参数，

Demo.java

  //作业类JobDetail jobDetail=newJob(RamJob.class).withIdentity("job1","goroup1") //标识，.withDescription("this is a job1").build();//传参JobDataMap jobDataMap=jobDetail.getJobDataMap();jobDataMap.put("name","注释fod");jobDataMap.put("age",11);jobDataMap.put("sex","男");

在RamJob.java中拿

 public class RamJob implements Job {@Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {System.out.println("定时任务具体执行的业务逻辑。。。");JobDataMap jobDataMap = jobExecutionContext.getJobDetail().getJobDataMap();System.out.println(jobDataMap.get("name").toString() + ":" + jobDataMap.get("age").toString() +":"+ jobDataMap.get("sex").toString());}}

String task Vs Quartz

Spring task

优点：无需整合spring，作业类中就可以调用业务service
缺点：单线程；不能做数据存储型的定时任务

SpringTask.java

运行10秒是多线程，30是单线程。

 package com.javabz.quartz01.task;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Component;import java.text.SimpleDateFormat;import java.util.Date;/*** @author因果* @site www.xiaomage.com* @company xxx公司* @create  2020-12-04 12:16*/@Componentpublic class SpringTask {@Scheduled(cron = "0/10 * * * * ?")public void xxx(){System.out.println("spring 框架自带的定时任务。。。。");SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");System.err.println(format.format(new Date())+" : 这是一个spring task...");try {Thread.sleep(20*1000);System.out.println("模拟正在处理大数据....");} catch (InterruptedException e) {e.printStackTrace();}}}

Quartz

优点：多线程；可以做数据存储型的定时任务，维护性高；
缺点：需要整合spring，不能直接调用业务层service；

Demol4.java

 package com.javabz.quartz01.quartz;import com.javabz.quartz01.job.RamJob;import org.quartz.*;import org.quartz.impl.StdSchedulerFactory;import static org.quartz.JobBuilder.newJob;/*** @author因果* @site www.xiaomage.com* @company xxx公司* @create  2020-12-04 14:25*/public class Demol4 {public static void main(String[] args) throws SchedulerException {SchedulerFactory factory = new StdSchedulerFactory();//        调度器创建Scheduler scheduler = factory.getScheduler();//        具体定时任务需要执行的代码JobDetail jobDetail = newJob(RamJob.class).withIdentity("job2", "group1").withIdentity("这是一个作业类案例").build();Trigger trigger = (Trigger) TriggerBuilder.newTrigger()//                每10s执行一次.withSchedule(CronScheduleBuilder.cronSchedule("0/10 * * * * ?"))//                触发器标识.withIdentity("trigger2", "group1").withDescription("这是一个触发器").build();//       调度工厂绑定作业类及触发器scheduler.scheduleJob(jobDetail, trigger);scheduler.start();}}

jop包下

  @Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");System.err.println(format.format(new Date())+" : 基于RAM的quartz调度框架定时任务...");try {Thread.sleep(20*1000);System.out.println("模拟正在处理大数据....");} catch (InterruptedException e) {e.printStackTrace();}}

运行，10秒是多线程

Quartz简介及应用场景相关推荐

数据批处理神器-Spring Batch(1)简介及使用场景
数据批处理神器-Spring Batch(1)简介及使用场景 tags: springbatch 1.引言最近使用Spring Batch进行做数据迁移.数据同步.数据批处理等工作,感叹Spring ...
kafka入门：简介、使用场景、设计原理、主要配置及集群搭建
为什么80%的码农都做不了架构师?>>> kafka入门:简介.使用场景.设计原理.主要配置及集群搭建(转) 问题导读: 1.zookeeper在kafka的作用是什么? 2. ...
DL：深度学习模型概览(包括DNN、CNN、RNN等)的简介、网络结构简介、使用场景对比之详细攻略
DL:神经网络所有模型(包括DNN.CNN.RNN等)的简介(概览).网络结构简介.使用场景对比之详细攻略目录神经网络所有模型的简介及其总结神经网络所有模型的简介(概览) 神经网络算法之DNN. ...
经济型EtherCAT运动控制器(一)：功能简介与应用场景
XPLC006E功能简介 XPLC006E是正运动运动控制器推出的一款多轴经济型EtherCAT总线运动控制器,XPLC系列运动控制器可应用于各种需要脱机或联机运行的场合. XPLC006E自带6个电 ...
Apache Camel简介以及使用场景
Apache Camel简介以及使用场景我们要解决的问题以及解决方案我们要解决的问题 EAI的常用解决方案 SOA架构模型 ESB企业服务总线如何实现ESB 为什么使用Camel Camel可以 ...
Cloud Computing：基于无影云电脑利用Python语言实现绘制“可爱小老虎”虎年快乐及无影云电脑简介、应用场景、使用体验(五步快速上手)分享图文教程之详细攻略
Cloud Computing:基于无影云电脑利用Python语言实现绘制"可爱小老虎"虎年快乐及无影云电脑简介.应用场景.使用体验(五步快速上手)分享图文教程之详细攻略目录无 ...
Go 简介、应用场景
Go 简介.应用场景一. go语言的优势 1.并发性能好基于goroutine(协程) 的并发,可以将 goroutine 理解为一种虚拟线程.Go 语言运行时会参与调度 goroutine,并将 ...
3dmax：3dmax三维动画之粒子系统简介、基本场景之详细攻略
3dmax:3dmax三维动画之粒子系统简介.基本场景之详细攻略目录 3dmax三维动画之粒子系统简介.使用方法之详细攻略粒子系统简介.使用方法
c++ 单例模式简介和应用场景
单例模式简介和应用场景 1. 单例模式定义 2.单例模式存在的意义 3.适用于单例模式的场景 4.单例模式的使用 4.1饿汉模式(线程安全) 4.2懒汉模式(线程安全) 参考文档] 1. 单例模式定义 ...

Quartz简介及应用场景

Quartz简介及应用场景

1. Quartz介绍

核心类介绍

简单触发器

创建一个Quartz项目

pom导入：

入门级案例

最终执行，是没6秒指定一次，自行三次，触发器设定的。

表达式触发器

表达式触发器：定时定点完成。

表达式触发器:循某一规定循环执行，不限次数

定时任务参数传递问题

String task Vs Quartz

Quartz简介及应用场景相关推荐

最新文章

热门文章