您现在的位置是: 首页 > 汽车知识 汽车知识

java quartz调度_java任务调度quartz

2025-09-20 14:07:25 22人已围观

简介java quartz调度_java任务调度quartz   非常感谢大家聚集在这里共同探讨java quartz调度的话题。这个问题集合涵盖了java quartz调度的广泛内容,我将用我的知识和经验为大家提供全面而深入的回答。1.java定时任务需要一直启动服务器吗?2.分布式定时任务调度框架实

java quartz调度_java任务调度quartz

       非常感谢大家聚集在这里共同探讨java quartz调度的话题。这个问题集合涵盖了java quartz调度的广泛内容,我将用我的知识和经验为大家提供全面而深入的回答。

1.java定时任务需要一直启动服务器吗?

2.分布式定时任务调度框架实践

3.java的几种定时任务

4.quartz求助:每天定点执行一次,该怎么做?

5.quartz 每天 8-10点每隔10分钟执行一次,11-13点每隔1小时执行一次 cronExpression 要怎么写?

java定时任务需要一直启动服务器吗?

       Java定时任务通常需要服务器一直运行才能保证任务的正常执行。这是因为定时任务是基于时间的触发器,需要在指定的时间点执行任务,只有服务器一直运行才能保证定时任务的准确执行。

       当服务器停止运行时,定时任务也会随之停止。如果有重要的任务需要在指定的时间点执行,而服务器没有一直运行,就会出现任务无法按时执行的情况。这对于一些需要高可靠性的系统来说是非常不利的。

       除了需要服务器一直运行外,还需要注意定时任务的时间间隔和执行时间。如果时间间隔过短或者执行时间过长,可能会对服务器造成不必要的负担,影响系统的稳定性和性能。因此,在设计和实现定时任务时,需要考虑到系统的实际情况,合理地安排任务时间,以保证系统的高可靠性和高性能。

分布式定时任务调度框架实践

       Quartz框架有一个丰富的特征集。事实上,Quartz有太多特性以致不能在一种情况中全部领会,下面列出了一些有意思的特征,但没时间在此详细讨论。

       监听器和插件

       每个人都喜欢监听和插件。今天,几乎下载任何开源框架,你必定会发现支持这两个概念。监听是你创建的java类,当关键事件发生时会收到框架的回调。例如,当一个作业被调度、没有调度或触发器终止和不再触发时,这些都可以通过设置来通知你的监听器。Quartz框架包含了调度器监听、作业和触发器监听。你可以配置作业和触发器监听为全局监听或者是特定于作业和触发器的监听。

       一旦你的一个具体监听被调用,你就能使用这个技术来做一些你想要在监听类里面做的事情。例如,你如果想要在每次作业完成时发送一个电子邮件,你可以将这个逻辑写进作业里面,也可以写进JobListener里面。写进JobListener的方式强制使用松耦合有利于设计上做到更好。

       Quartz插件是一个新的功能特性,无须修改Quartz源码便可被创建和添加进Quartz框架。他为想要扩展Quartz框架又没有时间提交改变给Quartz开发团队和等待新版本的开发人员而设计。如果你熟悉Struts插件的话,那么完全可以理解Quartz插件的使用。

       与其Quartz提供一个不能满足你需要的有限扩展点,还不如通过使用插件来拥有可修整的扩展点。

       集群Quartz应用

       Quartz应用能被集群,是水平集群还是垂直集群取决于你自己的需要。集群提供以下好处:

       ·伸缩性

       ·高可用性

       ·负载均衡

       Quartz可以借助关系数据库和JDBC作业存储支持集群。

       Terracotta扩展quartz提供集群功能而不需要数据库支持

       相关工具

       Quartz经常会用到cron表达式,可以使用国外网站cronmaker辅助生成cron表达式。

