百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 热门文章 > 正文

java的定时任务解决方案有哪些?你会几种?

bigegpt 2025-03-19 10:41 7 浏览

一、 业务中的定时任务,java语言有哪些解决方案


产品经理说要定时发邮件,定时修改积分,定时发送短信。

在我们的开发过程中,经常需要用到定时任务。像php,python,sh,这些脚本语言,一般是配合linux的计划任务,但java就不一样了。让我们看看java中定时任务的实现吧。

Java 中有多种定时任务解决方案,下面列举了比较常用的几种:

Timer 和 TimerTask:Java 标准库提供的 Timer 类可以用于调度定时任务。Timer 通过创建一个背景线程定期执行 TimerTask 来实现定时任务。使用简单,但是不适用于大规模的和高并发的应用程序。

package test;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;

public class MyTimerTask {
    public static void main(String[] args) {
        TimerTask timerTask = new TimerTask() {
            @Override
            public void run() {
                SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss.SSS");
                String dateStr = sdf.format(new Date());
                System.out.println("运行定时任务:" + dateStr);
            }
        };

        Timer timer = new Timer();
        timer.schedule(timerTask, 1000, 3000);

    }
}


// 在指定延迟时间后执行指定的任务
schedule(TimerTask task,long delay);
 
// 在指定时间执行指定的任务。(只执行一次)
schedule(TimerTask task, Date time);
 
// 延迟指定时间(delay)之后,开始以指定的间隔(period)重复执行指定的任务
schedule(TimerTask task,long delay,long period);
 
// 在指定的时间开始按照指定的间隔(period)重复执行指定的任务
schedule(TimerTask task, Date firstTime , long period);
 
// 在指定的时间开始进行重复的固定速率执行任务
scheduleAtFixedRate(TimerTask task,Date firstTime,long period);
 
// 在指定的延迟后开始进行重复的固定速率执行任务
scheduleAtFixedRate(TimerTask task,long delay,long period);
 
// 终止此计时器,丢弃所有当前已安排的任务。
cancal();
 
// 从此计时器的任务队列中移除所有已取消的任务。
purge();
 

ScheduledExecutorService:Java 并发包中的 ScheduledExecutorService 可以用于以多种不同的方式执行定时任务。它支持延迟执行、周期性执行等多种类型的任务,并且可以非常容易地配置任务执行的线程池大小。

Quartz:Quartz 是一个流行的开源定时调度框架,可以配置和管理大规模和高并发的定时任务。它支持多种任务类型,支持分布式环境下的任务调度,还提供了丰富的管理和监控功能。

Spring Task:Spring 框架提供了一组用于调度任务的工具,包括基于注解的方法调度、任务异常处理和任务执行监听等功能。它可以与 Spring 应用程序集成,非常适合基于 Spring 的应用程序。

根据具体的需求和场景,选择适合的定时任务解决方案非常重要。例如,对于小规模的和简单的应用程序,可以选择 Timer 或 ScheduledExecutorService;对于复杂的和高并发的应用程序,可以选择 Quartz 或 Spring Task。

二、Quartz是什么呢

Quartz 是一个流行的开源定时调度框架,它可以帮助我们管理和调度多个任务。Quartz 可以在指定的时间或间隔时间内自动执行指定的任务,支持基于日历的异常处理、分布式环境下的任务调度、任务执行监听等功能。Quartz 还提供了丰富的管理和监控功能,让我们可以方便地查看正在运行的任务、已经完成的任务以及任务的执行情况和状态。

Quartz 中最常用的对象是 Job 和 Trigger。Job 是可执行的任务,Trigger 触发 Job 执行的方式和时间。当 Trigger 触发时,Quartz 将启动一个新线程并执行相应的 Job。Quartz 中还有 Scheduler、JobDetail、JobDataMap 等对象,可用于配置和管理任务的执行。

使用 Quartz 可以帮助我们管理复杂的任务调度,避免手动进行任务调度和管理过程中的疏忽和错误。同时,Quartz 支持多种任务类型和任务调度算法,可以满足不同场景下的需求。因此,Quartz 在众多 Java 定时任务框架中得到了广泛的应用。

三、中各个类和组件的功能

Quartz 是一个大型、功能强大的框架,主要由以下几个组成部分构成:

1. Scheduler:Quartz 中最核心的组件,负责任务调度和执行。Scheduler 可以启动、停止、暂停和恢复任务的执行,并提供了一些管理和监控任务的 API。

2. Job:可执行的任务,Quartz 提供了 Job 接口,我们需要实现该接口并编写任务的具体逻辑。

3. Trigger:触发器,用于定义任务的触发方式和调度计划。Quartz 支持多种触发器类型,如简单触发器、Cron 触发器等。

