网站前台架构,随便来一个公司邮箱,网站建设费税率,推广型网站Quartz简介及应用场景 1. Quartz介绍核心类介绍简单触发器创建一个Quartz项目pom导入#xff1a;入门级案例最终执行#xff0c;是没6秒指定一次#xff0c;自行三次#xff0c;触发器设定的。 表达式触发器表达式触发器#xff1a;定时定点完成。表达式触发器:循某一规定… 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 bid30
注意类似Quartz这样的还有MyCATMySQL的分布式架构。
核心类介绍 三大核心类 Scheduler调度器Trigger触发器JObDetail作业类。Trigger指定JObDetail什么时候发布任务。
quartz相关表达式 在线生成表达式网址: http://cron.qqe2.com/.
简单触发器
创建一个Quartz项目
创建时和整合mybatis一样不过要多选择一个Quartz。 pom导入 dependencygroupIdorg.quartz-scheduler/groupIdartifactIdquartz-jobs/artifactIdversion2.2.1/version/dependency切面依赖dependencygroupIdorg.springframework/groupIdartifactIdspring-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 schedulerFactorynew StdSchedulerFactory();Scheduler scheduler schedulerFactory.getScheduler();//作业类JobDetail jobDetailnewJob(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 jobDetailnewJob(RamJob.class).withIdentity(job1,goroup1) //标识.withDescription(this is a job1).build();//传参JobDataMap jobDataMapjobDetail.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不能直接调用业务层serviceDemol4.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秒是多线程
