当前位置：首页 > 文章列表 > 文章 > java教程 > SpringBoot整合ElasticJob定时任务详解

SpringBoot整合ElasticJob定时任务详解

2025-08-13 20:54:28 0浏览收藏

本文详细介绍了如何在 Spring Boot 项目中整合 ElasticJob，实现强大的分布式定时任务功能。首先，需要在项目中引入 ElasticJob 和 Curator 依赖，并注意版本匹配。接着，配置 Zookeeper 连接信息，包括地址和命名空间，ElasticJob 将使用 Zookeeper 作为注册中心。然后，编写具体的任务类，实现 SimpleJob 接口并重写 execute 方法，编写业务逻辑。最后，通过 JobConfiguration 和 ScheduleJobBootstrap 注册任务，设置 cron 表达式和分片参数。此外，文章还强调了 Zookeeper 启动顺序、避免任务名重复、合理设置分片参数等注意事项，帮助开发者顺利完成 Spring Boot 与 ElasticJob 的整合，轻松实现数据同步、日志清理等定时任务需求。

Spring Boot 整合 ElasticJob 的步骤包括引入依赖、配置 Zookeeper、编写任务类、注册任务。① 引入 ElasticJob 和 Curator 依赖，注意版本匹配；② 在 application.yml 中配置 Zookeeper 地址和命名空间；③ 创建实现 SimpleJob 接口的任务类并重写 execute 方法；④ 通过 JobConfiguration 和 ScheduleJobBootstrap 注册任务并设置 cron 表达式与分片参数；注意事项包括确保 Zookeeper 先启动、避免任务名重复、合理设置分片参数及考虑任务重启机制。

Spring Boot整合ElasticJob实现定时任务详细步骤

定时任务在很多业务场景中必不可少，比如数据同步、日志清理、报表生成等。ElasticJob 是当当开源的一个分布式调度解决方案，和 Spring Boot 结合后可以非常方便地实现任务调度功能。

下面我来详细说一下 Spring Boot 整合 ElasticJob 的具体步骤，适合有一定 Java 基础的开发者参考。

引入依赖

首先要在项目中引入 ElasticJob 和 Zookeeper 相关的依赖。Spring Boot 项目一般使用 Maven 或 Gradle 管理依赖，这里以 Maven 为例：

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

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>5.2.0</version>
</dependency>

注意版本号要匹配当前使用的 ElasticJob 版本，目前推荐使用 3.x 版本，它对 Spring Boot 支持更好。

如果你用的是 Spring Boot 2.x，这个 starter 已经足够支持基本功能了。

配置 Zookeeper 连接信息

ElasticJob 使用 Zookeeper 来做注册中心，所以需要配置 Zookeeper 地址。通常写在 application.yml 文件中：

elasticjob:
  reg-center:
    server-lists: localhost:2181
    namespace: elasticjob-example

其中：

server-lists 是你的 Zookeeper 地址，多个地址可以用逗号分隔。
namespace 是命名空间，用于隔离不同环境的任务（如 dev、test）。

启动项目时，ElasticJob 会自动连接到指定的 Zookeeper 实例，并在对应命名空间下创建节点。

编写定时任务类

接下来就是编写具体的任务逻辑。你需要创建一个类并继承 SimpleJob 接口，然后重写它的 execute() 方法。

举个例子：

import org.apache.shardingsphere.elasticjob.api.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;

public class MyElasticJob implements SimpleJob {

    @Override
    public void execute(ShardingContext shardingContext) {
        System.out.println("当前分片项：" + shardingContext.getShardingItem() 
                + "，总分片数：" + shardingContext.getShardingTotalCount());
        // 这里写你的业务逻辑
    }
}

这个类实现了简单的任务执行逻辑。你可以根据需要在里面调用数据库操作、发送邮件、处理文件等。

注册任务配置

最后一步是将任务注册进 ElasticJob 框架。可以在 Spring Boot 的配置类中通过注解方式完成：

import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import org.apache.shardingsphere.elasticjob.lite.api.bootstrap.impl.ScheduleJobBootstrap;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class JobConfig {

    @Bean
    public ScheduleJobBootstrap myElasticJobBootstrap(MyElasticJob myElasticJob) {
        return new ScheduleJobBootstrap(myElasticJob, 
                JobConfiguration.newBuilder("myElasticJob", 3)
                        .cron("0/5 * * * * ?")
                        .shardingItemParameters("0=A,1=B,2=C")
                        .build());
    }
}

上面这段代码做了几件事：