百度360必应搜狗淘宝本站头条
分布式事务框架shiro框架框架图cad怎么画框架scrapy框架
当前位置：网站首页 > 技术文章 > 正文

Spring Boot中使用Elastic Job实现定时任务

ccwgpt 2024-11-09 11:23 20 浏览 0 评论

上一篇，我们介绍了如何使用Spring Boot自带的@Scheduled注解实现定时任务（https://blog.didispace.com/spring-boot-learning-2-7-1/）。文末也提及了这种方式的局限性。当在集群环境下的时候，如果任务的执行或操作依赖一些共享资源的话，就会存在竞争关系。如果不引入分布式锁等机制来做调度的话，就可能出现预料之外的执行结果。所以，@Scheduled注解更偏向于使用在单实例自身维护相关的一些定时任务上会更为合理一些，比如：定时清理服务实例某个目录下的文件、定时上传本实例的一些统计数据等。

那么，在实际实现业务逻辑的时候，没有更好的定时任务方案呢？今天我们就来介绍一个老牌的分布式定时任务框架，在Spring Boot下的使用案例。

Elastic Job

Elastic Job的前生是当当开源的一款分布式任务调度框架，而目前已经加入到了Apache基金会。

该项目下有两个分支：ElasticJob-Lite和ElasticJob-Cloud。ElasticJob-Lite是一个轻量级的任务管理方案，本文接下来的案例就用这个来实现。而
ElasticJob-Cloud则相对重一些，因为它使用容器来管理任务和隔离资源。

更多关于ElasticJob的介绍，您也可以点击这里直达官方网站（https://shardingsphere.apache.org/elasticjob/）了解更多信息。

动手试试

说那么多，一起动手试试吧！

第一步：创建一个最基础的Spring Boot项目，如果还不会？那么看看这篇快速入门（https://blog.didispace.com/spring-boot-learning-21-1-1/）。

第二步：pom.xml中添加elasticjob-lite的starter

<dependencies>
    <dependency>
        <groupId>org.apache.shardingsphere.elasticjob</groupId>
        <artifactId>elasticjob-lite-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    // ...
</dependencies>

第三步：创建一个简单任务

@Slf4j
@Service
public class MySimpleJob implements SimpleJob {

    @Override
    public void execute(ShardingContext context) {
        log.info("MySimpleJob start : didispace.com {}", System.currentTimeMillis());
    }

}

第四步：编辑配置文件

elasticjob.reg-center.server-lists=localhost:2181
elasticjob.reg-center.namespace=didispace

elasticjob.jobs.my-simple-job.elastic-job-class=com.didispace.chapter72.MySimpleJob
elasticjob.jobs.my-simple-job.cron=0/5 * * * * ?
elasticjob.jobs.my-simple-job.sharding-total-count=1

这里主要有两个部分：

第一部分：elasticjob.reg-center开头的，主要配置elastic job的注册中心和namespace

第二部分：任务配置，以elasticjob.jobs开头，这里的my-simple-job是任务的名称，根据你的喜好命名即可，但不要重复。任务的下的配置elastic-job-class是任务的实现类，cron是执行规则表达式，sharding-total-count是任务分片的总数。我们可以通过这个参数来把任务切分，实现并行处理。这里先设置为1，后面我们另外讲分片的使用。

运行与测试

完成了上面所有操作时候，我们可以尝试运行一下上面应用，因为这里需要用到ZooKeeper来协调分布式环境下的任务调度。所以，你需要先在本地安装ZooKeeper，然后启动它。注意：上面elasticjob.reg-center.server-lists配置，根据你实际使用的ZooKeeper地址和端口做相应修改。

在启动上述Spring Boot应用之后，我们可以看到如下日志输出：

2021-07-20 15:33:39.541  INFO 56365 --- [           main] org.quartz.impl.StdSchedulerFactory      : Quartz scheduler 'my-simple-job' initialized from an externally provided properties instance.
2021-07-20 15:33:39.541  INFO 56365 --- [           main] org.quartz.impl.StdSchedulerFactory      : Quartz scheduler version: 2.3.2
2021-07-20 15:33:39.551  INFO 56365 --- [           main] org.apache.curator.utils.Compatibility   : Using org.apache.zookeeper.server.quorum.MultipleAddresses
2021-07-20 15:33:40.067  INFO 56365 --- [           main] c.d.chapter72.Chapter72Application       : Started Chapter72Application in 3.25 seconds (JVM running for 4.965)
2021-07-20 15:33:40.069  INFO 56365 --- [           main] .s.b.j.ScheduleJobBootstrapStartupRunner : Starting ElasticJob Bootstrap.
2021-07-20 15:33:40.078  INFO 56365 --- [           main] org.quartz.core.QuartzScheduler          : Scheduler my-simple-job_$_NON_CLUSTERED started.
2021-07-20 15:33:40.078  INFO 56365 --- [           main] .s.b.j.ScheduleJobBootstrapStartupRunner : ElasticJob Bootstrap started.
2021-07-20 15:33:45.157  INFO 56365 --- [le-job_Worker-1] com.didispace.chapter72.MySimpleJob      : MySimpleJob start : didispace.com 1626766425157
2021-07-20 15:33:50.010  INFO 56365 --- [le-job_Worker-1] com.didispace.chapter72.MySimpleJob      : MySimpleJob start : didispace.com 1626766430010
2021-07-20 15:33:55.013  INFO 56365 --- [le-job_Worker-1] com.didispace.chapter72.MySimpleJob      : MySimpleJob start : didispace.com 1626766435013

