浦东新区做网站公司遵义新蓝外国语学校网站建设

)

1. Quartz介绍

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

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

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

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

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

    		举个例：	快递一个县	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秒是多线程