SpringCloud与elastic-job集成(一)

原创

3号攻城狮

发布于 2018-06-10 10:16:37

6.6K0

文章被收录于专栏：微服务那些事儿微服务那些事儿

背景

在项目初期,基于quartz我们做了一个原始的job调度服务,用以执行我们的定时任务,但是随着业务的扩充,对性能及稳定性有了更高的要求.

就目前而言,除了优化代码,调整单机硬件设备外,已经没有其他方式了,对定时任务代改造势在必行.

elastic-job

elastic-job相关资料可以从如下博文中获取,总结的非常好,就不在重复赘述,本文仅仅解决如何与SpringCloud集成的问题.

官网:http://elasticjob.io/docs/elastic-job-lite/00-overview
参考资料:https://blog.csdn.net/lovelong8808/article/category/7670721
项目开源地址:https://github.com/elasticjob

elastic-job-spring-boot-starter

将elastic-job以组件的形式引入,在该过程中参考了:

项目开源地址:https://github.com/yinjihuan/elastic-job-spring-boot-starter

将源码克隆下来后,按照readme文件,配置zookeeper及其他信息:

与SpringCloud集成

基于elastic-job-spring-boot-starter及我们自身的实际情况,我重写了该starter,添加了我们自己的处理方式,具体处理会在下一篇的文章中与大家分享.

在集成过程中需要注意的是,插件自身的:curator-client,curator-framework,curator-recipes与SpringCloud组件中的curator-client,curator-framework,curator-recipes有版本冲突.

排查问题过程很痛苦.最终在开源中国中得到了解答:

https://www.oschina.net/question/3711138_2268227?sort=time

<properties>
   <elastic-job.version>2.1.5</elastic-job.version>
   <curator.version>2.10.0</curator.version>
</properties>

<dependencies>
     <dependency>
            <groupId>com.dangdang</groupId>
            <artifactId>elastic-job-lite-core</artifactId>
            <version>${elastic-job.version}</version>
            <exclusions>
                <exclusion>
                    <artifactId>curator-client</artifactId>
                    <groupId>org.apache.curator</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>curator-framework</artifactId>
                    <groupId>org.apache.curator</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>curator-recipes</artifactId>
                    <groupId>org.apache.curator</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>${curator.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-client</artifactId>
            <version>${curator.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>${curator.version}</version>
        </dependency>
</dependencies>

elastic-job-lite-console

这是个elastic-job的管理台控制工具.

具体安装部署可参考:

https://blog.csdn.net/u013274055/article/details/77767506?locationNum=5&fps=1

elastic-job-lite-lifecycle

该插件配合elastic-job-lite-console使用,可以通过API操控JOB运行状态

插件引入

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

核心代码

JobOperateAPI jobAPIService= JobAPIFactory.createJobOperateAPI("zookeeper地址", "任务命名空间", Optional.fromNullable(null));
jobAPIService.trigger(Optional.of("定时任务类的全类名"), Optional.<String>absent())

public interface JobOperateAPI {
    void trigger(Optional<String> var1, Optional<String> var2);

    void disable(Optional<String> var1, Optional<String> var2);

    void enable(Optional<String> var1, Optional<String> var2);

    void shutdown(Optional<String> var1, Optional<String> var2);

    void remove(Optional<String> var1, Optional<String> var2);
}