zoukankan      html  css  js  c++  java
  • quartz框架(一)-入门使用

    什么是quartz?

    quartz是一个开源的任务调度框架,它可以帮助我们实现任务的定时调度,任务的持久化,支持故障切换和负载均衡。当然,它的优点远远不止这些。

    什么是任务调度框架?

    任务调度框架的核心功能就是它可以根据我们定义好的调度规则,在线程池中创建线程来执行我们的业务方法。那么一个完善的任务调度框架需要具备哪些功能呢?

    灵活的触发规则

    触发规则就是我的这个业务方法需要在什么时候开始执行,每隔多少时间执行,一共需要执行多少次。对于触发规则来说我们常见的是使用corn表达式,来进行任务触发规则的表达。

    任务的持久化

    任务的持久化就是弥补内存中保存任务的不足。比如说程序异常退出,那么此时我们就无法知道上一次执行的状态,只能够重新开始执行。举个例子,比如说我们的某个任务需要在9点执行,当前时间为8.59分,程序刚好异常退出。重新启动完成的时候已经到了9点01分,那么此时我们是无法知道9点是否执行了那个任务的。

    弥补措施

    上面说到了,如果程序异常退出,那么此时我们应该基于什么样的策略进行弥补?是直接忽略,还是立马执行?quartz的弥补策略比较丰富,博主会在之后的文章中详细介绍。除了异常退出会导致失火之外,任务的耗时执行,也会导致失火。比如说你的任务每隔3秒执行依次,你的任务执行一次需要5秒,那么你的任务还没执行完的时候,第二个触发调度就开始了,那么此时又应该怎么处理呢?

    负载均衡

    为了解决单点故障的问题,我们可以多部署几个服务。但是怎么确保这些服务可以平均分分配到对应的服务器上,这里就需要使用负载均衡策略,比如说随机分配,加权轮询等。

    任务的监控

    作为使用者来说,我们当然希望知道此时程序任务的执行状态。而通过日志,数据库表查询状态的方式并不直接,也比较费时费力,也不通用。那么此时,我们就需要提供一个监控界面,来实时查看任务的总体情况,以及某一个任务的执行历史,当然我们也可以手动决定某个任务是否执行,这样我们就不需要修改代码重新发布了。

    quartz使用

    说了这么多关于任务调度框架的东西,我们先来介绍一下quartz的简单使用。至于源码,以及更详细的quartz使用,博主会在后面的文章中继续介绍。

    导入依赖

    <dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.3.0</version>
    </dependency>
    

    编写job

    我们先实现一个job,然后在execute方法里面,放入我们的业务逻辑。

    public class TestJob implements Job {
        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
            System.out.println("hello world!");
        }
    }
    
    

    调度job

    有了任务之后,我们需要对任务进行调度。

    public class Main {
        public static void main(String[] args) throws SchedulerException {
    
    //创建一个任务详情对象,它里面有我们业务job的class对象
            JobDetail jobDetail = JobBuilder.newJob(TestJob.class).withIdentity("myJob").build();
    
    //创建一个简单的触发器,它的触发规则是基于当前时间,每个1秒执行,并且只执行一次。
            SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).withRepeatCount(1)).build();
    
    //创建调度器,它会根据触发规则,将任务放到线程中执行。
            StdSchedulerFactory factory = new StdSchedulerFactory();
            Scheduler scheduler = factory.getScheduler();
            scheduler.start();
            scheduler.scheduleJob(jobDetail,trigger);
        }
    }
    

    查看运行结果

    运行结果

    博主微信公众号

  • 相关阅读:
    SQL Server存储过程(二)
    WPF 小知识 (设置背景图)
    关于SQL Server中索引使用及维护简介
    学习asp.net比较完整的流程(转)
    web开发常用默认端口
    接口和类的几大区别
    WEB建站规划之建站目的
    个人经验:页面无刷新传输数据的多种方法总结
    旅游电子商务探讨
    vs2008中文版提供下载(包含中文msdn)
  • 原文地址:https://www.cnblogs.com/chenhaoblog/p/13458828.html
Copyright © 2011-2022 走看看