接私活/工作必备-SpringBoot＋Elastic-Job的快速启动Demo-阿里云开发者社区

接私活/工作必备-SpringBoot＋Elastic-Job的快速启动Demo

2023-01-31 173

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

服务治理 MSE Sentinel/OpenSergo，Agent数量不受限

简介： 接私活/工作必备-SpringBoot＋Elastic-Job的快速启动Demo

如果你还没有掌握elasticjob的maven版本的快速入门，欢迎查看我上一篇文章，这次我们来讲springboot集成elasticJob。使得大家能够快速入门elasticjob，快速开始

elasticjob快速入门

仓库地址：

https://gitee.com/WangFuGui-Ma/elastic-job-quickstart

第一步，创建一个springboot项目并且导入jar包：

      <dependency>
            <groupId>com.dangdang</groupId>
            <artifactId>elastic-job-lite-spring</artifactId>
            <version>2.1.5</version>
        </dependency>

第二步，编写`RegistryCenterConfig`注册中心类

@Configuration
public class RegistryCenterConfig {
    @Value("${elasticJob.zookeeperUrl}")
    private String zookeeperUrl;
    @Value("${elasticJob.zookeeperNameSpace}")
    private String zookeeperNameSpace;
    @Bean(initMethod = "init")
    public CoordinatorRegistryCenter createRegistryCenter() {
        //注册中心
        ZookeeperConfiguration zkConfig = new ZookeeperConfiguration(zookeeperUrl, zookeeperNameSpace);
        zkConfig.setSessionTimeoutMilliseconds(100);
        return new ZookeeperRegistryCenter(zkConfig);
    }
}

第三步，编写`ElasticJobConfig`类

@Configuration
public class ElasticJobConfig {
    @Autowired
    private CoordinatorRegistryCenter registryCenterConfig;
    //加入bean注解就可以拿到MyJob
    @Bean(initMethod = "init")
    public SpringJobScheduler initJobConfiguration(MyJob myJob) {
        return new SpringJobScheduler(myJob, registryCenterConfig, createJobConfiguration(myJob.getClass(),"0/3 * * * * ?",1,null));
    }
    /**
     *
     * @param clazz 任务的字节码
     * @param cron 表达式
     * @param shrdingCount 分片个数
     * @param shardingParamter 分片参数
     * @return
     */
    private LiteJobConfiguration createJobConfiguration(Class<? extends ElasticJob> clazz, String cron, int shrdingCount, String shardingParamter) {
        JobCoreConfiguration.Builder builder = JobCoreConfiguration.newBuilder(clazz.getSimpleName(), cron, shrdingCount);
        if (StringUtils.isEmpty(shardingParamter)) {
            builder.shardingItemParameters(shardingParamter);
        }
        //创建作业配置
        SimpleJobConfiguration simpleJobConfiguration = new SimpleJobConfiguration(builder.build(), clazz.getCanonicalName());
        //覆盖zookeeper
        return LiteJobConfiguration.newBuilder(simpleJobConfiguration).overwrite(true).build();
    }
}

第四步，编写`MyJob`类

@Component
public class MyJob implements SimpleJob {
    public void execute(ShardingContext shardingContext) {
        System.out.println("定时任务开始执行了"+ new Date());
    }
}