4. JobDetail:封装了任务的详细信息,包括任务名称、任务组名、Job 类等。

5. JobDataMap:用于传递任务执行时需要的参数和数据,可在 JobDetail 和 Trigger 中设置和获取 JobDataMap。

6. Listener:Quartz 支持多种监听器接口,如 JobListener、TriggerListener 等,可以用于在任务执行前后做一些处理,如记录日志、发送通知等。

7. JobStore:任务存储器,负责将任务和触发器存储到数据库或内存中,并提供了查询和修改任务、触发器等的 API。

8. SchedulerFactory:负责创建 Scheduler 实例。

Quartz 的各个组件之间相互依赖,形成了一个完整的调度系统。开发者只需要通过配置和使用上述组件,即可轻松实现复杂的任务调度和执行逻辑。

四、怎么和springboot结合呢。

Quartz 可以与 Spring Boot 集成,这样就可以在 Spring Boot 应用中方便地使用 Quartz 进行任务调度和管理。具体步骤如下:

  1. 在 pom.xml 文件中添加 Quartz 和 Spring Boot Starter Quartz 的依赖:

    org.quartz-scheduler
    quartz
    2.3.2



    org.springframework.boot
    spring-boot-starter-quartz

  1. 在 application.properties 或 application.yml 文件中配置 Quartz 和数据源相关的属性。例如:
spring.quartz.job-store-type=jdbc
spring.datasource.url=jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=utf-8&useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
  1. 创建 Job 类,在其中编写需要执行的任务逻辑。例如:
@Component
public class MyJob implements Job {
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        // 任务逻辑
    }
}
  1. 创建 Trigger 对象,定义任务触发方式和时间。例如:
@Bean
public Trigger myTrigger() {
    SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
            .withIntervalInSeconds(10) // 每 10 秒执行一次
            .repeatForever();

    return TriggerBuilder.newTrigger()
            .forJob(myJobDetail())
            .withIdentity("myTrigger", "group1")
            .withSchedule(scheduleBuilder)
            .build();
}
  1. 创建 JobDetail 对象,定义任务名称、组名和 Job 类。例如:
@Bean
public JobDetail myJobDetail() {
    return JobBuilder.newJob(MyJob.class)
            .withIdentity("myJob", "group1")
            .storeDurably()
            .build();
}
  1. 创建 SchedulerFactoryBean,并将 Trigger 和 JobDetail 注册到其中。例如:
@Bean
public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
    SchedulerFactoryBean scheduler = new SchedulerFactoryBean();
    scheduler.setDataSource(dataSource);
    scheduler.setOverwriteExistingJobs(true);
    scheduler.setQuartzProperties(quartzProperties());
    scheduler.setApplicationContextSchedulerContextKey("applicationContext");
    scheduler.setTriggers(myTrigger()); // 注册 Trigger 对象
    scheduler.setJobDetails(myJobDetail()); // 注册 JobDetail 对象
    return scheduler;
}
  1. 在需要调用任务的地方,注入 Scheduler 实例并调用相应的方法即可。例如:
@Autowired
private Scheduler scheduler;

...
scheduler.start();

通过以上步骤,就可以在 Spring Boot 应用中使用 Quartz 进行任务调度和管理。值得注意的是,在处理任务时,可以利用 Spring 的依赖注入机制和 AOP 框架,方便地实现对任务的事务处理、异常处理、日志记录等操作。


Spring Task(也称为 Spring Scheduling)

Spring Task(也称为 Spring Scheduling)是 Spring 框架提供的一种轻量级任务调度解决方案,它能够方便地实现任务的定时执行。下面是使用 Spring Task 的基本步骤:


  1. 在 Spring 配置文件中启用任务调度:
    在 Spring 的配置文件(如 applicationContext.xml 或者使用注解的方式)中,启用任务调度的功能。
    • XML 配置方式:
    • 注解方式:
      在配置类上添加 @EnableScheduling 注解。
  1. 创建任务类:
    创建一个带有 @Scheduled 注解的方法,该方法即为要定时执行的任务。
@Component
public class MyTask {
    @Scheduled(cron = "0 0/5 * * * ?") // 每隔5分钟执行一次
    public void executeTask() {
        // 任务的具体执行逻辑
        System.out.println("执行定时任务");
    }
}


  1. 配置任务调度规则:
    使用 @Scheduled 注解来配置任务的执行规则。可以根据不同的需求选择不同的规则,比如 cron 表达式、固定间隔时间、固定延迟时间等。
    这里使用了 cron 表达式 "0 0/5 * * * ?",表示每隔 5 分钟执行一次。
  2. 启动 Spring 应用程序:
    在 Spring 应用程序启动时,Spring Task 将根据配置自动扫描任务并进行定时调度。
    如果是基于 Spring Boot 的应用程序,则可以使用 @SpringBootApplication 注解的主类启动。