java的几种定时任务

        分布式任务调度框架几乎是每个大型应用必备的工具,本文介绍了任务调度框架使用的需求背景和痛点,对业界普遍使用的开源分布式任务调度框架的使用进行了探究实践,并分析了这几种框架的优劣势和对自身业务的思考。

        一、业务背景

        1.1 为什么需要使用定时任务调度

        (1)时间驱动处理场景: 整点发送优惠券,每天更新收益,每天刷新标签数据和人群数据。

        (2)批量处理数据: 按月批量统计报表数据,批量更新短信状态,实时性要求不高。

        (3)异步执行解耦: 活动状态刷新,异步执行离线查询,与内部逻辑解耦。

        1.2 使用需求和痛点

        (1)任务执行监控告警能力。

        (2)任务可灵活动态配置,无需重启。

        (3)业务透明,低耦合,配置精简,开发方便。

        (4)易测试。

        (5)高可用,无单点故障。

        (6)任务不可重复执行,防止逻辑异常。

        (7)大任务的分发并行处理能力。

        二、开源框架实践与 探索

        2.1 Java 原生 Timer 和

        ScheduledExecutorService

        2.1.1 Timer使用

        Timer缺陷:

        由于上述缺陷,尽量不要使用Timer, idea中也会明确提示,使用ScheduledThreadPoolExecutor替代Timer 。

        2.1.2 ScheduledExecutorService使用

        ScheduledExecutorService对于Timer的缺陷进行了修补,首先ScheduledExecutorService内部实现是ScheduledThreadPool线程池,可以支持多个任务并发执行。

        对于某一个线程执行的任务出现异常,也会处理,不会影响其他线程任务的执行,另外ScheduledExecutorService是基于时间间隔的延迟,执行不会由于系统时间的改变发生变化。

        当然,ScheduledExecutorService也有自己的局限性:只能根据任务的延迟来进行调度,无法满足基于绝对时间和日历调度的需求。

        2.2 Spring Task

        2.2.1 Spring Task 使用

        spring task 是spring自主开发的轻量级定时任务框架,不需要依赖其他额外的包,配置较为简单。

        此处使用注解配置

        2.2.2 Spring Task缺陷

        Spring Task 本身不支持持久化,也没有推出官方的分布式集群模式,只能靠开发者在业务应用中自己手动扩展实现,无法满足可视化,易配置的需求。

        2.3 永远经典的 Quartz

        2.3.1 基本介绍

        Quartz框架是Java领域最著名的开源任务调度工具,也是目前事实上的定时任务标准,几乎全部的开源定时任务框架都是基于Quartz核心调度构建而成。

        2.3.2 原理解析

        核心组件和架构

        关键概念

        (1)Scheduler :任务调度器,是执行任务调度的控制器。本质上是一个计划调度容器,注册了全部Trigger和对应的JobDetail, 使用线程池作为任务运行的基础组件,提高任务执行效率。

        (2)Trigger :触发器,用于定义任务调度的时间规则,告诉任务调度器什么时候触发任务,其中CronTrigger是基于cron表达式构建的功能强大的触发器。

        (3)Calendar :日历特定时间点的集合。一个trigger可以包含多个Calendar,可用于排除或包含某些时间点。

        (4)JobDetail :是一个可执行的工作,用来描述Job实现类及其它相关的静态信息,如Job的名称、监听器等相关信息。

        (5)Job :任务执行接口,只有一个execute方法,用于执行真正的业务逻辑。

        (6)JobStore :任务存储方式,主要有RAMJobStore和JDBCJobStore,RAMJobStore是存储在JVM的内存中,有丢失和数量受限的风险,JDBCJobStore是将任务信息持久化到数据库中,支持集群。

        2.3.3 实践说明

        (1)关于Quartz的基本使用

        (2)业务使用要满足动态修改和重启不丢失, 一般需要使用数据库进行保存。

        (3)组件化

        (4)扩展

        2.3.4 缺陷和不足

        (1)需要把任务信息持久化到业务数据表,和业务有耦合。

        (2)调度逻辑和执行逻辑并存于同一个项目中,在机器性能固定的情况下,业务和调度之间不可避免地会相互影响。

        (3)quartz集群模式下,是通过数据库独占锁来唯一获取任务,任务执行并没有实现完善的负载均衡机制。

        2.4 轻量级神器 XXL-JOB

        2.4.1 基本介绍

        XXL-JOB是一个轻量级分布式任务调度平台,主打特点是平台化,易部署,开发迅速、学习简单、轻量级、易扩展,代码仍在持续更新中。

        主要提供了任务的动态配置管理、任务监控和统计报表以及调度日志几大功能模块,支持多种运行模式和路由策略,可基于对应执行器机器集群数量进行简单分片数据处理。

        2.4.2 原理解析

        2.1.0版本前核心调度模块都是基于quartz框架,2.1.0版本开始自研调度组件,移除quartz依赖 ,使用时间轮调度。

        2.4.3 实践说明

        详细配置和介绍参考官方文档。

        2.4.3.1 demo使用:

        @JobHandler(value="offlineTaskJobHandler") ,实现业务逻辑即可。(注:此次引入了dubbo,后文介绍)。

        (滑动可查看)

        示例2:分片广播任务。

        (滑动可查看)

        2.4.3.2 整合dubbo

        (1)引入dubbo-spring-boot-starter和业务facade jar包依赖。

        (滑动可查看)

        (2)配置文件加入dubbo消费端配置(可根据环境定义多个配置文件,通过profile切换)。

        (滑动可查看)

        (3)代码中通过@Reference注入facade接口即可。

        (滑动可查看)

        (4)启动程序加入@EnableDubboConfiguration注解。

        (滑动可查看)

        2.4.4 任务可视化配置

        内置了平台项目,方便了开发者对任务的管理和执行日志的监控,并提供了一些便于测试的功能。

        2.4.5 扩展

        (1)任务监控和报表的优化。

        (2)任务报警方式的扩展,比如加入告警中心,提供内部消息,短信告警。

        (3)对实际业务内部执行出现异常情况下的不同监控告警和重试策略。

        2.5 高可用 Elastic-Job

        2.5.1 基本介绍

        Elastic-Job是一个分布式调度解决方案,由两个相互独立的子项目Elastic-Job-Lite和Elastic-Job-Cloud组成。

        Elastic-Job-Lite定位为轻量级无中心化解决方案,使用jar包的形式提供分布式任务的协调服务。

        Elastic-Job-Cloud使用Mesos + Docker的解决方案,额外提供资源治理、应用分发以及进程隔离等服务。

        可惜的是已经两年没有迭代更新记录。

        2.5.2 原理解析

        2.5.3 实践说明

        2.5.3.1 demo使用

        (1)安装zookeeper,配置注册中心config,配置文件加入注册中心zk的配置。

        (滑动可查看)

        (滑动可查看)

        (2)配置数据源config,并配置文件中加入数据源配置。

        (滑动可查看)

        (滑动可查看)

        (3)配置事件config。

        (滑动可查看)

        (4)为了便于灵活配置不同的任务触发事件,加入ElasticSimpleJob注解。

        (滑动可查看)

        (5)对配置进行初始化。

        (滑动可查看)

        (6)实现 SimpleJob接口,按上文中方法整合dubbo, 完成业务逻辑。

        (滑动可查看)

        2.6 其余开源框架

        (1)Saturn :Saturn是唯品会开源的一个分布式任务调度平台,在Elastic Job的基础上进行了改造。

        (2)SIA-TASK :是宜信开源的分布式任务调度平台。

        三、优劣势对比和业务场景适配思考

        业务思考:

        四、结语

        对于并发场景不是特别高的系统来说,xxl-job配置部署简单易用,不需要引入多余的组件,同时提供了可视化的控制台,使用起来非常友好,是一个比较好的选择。希望直接利用开源分布式框架能力的系统,建议根据自身的情况来进行合适的选型。

        附:参考文献

        高可用架构

        改变互联网的构建方式

