分布式定时任务 Elastic Job 开发部署实战（结合Spring Boot开发分布式任务调度）

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
 
@SpringBootApplication
@EnableScheduling
public class ElasticJobSpringBootStarterDemo {
    public static void main(String[] args) {
        SpringApplication.run(ElasticJobSpringBootStarterDemo.class, args);
    }
}
 
// 定义作业执行的业务逻辑
public class MySimpleJob implements SimpleJob {
    @Override
    public void execute(ShardingContext context) {
        String jobName = context.getJobName();
        int shardingTotalCount = context.getShardingTotalCount();
        int shardingItem = context.getShardingItem();
        String shardingParameter = context.getShardingParameter();
        String hostname = context.getHostname();
 
        // 实现作业具体逻辑
        System.out.println(String.format("作业名称 = %s, 分片总数 = %d, 分片编号 = %d, 分片参数 = %s, 执行主机 = %s.",
                jobName, shardingTotalCount, shardingItem, shardingParameter, hostname));
    }
}
 
// 作业配置
@Configuration
public class JobConfig {
    @Bean
    public JobCoreConfiguration simpleJobConfig() {
        return JobCoreConfiguration.newBuilder("mySimpleJob", "0/15 * * * * ?", 10).build();
    }
 
    @Bean
    public SimpleJob simpleJob(JobCoreConfiguration simpleJobConfig) {
        return new MySimpleJob();
    }
}

这个代码实例展示了如何在Spring Boot应用中使用Elastic Job实现分布式定时任务。首先，我们创建了一个Spring Boot应用的入口类，启动了Spring应用上下文。接着，我们定义了一个实现了SimpleJob接口的作业类MySimpleJob，它的execute方法将会在作业触发时执行。在JobConfig配置类中，我们配置了作业的核心参数，包括作业名称、cron表达式和分片总数。最后，我们将作业配置作为Bean注册到Spring容器中。这样，当Spring Boot应用启动时，Elastic Job也会自动启动，并按照配置执行定时任务。