elastic-job控制台部署与使用

柔光的暖阳◎ 2022-12-19 11:51 1047阅读 0赞

## 前言 ##

elastic-job官方提供了对于后台应用中的job管控台，可以比较方便的对正在运行的分布式job做一些基本的管理，比如修改job配置参数，启停，废除任务等，下面让我们将控制台部署起来看看效果如何

**1、git下载elasticjob源码**

git地址：https://github.com/apache/shardingsphere-elasticjob

通过git命令将项目下载到服务器或者本地，  
![在这里插入图片描述][20201107110228551.png_pic_center]

**2、进入项目根目录，执行编译打包命令**

mvn clean install -Dmaven.test.skip=true

经过漫长的打包，终于将所需的包打好了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center]

**3、将控制台的jar包拷贝到本地并启动**  
![在这里插入图片描述][20201107112000807.png_pic_center]

windows环境下，进入bin目录后，可以直接通过start.bat进行启动  
![在这里插入图片描述][20201107112025334.png_pic_center]  
启动成功后，默认的段开是8899,浏览器访问:localhost:8899，可以看到如下界面  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 1]

## 管控台使用 ##

**1、配置zk注册中心**

通过之前的内容我们知道，es-job依赖zk,因此首先我们需要将zk的配置信息添加进去  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 2]  
**2、job操作**

后台启动服务，以上一篇的simpleJob为例，当job开始运行之后，在控制台的作业操作一栏，可以看到任务的相关参数信息已经展示在列表上面了，对应着程序中job的配置参数

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 3]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 4]

基于此，我们可以对当前运行中的job做相应的操作

**详情**  
![在这里插入图片描述][20201107113442455.png_pic_center]  
列出当前job对应的分片项信息，比如当前的这个job设置了2个分片，由于只启动了一个示例，而且在同一台机器，因此IP相同，进程号也一样

**点击失效**  
![在这里插入图片描述][20201107121305404.png_pic_center]  
这时发现分片项0已经失效，后台不再输出关于分片项0的信息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 5]

**修改**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 6]  
点击修改可以看到关于当前simpleJob的完整参数信息，当前的job每5秒执行一次，假如我们将其改为每10秒执行一次，通过控制台打印的时间窗口可以看到已经生效了

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 7]  
**失效或终止**

![在这里插入图片描述][20201107122409458.png_pic_center]  
顾名思义，即将当前job停止运行，点击失效后，我们再次观察控制台，发现任务就不再执行了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 8]

关于任务的界面操作是比较简单的，大家可以尝试下，下面我们通过控制台来看看elastic-job的另一个功能，任务追踪

## 事件追踪 ##

> Elastic-Job提供了事件追踪功能，用于查询、统计和监控作业执行历史和执行状态。Elastic-Job-Lite在配置中提供了JobEventConfiguration，目前支持数据库方式配置。事件追踪所配置的DataSource数据库中会自动创建JOB\_EXECUTION\_LOG和JOB\_STATUS\_TRACE\_LOG两张表以及若干索引

简而言之，esJob在运行过程中的产生的相关数据会被记录到这两张表中去，方便开发人员快速定位job运行过程中的日志数据或问题等操作

**springboot集成事件追踪功能**

在上一篇的项目中，我们增加mysql的依赖和配置

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>

spring.datasource.username=root
    spring.datasource.password=root
    spring.datasource.url=jdbc:mysql://IP:3306/dataflow?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
    spring.datasource.driver-class-name=com.mysql.jdbc.Driver

然后再在JobScheduler的配置bean中，将JobEventConfiguration这个配置对象加入即可，以上篇的mySimpleJob为例，修改后的代码如下：

@Configuration
    public class MySimpleJobConfig {
    
        @Value("${mySimpleJob.cron}")
        private String cron;
    
        @Value("${mySimpleJob.shardingTotalCount}")
        private int shardingTotalCount;
    
        @Value("${mySimpleJob.shardingItemParameters}")
        private String shardingItemParameters;
    
        @Autowired
        private ZookeeperRegistryCenter regCenter;
    
        @Autowired
        private MySimpleJob mySimpleJob;
    
        @Autowired
        private DataSource dataSource;
    
        @Bean(initMethod = "init")
        public JobScheduler simpleJobScheduler() {
            JobEventConfiguration jcf = new JobEventRdbConfiguration(dataSource);
            return new SpringJobScheduler(mySimpleJob, regCenter,
                    ElasticJobUtils.getSimpleJobConfiguration(
                            mySimpleJob.getClass(),
                            cron,
                            shardingTotalCount,
                            shardingItemParameters),jcf
                    //,new MyElasticJobListener() 可配置监听器
            );
        }
    
    }

然后，启动项目，这时可以看到，在数据库中，就会在dataflow库下生成了两张表  
![在这里插入图片描述][20201107133610105.png_pic_center]  
同时，一旦任务开始运行，job运行过程中产生的数据就会记录到表中去，想必表中的字段信息大家一看便知，就不再过多解释了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 9]

这里想要说的是，可以通过elastic-job控制台将这些数据展示到界面上，更方便我们观察，怎么操作呢？

**点击左侧的数据源追踪配置，填写mysql的连接信息**

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 10]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 11]

这时我们再次启动后台项目，再到控制台中观察作业的历史操作和历史轨迹，可以发现job的执行信息都可以展示在控制台上了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 12]

**本篇主要讲述了如何部署elastic-job控制台，以及elastic-job控制台的基本使用，最后基于elastic-job的事件追踪功能，将产生的数据展示到控制台上方便运维和管理，本篇到此结束，最后感谢观看！**

[20201107110228551.png_pic_center]: /images/20221120/1e201a730f384ea3b181d0970a3a7fe7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/15a79c5ebd324221b37384e7b253f155.png
[20201107112000807.png_pic_center]: /images/20221120/a19544df921f4e8ca67feb4895a8267e.png
[20201107112025334.png_pic_center]: /images/20221120/13c706f1759143ba809815150b690b44.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/27062b942df74e07866591fd49e943b7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/1ca4f35fc7364ffb84e7e88c9cb3b4eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/3d83a9ba437e4640be062eb21972026a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221120/9665dd3898b641f4aa054b64368fd46a.png
[20201107113442455.png_pic_center]: /images/20221120/a67783e17544492385d9f1dfb7fed935.png
[20201107121305404.png_pic_center]: /images/20221120/fc7908cf74334384a9d9abc378c83681.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221120/b7a2f670cfe546edac8fb098204f840c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221120/b0971a33cfbd48f7a2bb12c510c2e831.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221120/d0b9f4c450b44710bb52bf46565e38eb.png
[20201107122409458.png_pic_center]: /images/20221120/9eaa71479bdf4b6297a5550698faa22b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20221120/c1e7e19f17904c8883745c5661a45986.png
[20201107133610105.png_pic_center]: /images/20221120/10a87a0e0e494cdeb2c6778d42d5bea5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 9]: /images/20221120/8b89c28cb6fb4519a28007bac8be844c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 10]: /images/20221120/75ab12d521434f4ea28ad9c6f9ae1e34.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 11]: /images/20221120/d0ff3aa27a7648669d54c0062a1bdccb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70_pic_center 12]: /images/20221120/33ede2b9401b4449863054724559eba8.png