既然是分布式任务调度，那么我们再启动一个（注意，在同一台机器启动的时候，会端口冲突，可以在启动命令中加入-Dserver.port=8081来区分端口），在第二个启动的服务日志也打印了类似的内容

2021-07-20 15:34:06.430  INFO 56371 --- [           main] org.quartz.impl.StdSchedulerFactory      : Quartz scheduler 'my-simple-job' initialized from an externally provided properties instance.
2021-07-20 15:34:06.430  INFO 56371 --- [           main] org.quartz.impl.StdSchedulerFactory      : Quartz scheduler version: 2.3.2
2021-07-20 15:34:06.436  INFO 56371 --- [           main] org.apache.curator.utils.Compatibility   : Using org.apache.zookeeper.server.quorum.MultipleAddresses
2021-07-20 15:34:06.786  INFO 56371 --- [           main] c.d.chapter72.Chapter72Application       : Started Chapter72Application in 1.446 seconds (JVM running for 1.884)
2021-07-20 15:34:06.787  INFO 56371 --- [           main] .s.b.j.ScheduleJobBootstrapStartupRunner : Starting ElasticJob Bootstrap.
2021-07-20 15:34:06.792  INFO 56371 --- [           main] org.quartz.core.QuartzScheduler          : Scheduler my-simple-job_$_NON_CLUSTERED started.
2021-07-20 15:34:06.792  INFO 56371 --- [           main] .s.b.j.ScheduleJobBootstrapStartupRunner : ElasticJob Bootstrap started.
2021-07-20 15:34:10.182  INFO 56371 --- [le-job_Worker-1] com.didispace.chapter72.MySimpleJob      : MySimpleJob start : didispace.com 1626766450182
2021-07-20 15:34:15.010  INFO 56371 --- [le-job_Worker-1] com.didispace.chapter72.MySimpleJob      : MySimpleJob start : didispace.com 1626766455010
2021-07-20 15:34:20.013  INFO 56371 --- [le-job_Worker-1] com.didispace.chapter72.MySimpleJob      : MySimpleJob start : didispace.com 1626766460013

此时，在回头看看之前第一个启动的应用，日志输出停止了。由于我们设置了分片总数为1，所以这个任务启动之后，只会有一个实例接管执行。这样就避免了多个进行同时重复的执行相同逻辑而产生问题的情况。同时，这样也支持了任务执行的高可用。比如：可以尝试把第二个启动的应用（正在打印日志的）终止掉。可以发现，第一个启动的应用（之前已经停止输出日志）继续开始打印任务日志了。

在整个实现过程中，我们并没有自己手工的去编写任何的分布式锁等代码去实现任务调度逻辑，只需要关注任务逻辑本身，然后通过配置分片的方式来控制任务的分割，就可以轻松的实现分布式集群环境下的定时任务管理了。是不是在复杂场景下，这种方式实现起来要比@Scheduled更方便呢？

记得自己动手写一写，这样体会更深哦！如果碰到问题，可以拉取文末的代码示例对比一下是否有地方配置不一样。下一篇，我们还将继续介绍关于定时任务的一些高级内容。关注我，收藏本系列教程《Spring Boot 2.x基础教程》（http://blog.didispace.com/spring-boot-learning-2x/）。学习过程中如遇困难，建议加入Spring技术交流群（https://blog.didispace.com/join-group-spring/index.html），参与交流与讨论，更好的学习与进步！

代码示例

本文的完整工程可以查看下面仓库中的chapter7-2目录：

  • Github：https://github.com/dyc87112/SpringBoot-Learning/
  • Gitee：https://gitee.com/didispace/SpringBoot-Learning/

如果您觉得本文不错，欢迎Star支持，您的关注是我坚持的动力！

相关推荐

定时任务工具，《此刻我要...》软件体验