以上就是使用 Spring Task 的基本步骤。通过简单的配置和注解,在 Spring 框架中可以方便地实现任务调度和定时任务的管理和执行。

以上就是java中定时任务的解决方案了。下期分享shell的计划任务哈。

关注我,更快的找到问题解决方案。

相关推荐

得物可观测平台架构升级:基于GreptimeDB的全新监控体系实践

一、摘要在前端可观测分析场景中,需要实时观测并处理多地、多环境的运行情况,以保障Web应用和移动端的可用性与性能。传统方案往往依赖代理Agent→消息队列→流计算引擎→OLAP存储...

warm-flow新春版:网关直连和流程图重构

本期主要解决了网关直连和流程图重构,可以自此之后可支持各种复杂的网关混合、多网关直连使用。-新增Ruoyi-Vue-Plus优秀开源集成案例更新日志[feat]导入、导出和保存等新增json格式支持...

扣子空间体验报告

在数字化时代,智能工具的应用正不断拓展到我们工作和生活的各个角落。从任务规划到项目执行,再到任务管理,作者深入探讨了这款工具在不同场景下的表现和潜力。通过具体的应用实例,文章展示了扣子空间如何帮助用户...

spider-flow:开源的可视化方式定义爬虫方案

spider-flow简介spider-flow是一个爬虫平台,以可视化推拽方式定义爬取流程,无需代码即可实现一个爬虫服务。spider-flow特性支持css选择器、正则提取支持JSON/XML格式...

solon-flow 你好世界!

solon-flow是一个基础级的流处理引擎(可用于业务规则、决策处理、计算编排、流程审批等......)。提供有“开放式”驱动定制支持,像jdbc有mysql或pgsql等驱动,可...

新一代开源爬虫平台:SpiderFlow

SpiderFlow:新一代爬虫平台,以图形化方式定义爬虫流程,不写代码即可完成爬虫。-精选真开源,释放新价值。概览Spider-Flow是一个开源的、面向所有用户的Web端爬虫构建平台,它使用Ja...

通过 SQL 训练机器学习模型的引擎

关注薪资待遇的同学应该知道,机器学习相关的岗位工资普遍偏高啊。同时随着各种通用机器学习框架的出现,机器学习的门槛也在逐渐降低,训练一个简单的机器学习模型变得不那么难。但是不得不承认对于一些数据相关的工...

鼠须管输入法rime for Mac

鼠须管输入法forMac是一款十分新颖的跨平台输入法软件,全名是中州韵输入法引擎,鼠须管输入法mac版不仅仅是一个输入法,而是一个输入法算法框架。Rime的基础架构十分精良,一套算法支持了拼音、...

Go语言 1.20 版本正式发布:新版详细介绍

Go1.20简介最新的Go版本1.20在Go1.19发布六个月后发布。它的大部分更改都在工具链、运行时和库的实现中。一如既往,该版本保持了Go1的兼容性承诺。我们期望几乎所...

iOS 10平台SpriteKit新特性之Tile Maps(上)

简介苹果公司在WWDC2016大会上向人们展示了一大批新的好东西。其中之一就是SpriteKitTileEditor。这款工具易于上手,而且看起来速度特别快。在本教程中,你将了解关于TileE...

程序员简历例句—范例Java、Python、C++模板

个人简介通用简介:有良好的代码风格,通过添加注释提高代码可读性,注重代码质量,研读过XXX,XXX等多个开源项目源码从而学习增强代码的健壮性与扩展性。具备良好的代码编程习惯及文档编写能力,参与多个高...

Telerik UI for iOS Q3 2015正式发布

近日,TelerikUIforiOS正式发布了Q32015。新版本新增对XCode7、Swift2.0和iOS9的支持,同时还新增了对数轴、不连续的日期时间轴等;改进TKDataPoin...

ios使用ijkplayer+nginx进行视频直播

上两节,我们讲到使用nginx和ngixn的rtmp模块搭建直播的服务器,接着我们讲解了在Android使用ijkplayer来作为我们的视频直播播放器,整个过程中,需要注意的就是ijlplayer编...

IOS技术分享|iOS快速生成开发文档(一)

前言对于开发人员而言,文档的作用不言而喻。文档不仅可以提高软件开发效率,还能便于以后的软件开发、使用和维护。本文主要讲述Objective-C快速生成开发文档工具appledoc。简介apple...

macOS下配置VS Code C++开发环境

本文介绍在苹果macOS操作系统下,配置VisualStudioCode的C/C++开发环境的过程,本环境使用Clang/LLVM编译器和调试器。一、前置条件本文默认前置条件是,您的开发设备已...