当前位置: 首页 > news >正文

java:简单入门定时任务的几种方式Timer、Quartz、Spring Task

背景

后端的定时任务在许多应用中都扮演着重要的角色,它们可用于处理重复性任务、执行定期操作或处理需要定时触发的任务。以下是一些使用场景的示例:

  • 数据同步:在分布式系统中,不同系统之间经常需要进行数据同步。例如,一个系统可能需要定期从另一个系统获取最新数据,或者将数据推送到另一个系统。定时任务可以用于定期执行这些数据同步操作。
  • 报表生成:对于需要生成报表或报告的企业应用,可以使用定时任务来定期收集数据、生成报告并发送给相关人员。这样,报表或报告可以在特定时间(如每天、每周或每月)自动生成并发送给用户。
  • 定时任务调度:对于需要定期执行某些任务的应用,如定期清理临时文件、备份数据、发送通知等,可以使用定时任务来实现。这样,任务可以在指定的时间自动执行,无需人工干预。
  • 日志分析:许多系统会生成大量的日志数据。使用定时任务可以定期对这些日志进行分析,以便及时发现潜在的问题或异常情况。
  • 监控和警报:定时任务可以用于监控系统的性能和状态,并在发现问题时发送警报。例如,可以定期检查服务器的CPU使用率、内存消耗等指标,并在指标超过阈值时发送警报。
  • 自动化流程:在业务流程自动化或工作流管理中,定时任务可以用于触发某些流程步骤或操作。例如,可以在特定时间自动将任务分配给员工、发送审批请求或触发其他流程操作。
  • 数据爬取:对于需要定期从互联网获取数据的应用,如新闻聚合、价格监控、竞争情报等,可以使用定时任务来执行数据爬取操作。这样,应用可以在指定时间自动获取最新数据,并进行处理和分析。

在Java中,你可以使用各种库和框架来创建和管理定时任务,如Quartz、Spring的@Scheduled注解、Timer等。选择适合你项目需求的工具和方法,并确保正确配置和管理定时任务,以确保它们在正确的时机执行并达到预期的效果。

分类

触发时机

  • 每隔指定时间则触发一次
  • 每到指定时间则触发一次

并非每种任务都可以使用这两种触发器,如java.util.TimerTask任务就只能使用第一种。而 Quartz 和 spring task 可以支持这两种触发条件。

每隔指定时间则触发一次,在 Quartz 中对应的触发器为:org.springframework.scheduling.quartz.SimpleTriggerBean
每到指定时间则触发一次,在 Quartz 中对应的调度器为: org.springframework.scheduling.quartz.CronTriggerBean

java.util.Timer类

Java自带的java.util.Timer类,这个类允许调度一个java.util.TimerTask任务。使用这种方式可以让程序按照某一个频度执行,但不能在指定时间运行。一般用的较少。