quartz求助:每天定点执行一次,该怎么做?

       java定时任务有三种:

       - JDK自带 :JDK自带的Timer以及JDK1.5+ 新增的ScheduledExecutorService;?

       - Quartz :简单却强大的JAVA作业调度框架?

       - Spring3.0以后自带的task :可以将它看成一个轻量级的Quartz,而且使用起来比Quartz简单许多;

       代码参考:

       JDK 自带的定时器实现

       schedule(TimerTask task, Date time) 特定时间执行

       public static void main(String[] args) {

       for (int i = 0; i < 10; ++i) {

       new Timer("timer - " + i).schedule(new TimerTask() {

       @Override

       public void run() {

       println(Thread.currentThread().getName() + " run ");

       }

       }, new Date(System.currentTimeMillis() + 2000));

       }

       }

       Quartz 定时器实现

       2.1? 通过maven引入依赖(这里主要介绍2.3.0) ?注意:shiro-scheduler中依赖的是1.x版本 ?如果同时使用会冲突

       <!-- /artifact/org.quartz-scheduler/quartz -->

       <dependency>

       <groupId>org.quartz-scheduler</groupId>

       <artifactId>quartz</artifactId>

       <version>2.3.0</version>

       </dependency>

       2.2?创建Job类

       public class TestJob implements Job{

       @Override

       public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {

       println(Thread.currentThread().getName() + " test job begin " + DateUtil.getCurrentTimeStr());

       }

       }

       2.3?调度任务

       public static void main(String[] args) throws InterruptedException, SchedulerException {

       Scheduler scheduler = new StdSchedulerFactory().getScheduler();

       // 开始

       scheduler.start();

       // job 唯一标识 test.test-1

       JobKey jobKey = new JobKey("test" , "test-1");

       JobDetail jobDetail = JobBuilder.newJob(TestJob.class).withIdentity(jobKey).build();

       Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("test" , "test")

       // 延迟一秒执行

       .startAt(new Date(System.currentTimeMillis() + 1000))

       // 每隔一秒执行 并一直重复

       .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever())

       .build();

       scheduler.scheduleJob(jobDetail , trigger);

       Thread.sleep(5000);

       // 删除job

       scheduler.deleteJob(jobKey);

       }

       3.Spring 相关的任务调度

       3.1 配置文件实现

       spring-schedule.xml

       <task:scheduler id="myScheduler" pool-size="10" />

       <task:scheduled-tasks scheduler="myScheduler">

       <task:scheduled ref="job" method="test" cron="0 * * * * ?"/>

       </task:scheduled-tasks>

       3.2注解实现

       spring-schedule.xml

       <task:scheduler id="myScheduler" pool-size="10" />

       // 启用注解

       <task:annotation-driven scheduler="myScheduler"/>

       @Component?

       public class Task{ ?

       @Scheduled(cron="0/5 * *? * * ? ")? //每5秒执行一次

       public void execute(){

       DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

       System.out.println(sdf.format(DateTime.now().toDate())+"*********B任务每5秒执行一次进入测试"); ?

       }?

       }

