Spring Boot 整合 ElasticJob 分布式任务调度教程

news2025/4/2 0:50:29

精心整理了最新的面试资料和简历模板，有需要的可以自行获取

点击前往百度网盘获取
点击前往夸克网盘获取

Spring Boot 整合 ElasticJob 分布式任务调度教程

一、ElasticJob 简介

ElasticJob 是当当网开源的分布式任务调度解决方案，支持：

分布式调度：自动分片、负载均衡
弹性调度：服务器宕机自动故障转移
定时任务：支持Cron表达式
任务监控：运维控制台可视化

二、环境准备

JDK 1.8+
Maven 3.6+
Spring Boot 2.7.x
ElasticJob 3.0.3
ZooKeeper 3.8.1（用于注册中心）

三、整合步骤

1. 创建Spring Boot项目

通过 start.spring.io 创建基础项目，选择 Web 依赖

2. 添加依赖

<!-- ElasticJob 核心依赖 -->
<dependency>
    <groupId>org.apache.shardingsphere.elasticjob</groupId>
    <artifactId>elasticjob-lite-spring-boot-starter</artifactId>
    <version>3.0.3</version>
</dependency>

<!-- ZooKeeper 客户端 -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>5.4.0</version>
</dependency>

3. 配置ElasticJob

application.yml 配置：

elasticjob:
  reg-center:
    server-lists: localhost:2181  # ZooKeeper地址
    namespace: elasticjob-demo   # 命名空间

4. 编写定时任务

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

@Component
public class MyElasticJob implements SimpleJob {

    @Override
    public void execute(ShardingContext context) {
        System.out.println("------ 任务执行开始 ------");
        System.out.println("分片总数: " + context.getShardingTotalCount());
        System.out.println("当前分片: " + context.getShardingItem());
        System.out.println("分片参数: " + context.getShardingParameter());
        // 添加业务逻辑
    }
}

5. 任务配置类

import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ElasticJobConfig {

    @Bean
    public JobConfiguration myJobConfig() {
        return JobConfiguration.newBuilder("myJob", 3)  // 任务名称和分片数
                .cron("0/5 * * * * ?")  // 每5秒执行一次
                .shardingItemParameters("0=A,1=B,2=C")  // 分片参数
                .overwrite(true)  // 本地配置覆盖注册中心
                .build();
    }
}

四、ZooKeeper配置

下载并启动ZooKeeper：

# 解压后修改配置
cp conf/zoo_sample.cfg conf/zoo.cfg
# 启动服务
bin/zkServer.sh start

五、启动与测试

启动Spring Boot应用
查看控制台输出：

------ 任务执行开始 ------
分片总数: 3
当前分片: 0
分片参数: A

------ 任务执行开始 ------
分片总数: 3
当前分片: 1
分片参数: B

------ 任务执行开始 ------
分片总数: 3
当前分片: 2
分片参数: C

六、高级配置

1. 任务事件追踪

elasticjob:
  tracing:
    type: RDB  # 使用数据库存储日志
    rdb:
      url: jdbc:mysql://localhost:3306/ej_log
      username: root
      password: root

2. 任务监听器

public class MyJobListener implements ElasticJobListener {

    @Override
    public void beforeJobExecuted(ShardingContext context) {
        System.out.println("任务开始执行");
    }

    @Override
    public void afterJobExecuted(ShardingContext context) {
        System.out.println("任务执行结束");
    }
}

// 配置类中添加
@Bean
public ElasticJobListener myJobListener() {
    return new MyJobListener();
}