import java.util.Timer;  
import java.util.TimerTask;  public class Main {  public static void main(String[] args) {  Timer timer = new Timer(); // 创建一个新的 Timer 实例  TimerTask task = new TimerTask() { // 创建一个新的 TimerTask 实例  @Override  public void run() {  System.out.println("任务正在执行...");  }  };  // 安排任务每秒钟执行一次,总共执行10次  timer.scheduleAtFixedRate(task, 0, 1000);  }  
}

Quartz

使用 Quartz,这是一个功能比较强大的的调度器,可以让程序在指定时间执行,也可以按照某一个频度执行,配置起来稍显复杂。

1、添加Quartz依赖
在你的项目中添加Quartz依赖。如果你使用Maven,请在pom.xml文件中添加以下依赖:

<dependency>  <groupId>org.quartz-scheduler</groupId>  <artifactId>quartz</artifactId>  <version>2.3.2</version> <!-- 请检查是否有更新的版本 -->  
</dependency>

2、创建Job类
创建一个简单的Job类,它将执行你想要定期执行的任务。在这个例子中,我们将创建一个简单的Job,只是打印一条消息。

public class MyJob implements Job {  public void execute(JobExecutionContext context) throws JobExecutionException {  System.out.println("定时任务执行中...");  }  
}

3、创建Scheduler和任务计划
创建一个Scheduler实例,并设置任务计划。在这个例子中,我们将创建一个简单的定时任务,每5秒执行一次。

import org.quartz.*;  
import org.quartz.impl.StdSchedulerFactory;  public class QuartzSchedulerExample {  public static void main(String[] args) {  try {  Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();  JobDetail job = JobBuilder.newJob(MyJob.class)  .withIdentity("myJob", "group1")  .build();  Trigger trigger = TriggerBuilder.newTrigger()  .withIdentity("myTrigger", "group1")  .startNow()  .withSchedule(SimpleScheduleBuilder.simpleSchedule()  .withIntervalInSeconds(5) // 每5秒执行一次任务  .repeatForever()) // 无限循环执行任务  .build();  scheduler.scheduleJob(job, trigger);  scheduler.start(); // 启动调度器  } catch (SchedulerException e) {  e.printStackTrace();  }  }  
}

5、运行示例代码
运行QuartzSchedulerExample类的main方法。你应该看到控制台输出"定时任务执行中…",每5秒一次。

Spring的@Scheduled注解

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

1、首先,在你的Spring Boot项目的pom.xml文件中,添加Spring Scheduled的依赖:

<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-scheduling</artifactId>  
</dependency>

2、创建一个定时任务类,例如MyScheduledTask.java:

import org.springframework.scheduling.annotation.Scheduled;  
import org.springframework.stereotype.Component;  @Component  
public class MyScheduledTask {  @Scheduled(fixedRate = 5000) // 每5秒执行一次  public void execute() {  System.out.println("定时任务执行中...");  }  
}

3、在主应用类或配置类上添加@EnableScheduling注解,以启用定时任务支持:

import org.springframework.boot.SpringApplication;  
import org.springframework.boot.autoconfigure.SpringBootApplication;  
import org.springframework.scheduling.annotation.EnableScheduling;  @SpringBootApplication  
@EnableScheduling  
public class MySpringBootApplication {  public static void main(String[] args) {  SpringApplication.run(MySpringBootApplication.class, args);  }  
}

运行你的Spring Boot应用。现在,你应该每5秒在控制台看到"定时任务执行中…"的输出。

http://www.lryc.cn/news/239055.html

相关文章:

  • 木子-前端-方法标签属性小记(普通jsp/html篇)2023~2024
  • 音视频项目—基于FFmpeg和SDL的音视频播放器解析(十七)
  • 使用netty实现WebSocket协议通信
  • uniapp开发小程序,包过大解决方案
  • Go语言中string与byte转换
  • 机器学习8:在病马数据集上进行算法比较(ROC曲线与AUC)
  • 70. 爬楼梯 --力扣 --JAVA
  • 体感互动游戏VR游戏AR体感游戏软件开发
  • 计算3个点的6种分布在平面上的占比
  • 【香橙派】实战记录1——简介及烧录 Linux 镜像
  • redis之高可用
  • 使用 Core Tools 在本地开发 Azure Functions
  • Java零基础——Spring篇
  • jenkins清理缓存命令
  • 什么是深度学习
  • 数字IC基础:有符号数和无符号数加、减法的Verilog设计
  • 2023年11月25日(星期六)骑行三家村
  • .skip() 和 .only() 的使用
  • 如何证明特征值的几何重数不超过代数重数
  • Android修行手册-POI操作Excel文档
  • 浅析教学型数控车床使用案例
  • 图论 2023.11.20
  • 思福迪 运维安全管理系统 test_qrcode_b 远程命令执行漏洞
  • electron项目开机自启动
  • 2023年约特干故城夜间演艺《万方乐奏有于阗》完美谢幕
  • 学习网络编程No.10【深入学习HTTPS】
  • ubuntu下docker环境使用GPU配置
  • 渗透工具---BurpSuite 插件开发之HelloWorld
  • 2216. 美化数组的最少删除数
  • 竞赛 题目:基于深度学习的人脸表情识别 - 卷积神经网络 竞赛项目 代码