之前果核给大家介绍过一款小众但实用的软件——小说规则下载器，可以把网页里的小说章节按照规则下载到本地，非常适合喜欢阅读小说的朋友。有意思的是，软件作者当时看到果核写的体验内容后，给反推荐到他的帖子里去...

前端定时任务的神库:Node-cron，让你的项目更高效!

在前端开发中，定时任务是一个常见的需求。无论是定时刷新数据、轮询接口，还是发送提醒，都需要一个可靠且灵活的定时任务解决方案。今天，我要向大家介绍一个强大的工具——Node-cron，它不仅能解决定时任...

Shutter Pro!一款多功能定时执行任务工具

这是一款可以在电脑上定时执行多种任务的小工具，使用它可以根据时间，电量等来设定一些定时任务，像定时打开程序、打开文件，定时关机重启，以及定时弹窗提醒等都可以轻松做到。这是个即开即用的小工具，无需安装，...

深度解析 Redis 缓存击穿及解决方案

在当今互联网大厂的后端开发体系中，Redis缓存占据着极为关键的地位。其凭借高性能、丰富的数据类型以及原子性操作等显著优势，助力众多高并发系统从容应对海量用户的访问冲击，已然成为后端开发从业者不可或...

从零搭建体育比分网站完整步骤（比较好的体育比分软件）

搭建一个体育比分网站是一个涉及前端、后端、数据源、部署和维护的完整项目。以下是从零开始搭建的详细流程：一、明确项目需求1.功能需求：实时比分展示（如足球、篮球、网球等）支持多个联赛和赛事历史数据查询比...

告别复杂命令行:GoCron 图形界面让定时任务触手可及

如果你是运维人员或者经常接触一些定时任务的配置，那么你一定希望有一款图形界面来帮助你方便的轻松配置定时任务，而GoCron就是这样一款软件，让你的配置可视化。什么是GoCron从名字你就可以大概猜到，...

Java任务管理框架核心技术解析与分布式高并发实战指南

在当今数字化时代，Java任务管理框架在众多应用场景中发挥着关键作用。随着业务规模的不断扩大，面对分布式高并发的复杂环境，掌握其核心技术并进行实战显得尤为重要。Java任务管理框架的核心技术涵盖多个方...

链表和结构体实现:MCU软件定时器（链表在单片机中的应用）

在一般的嵌入式产品设计中，介于成本、功耗等，所选型的MCU基本都是资源受限的，而里面的定时器的数量更是有限。在我们软件设计中往往有多种定时需求，例如脉冲输出、按键检测、LCD切屏延时等等，我们不可能...

SpringBoot定时任务（springboot定时任务每小时执行一次）

前言在我们开发中，经常碰到在某个时间点去执行某些操作，而我们不能人为的干预执行，这个时候就需要我们使用定时任务去完成该任务，下面我们来介绍下载springBoot中定时任务实现的方式。定时任务实现方式...

定时任务新玩法!systemd timer 完整实战详解

原文链接：「链接」Hello，大家好啊！今天给大家带来一篇使用systemdtimer实现定时任务调度的详细实战文章。相比传统的crontab，systemdtimer更加现代化、结构清晰...

Celery与Django:打造高效DevOps的定时任务与异步处理神器

本文详细介绍了Celery这一强大的异步任务队列系统，以及如何在Django框架中应用它来实现定时任务和异步处理，从而提高运维开发（DevOps）的效率和应用性能。下面我们先认识一下Cele...

订单超时自动取消的7种方案，我用这种!

前言在电商、外卖、票务等系统中，订单超时未支付自动取消是一个常见的需求。这个功能乍一看很简单，甚至很多初学者会觉得："不就是加个定时器么？"但真到了实际工作中，细节的复杂程度往往会超...

裸机下多任务框架设计与实现（gd32裸机配置lwip 网络ping不通）

在嵌入式系统中，特别是在没有操作系统支持的裸机环境下，实现多任务执行是一个常见的挑战。本文将详细介绍一种基于定时器的多任务框架设计，通过全局时钟和状态机机制，实现任务的非阻塞调度，确保任务执行中不会出...

亿级高性能通知系统构建，小白也能拿来即用

作者介绍赵培龙，采货侠JAVA开发工程师分享概要一、服务划分二、系统设计1、首次消息发送2、重试消息发送三、稳定性的保障1、流量突增2、问题服务的资源隔离3、第三方服务的保护4、中间件的容错5、完善...

运维实战:深度拆解Systemd定时任务原理，90%的人不知道的玩法

运维实战：深度拆解Systemd定时任务原理，90%的人不知道的高效玩法一、Systemd定时任务的核心原理Systemd定时任务是Linux系统中替代传统cron的现代化解决方案，通过...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表