当前位置：首页 > article >正文

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

article 2024/12/22 10:10:57

背景

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

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

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

库

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);  
    }  
}