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 中的整合还是很顺利的。
