专栏首页让技术和时代并行java中quartz 调度在一些定时任务(job)的入门级应用

java中quartz 调度在一些定时任务(job)的入门级应用

Quartz 执行详解http://quartz-scheduler.org/ 去下载相应的jar包 在maven中可直接把依赖拷贝过来复制到pom中去。

具体规则可查询quartz的文档

下面是一个非常详细的实例: 1.首先把需要执行的任务写到execute中去 并实现job

package job;
import java.util.Date;  
 
import org.quartz.Job;  
import org.quartz.JobExecutionContext;  
import org.quartz.JobExecutionException;  
/**  
* 需要执行的任务  
* @author clq  
*  
*/  
public class MyJob implements Job {  
 
   @Override  
   //把要执行的操作,写在execute方法中  
   public void execute(JobExecutionContext arg0) throws JobExecutionException {  
       System.out.println("测试Quartz"+new Date());  
   }  
}  
2.调用任务需要实现的类
package job;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.impl.JobDetailImpl;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.triggers.CronTriggerImpl;
 
public class CronTriggerTest2 {

​public static void main(String[] args) {

​​//通过SchedulerFactory获得一个调度器
​​SchedulerFactory schedulerfactory=new StdSchedulerFactory();  
​    Scheduler scheduler=null;  
​       try{
​    ​   //获取调度器实例
​    ​   scheduler=schedulerfactory.getScheduler();  
​    ​  
            // 指明job的名称,所在组的名称,以及绑定job类    创建jobDetail实例,绑定Job实现类  
​    ​   JobDetailImpl jobDetail=new JobDetailImpl("job1", "jgroup1", MyJob.class);

​    ​   //定义调度出发规则 每隔2秒执行一次
​    ​   CronTriggerImpl cornTrigger=new CronTriggerImpl("jobname","jobgroup");

​    ​   //括号里面的*号依此为秒,分,时,天,周,月,年
​    ​   //里面有具体的使用规则,非常灵活
​    ​   cornTrigger.setCronExpression("0/2 * * * * ? *");

​    ​   //把作业和触发器注册到任务调度中  
​    ​   scheduler.scheduleJob(jobDetail, cornTrigger);
​    ​   //启动调度

​    ​   scheduler.start();  
​       }catch(Exception e){
​    ​   e.printStackTrace();
​       }
​}
}

CronTriggerTest2  这个类由于里面的很多方法已经被遗弃,这是一个新写的实现类,其功能和上面的一模一样

package job;
 
import org.quartz.JobBuilder;
import org.quartz.JobDetail;  
import org.quartz.Scheduler;  
import org.quartz.SchedulerFactory;  
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;  
/**  
* 调用任务的类  
* @author clq
*  
*/  
public class CronTriggerTest { 
  public static void main(String[] args) {  
   
      SchedulerFactory schedulerfactory=new StdSchedulerFactory();  
      Scheduler scheduler=null;  
      try{  
          scheduler=schedulerfactory.getScheduler();  
          JobDetail job = JobBuilder.newJob(MyJob.class)
          .withIdentity("myJob")
          .build();

          Trigger trigger = TriggerBuilder.newTrigger()
          .withIdentity(TriggerKey.triggerKey("myTrigger", "myTriggerGroup"))
          .withSchedule(SimpleScheduleBuilder.simpleSchedule()
              .withIntervalInMilliseconds(2000)
              .repeatForever())
          .startNow()
          .build();

          scheduler.scheduleJob(job, trigger);  
//       启动调度  
          scheduler.start();  
      }catch(Exception e){  
          e.printStackTrace();  
      }  
}  
}  

在某种意义上来理解一个job指的就是一个单线程,这个在开发中的使用更是普遍,大家可以认真学习一下quartz夫人用法。

在执行上述方法后,你会发现程序会非常稳定的去执行MyJob中自己需要去执行的方法,每隔2s执行一次

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

推荐阅读

  • 远程办公经验为0,如何将日常工作平滑过度到线上?

    我是一名创业者,我的公司(深圳市友浩达科技有限公司)在2018年8月8日开始运营,现在还属于微型公司。这个春节假期,我一直十分关注疫情动向,也非常关心其对公司带来的影响。

    TVP官方团队
    TAPD 敏捷项目管理腾讯乐享企业邮箱企业编程算法
  • 数据中台,概念炒作还是另有奇效? | TVP思享

    作者简介:史凯,花名凯哥,腾讯云最具价值专家TVP,ThoughtWorks数据智能业务总经理。投身于企业数字化转型工作近20年。2000年初,在IBM 研发企业级中间件,接着加入埃森哲,为大型企业提供信息化架构规划,设计,ERP,云平台,数据仓库构建等技术咨询实施服务,随后在EMC负责企业应用转型业务,为企业提供云迁移,应用现代化服务。现在专注于企业智能化转型领域,是数据驱动的数字化转型的行业布道者,数据中台的推广者,精益数据创新体系的创始人,2019年荣获全球Data IQ 100人的数据赋能者称号,创业邦卓越生态聚合赋能官TOP 5。2019年度数字化转型专家奖。打造了行业第一个数据创新的数字化转型卡牌和工作坊。创建了精益数据创新方法论体系构建数据驱动的智能企业,并在多个企业验证成功,正在向国内外推广。

    TVP官方团队
    大数据数据分析企业
  • 扩展 Kubernetes 之 CRI

    使用 cri-containerd 的调用流程更为简洁, 省去了上面的调用流程的 1,2 两步

    王磊-AI基础
    Kubernetes
  • 扩展 Kubernetes 之 Kubectl Plugin

    kubectl 功能非常强大, 常见的命令使用方式可以参考 kubectl --help,或者这篇文章

    王磊-AI基础
    Kubernetes
  • 多种登录方式定量性能测试方案

    最近接到到一个测试任务,某服务提供了两种登录方式:1、账号密码登录;2、手机号+验证码登录。要对这两种登录按照一定的比例进行压测。

    八音弦
    测试服务 WeTest
  • 线程安全类在性能测试中应用

    首先验证接口参数签名是否正确,然后加锁去判断订单信息和状态,处理用户增添VIP时间事务,成功之后释放锁。锁是针对用户和订单的分布式锁,使用方案是用的redis。

    八音弦
    安全编程算法
  • 使用CDN(jsdelivr) 优化博客访问速度

    PS: 此篇文章适用于 使用 Github pages 或者 coding pages 的朋友,其他博客也类似.

    IFONLY@CUIT
    CDNGitGitHub开源
  • 扩展 Kubernetes 之 CNI

    Network Configuration 是 CNI 输入参数中最重要当部分, 可以存储在磁盘上

    王磊-AI基础
    Kubernetes
  • 聚焦【技术应变力】云加社区沙龙online重磅上线!

    云加社区结合特殊时期热点,挑选备受关注的音视频流量暴增、线下业务快速转线上、紧急上线防疫IoT应用等话题,邀请众多业界专家,为大家提供连续十一天的干货分享。从视野、预判、应对等多角度,帮助大家全面提升「技术应变力」!

    腾小云
  • 京东购物小程序购物车性能优化实践

    它是小程序开发工具内置的一个可视化监控工具,能够在 OS 级别上实时记录系统资源的使用情况。

    WecTeam
    渲染JavaScripthttps网络安全缓存

扫码关注云+社区

领取腾讯云代金券