Spring Boot整合ElasticJob定时任务教程

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

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

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

引入依赖

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

    org.apache.shardingsphere.elasticjob
    elasticjob-lite-spring-boot-starter
    3.0.3



    org.apache.curator
    curator-recipes
    5.2.0

注意版本号要匹配当前使用的 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());
    }
}

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

• 定义了一个 Bean，名字是任务名 "myElasticJob"。
• 设置了 cron 表达式为每 5 秒执行一次。
• 分片数量设为 3，每个分片分别对应 A、B、C。
• 使用 ScheduleJobBootstrap 启动任务。

这样，任务就注册好了，项目一启动就会开始调度。

注意事项与小技巧

• Zookeeper 必须先启动：否则 ElasticJob 初始化会失败。
• 任务不能重复注册：同一个任务名不能重复注册，否则会抛异常。
• 分片参数合理设置：分片总数决定了并发度，可以根据服务器资源调整。
• 任务重启机制：如果任务崩溃，Zookeeper 会重新分配任务给其他节点（前提是部署了多实例）。

基本上就这些步骤了。整个过程不算复杂，但有几个关键点容易忽略，比如版本兼容性、Zookeeper 状态、任务名冲突等。只要把这些细节处理好，ElasticJob 在 Spring Boot 中的整合还是很顺利的。