ElasticJob 分布式任务调度框架：新手入门完整指南

2026-01-30 04:32:06作者：胡易黎Nicole

项目地址：https://gitcode.com/gh_mirrors/shar/shardingsphere-elasticjob

ElasticJob 是 Apache ShardingSphere 旗下的分布式任务调度框架，通过灵活调度、资源管理和作业治理三大核心功能，为互联网场景提供了一站式的分布式调度解决方案。作为一款轻量级、去中心化的分布式任务分片服务，ElasticJob 让开发者无需担心作业水平扩展等非功能性需求，从而更专注于业务编码。🚀

什么是 ElasticJob？

ElasticJob 是一个分布式任务调度框架，其核心价值在于弹性调度和分片机制。它能够感知分布式环境中的服务器数量变化，自动重新分配作业分片，实现真正的弹性伸缩。

核心功能特性

弹性调度能力

ElasticJob 最重要的特性就是弹性调度，它通过作业分片实现作业的水平扩展。当服务器数量增减时，ElasticJob 会重新分配作业分片，最大化资源利用效率。

分片机制：将作业拆分成多个独立的分片项，由分布式服务器分别执行其中的一部分。例如，一个作业被分成4个分片，有两台服务器执行，则每台服务器承担50%的工作量。

高可用与故障转移

当执行分片的服务器宕机时，注册中心会感知到这一情况，该分片将被转移到其他存活的服务器上，实现高可用性目标。

资源最大化利用

ElasticJob 提供了灵活的方式来最大化作业的吞吐量。当新的作业服务器加入时，ElasticJob 会在下一次调度过程中重新分片，新服务器将承担部分作业分片。

快速开始使用

环境要求

Java：Java 8 或以上版本
Maven：Maven 3.5.0 或以上版本
ZooKeeper：ZooKeeper 3.6.0 或以上版本

添加 Maven 依赖

在项目的 pom.xml 中添加 ElasticJob 依赖：

<dependency>
    <groupId>org.apache.shardingsphere.elasticjob</groupId>
    <artifactId>elasticjob-bootstrap</artifactId>
    <version>${latest.release.version}</version>
</dependency>

开发作业类

创建作业类实现 SimpleJob 接口：

public class MyJob implements SimpleJob {
    @Override
    public void execute(ShardingContext context) {
        // 根据分片项执行业务逻辑
        switch (context.getShardingItem()) {
            case 0:
                // 处理分片项0的业务
                break;
            case 1:
                // 处理分片项1的业务
                break;
            // 更多分片项...
        }
    }
}

配置和调度作业

public class MyJobDemo {
    public static void main(String[] args) {
        new ScheduleJobBootstrap(createRegistryCenter(), new MyJob(), createJobConfiguration()).schedule();
    }

    private static CoordinatorRegistryCenter createRegistryCenter() {
        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(
            new ZookeeperConfiguration("zk_host:2181", "my-job"));
        regCenter.init();
        return regCenter;
    }

    private static JobConfiguration createJobConfiguration() {
        return JobConfiguration.newBuilder("MyJob", 3)
            .cron("0/5 * * * * ?")
            .build();
    }
}