quartz 每天 8-10点每隔10分钟执行一次,11-13点每隔1小时执行一次 cronExpression 要怎么写?

       每天凌晨2点 ?0 0 2 * * ?和每天隔一小时 0 * */1 * * ?

       例1:每隔5秒执行一次:*/5 * * * * ?

       例2:每隔5分执行一次:0 */5 * * * ?

       在26分、29分、33分执行一次:0 26,29,33 * * * ?

       例3:每天半夜12点30分执行一次:0 30 0 * * ? (注意日期域为0不是24)

       每天凌晨1点执行一次:0 0 1 * * ?

       每天上午10:15执行一次: 0 15 10 ? * * 或 0 15 10 * * ? 或 0 15 10 * * ? *

       每天中午十二点执行一次:0 0 12 * * ?

       每天14点到14:59分,每1分钟执行一次:0 * 14 * * ?

       每天14点到14:05分,每1分钟执行一次:0 0-5 14 * * ?

       每天14点到14:55分,每5分钟执行一次:0 0/5 14 * * ?

       每天14点到14:55分,和18点到18点55分,每5分钟执行一次:0 0/5 14,18 * * ?

       每天18点执行一次:0 0 18 * * ?

       每天18点、22点执行一次:0 0 18,22 * * ?

       每天7点到23点,每整点执行一次:0 0 7-23 * * ?

       每个整点执行一次:0 0 0/1 * * ?

       每天凌晨2点 ?0 0 2 * * ?和每天隔一小时 0 * */1 * * ?

       例1:每隔5秒执行一次:*/5 * * * * ?

       例2:每隔5分执行一次:0 */5 * * * ?

       在26分、29分、33分执行一次:0 26,29,33 * * * ?

       例3:每天半夜12点30分执行一次:0 30 0 * * ? (注意日期域为0不是24)

       每天凌晨1点执行一次:0 0 1 * * ?

       每天上午10:15执行一次: 0 15 10 ? * * 或 0 15 10 * * ? 或 0 15 10 * * ? *

       每天中午十二点执行一次:0 0 12 * * ?

       每天14点到14:59分,每1分钟执行一次:0 * 14 * * ?

       每天14点到14:05分,每1分钟执行一次:0 0-5 14 * * ?

       每天14点到14:55分,每5分钟执行一次:0 0/5 14 * * ?

       每天14点到14:55分,和18点到18点55分,每5分钟执行一次:0 0/5 14,18 * * ?

       每天18点执行一次:0 0 18 * * ?

       每天18点、22点执行一次:0 0 18,22 * * ?

       每天7点到23点,每整点执行一次:0 0 7-23 * * ?

       每个整点执行一次:0 0 0/1 * * ?

       0 0/10 8-11 1-30 8点(8点执行)到晚上10点每隔10分钟触发一次

       0 0/1 11-13 1-31 1-13点每隔1小时执行一次

       cron表达式用于配置cronTrigger的实例。cron表达式实际上是由七个子表达式组成。这些表达式之间用空格分隔。

       1.Seconds (秒)

       2.Minutes(分)

       3.Hours(小时)

       4.Day-of-Month? (天)

       5.Month(月)

       6.Day-of-Week (周)

       7.Year(年)

       例:"0 0 12 ? * WED” 意思是:每个星期三的中午12点执行。

       个别子表达式可以包含范围或者列表。例如:上面例子中的WED可以换成"MON-FRI","MON,WED,FRI",甚至"MON-WED,SAT"。

       子表达式范围:

       1.Seconds (0~59)

       2.Minutes (0~59)

       3.Hours (0~23)

       4.Day-of-Month (1~31,但是要注意有些月份没有31天)

       5.Month (0~11,或者"JAN, FEB, MAR, APR, MAY, JUN, JUL, AUG, SEP, OCT, NOV,DEC")

       6.Day-of-Week (1~7,1=SUN 或者"SUN, MON, TUE, WED, THU, FRI, SAT”)

       7.Year (1970~2099)

扩展资料:

       Quartz是一个完全由java编写的开源作业调度框架。不要让作业调度这个术语吓着你。尽管Quartz框架整合了许多额外功能。

       但就其简易形式看,你会发现它易用得简直让人受不了!。简单地创建一个实现org.quartz.Job接口的java类。Job接口包含唯一的方法:

       public void execute(JobExecutionContext context)

       throws JobExecutionException;

       在你的Job接口实现类里面,添加一些逻辑到execute()方法。一旦你配置好Job实现类并设定好调度时间表,Quartz将密切注意剩余时间。

       当调度程序确定该是通知你的作业的时候,Quartz框架将调用你Job实现类(作业类)上的execute()方法并允许做它该做的事情。

       无需报告任何东西给调度器或调用任何特定的东西。仅仅执行任务和结束任务即可。如果配置你的作业在随后再次被调用,Quartz框架将在恰当的时间再次调用它。

       百度百科-quartz

       好了,关于“java quartz调度”的话题就到这里了。希望大家通过我的介绍对“java quartz调度”有更全面、深入的认识,并且能够在今后的实践中更好地运用所学知识。