Elastic Job 入门教程（三）— 作业监听

男娘i 2022-05-10 02:18 472阅读 0赞

接上一篇：[Elastic Job 入门教程（二）— Spring Boot框架下是实现Elastic Job 脚本作业（Script Job）][Elastic Job _ Spring Boot_Elastic Job _Script Job]，本章我们讨论作业Job的监听。

**定义监听器**

@Component
    @Slf4j
    public class CommonElasticJobListener implements ElasticJobListener {
        @Override
        public void beforeJobExecuted(ShardingContexts shardingContexts) {
            log.info("beforeJob {}", shardingContexts);
        }
    
        @Override
        public void afterJobExecuted(ShardingContexts shardingContexts) {
            log.info("afterJob {}", shardingContexts);
        }
    }

**使用监听器，定义作业时，将监听器作为参数传入**

@Component
    public class ElasticScriptJob {
        @Autowired
        private ZookeeperRegistryCenter regCenter;
    
        @Autowired
        private LiteJobConfiguration scriptLiteJobConfiguration;
    
        @Autowired
        private CommonElasticJobListener commonElasticJobListener;
    
        @Bean(initMethod = "init")
        public JobScheduler scriptJob() {
            return new JobScheduler(regCenter, scriptLiteJobConfiguration, commonElasticJobListener);
        }
    }

**执行结果**

2018-09-24 20:53:00.044  INFO 8256 --- [onitor_Worker-1] c.cib.listener.CommonElasticJobListener  : beforeJob ShardingContexts(taskId=cn.cib.job.ServiceMonitor@-@0,1@-@READY@-@192.168.227.1@-@8256, jobName=cn.cib.job.ServiceMonitor, shardingTotalCount=2, jobParameter=hello elastic simple job, shardingItemParameters={0=CIB, 1=ICBC}, jobEventSamplingCount=0, currentJobEventSamplingCount=0, allowSendJobEvent=true)
    2018-09-24 20:53:00.046  INFO 8256 --- [b name_Worker-1] c.cib.listener.CommonElasticJobListener  : beforeJob ShardingContexts(taskId=elastic script job name@-@0,1@-@READY@-@192.168.227.1@-@8256, jobName=elastic script job name, shardingTotalCount=2, jobParameter=hello elastic script job, shardingItemParameters={0=CIB, 1=ICBC}, jobEventSamplingCount=0, currentJobEventSamplingCount=0, allowSendJobEvent=true)
    2018-09-24 20:53:00.069  INFO 8256 --- [erviceMonitor-3] cn.cib.job.ServiceMonitor                : sharding context is ShardingContext(jobName=cn.cib.job.ServiceMonitor, taskId=cn.cib.job.ServiceMonitor@-@0,1@-@READY@-@192.168.227.1@-@8256, shardingTotalCount=2, jobParameter=hello elastic simple job, shardingItem=0, shardingParameter=CIB)
    2018-09-24 20:53:00.070  INFO 8256 --- [erviceMonitor-4] cn.cib.job.ServiceMonitor                : sharding context is ShardingContext(jobName=cn.cib.job.ServiceMonitor, taskId=cn.cib.job.ServiceMonitor@-@0,1@-@READY@-@192.168.227.1@-@8256, shardingTotalCount=2, jobParameter=hello elastic simple job, shardingItem=1, shardingParameter=ICBC)
    2018-09-24 20:53:00.099  INFO 8256 --- [onitor_Worker-1] c.cib.listener.CommonElasticJobListener  : afterJob ShardingContexts(taskId=cn.cib.job.ServiceMonitor@-@0,1@-@READY@-@192.168.227.1@-@8256, jobName=cn.cib.job.ServiceMonitor, shardingTotalCount=2, jobParameter=hello elastic simple job, shardingItemParameters={0=CIB, 1=ICBC}, jobEventSamplingCount=0, currentJobEventSamplingCount=0, allowSendJobEvent=true)
    2018-09-24 20:53:00.224  INFO 8256 --- [b name_Worker-1] c.cib.listener.CommonElasticJobListener  : afterJob ShardingContexts(taskId=elastic script job name@-@0,1@-@READY@-@192.168.227.1@-@8256, jobName=elastic script job name, shardingTotalCount=2, jobParameter=hello elastic script job, shardingItemParameters={0=CIB, 1=ICBC}, jobEventSamplingCount=0, currentJobEventSamplingCount=0, allowSendJobEvent=true)

> 注：若分布式场景中仅需要执行单一节点执行的监听，此类型业务场景较为复杂，你可以通过继承AbstractDistributeOnceElasticJobListener ，通过超时设置来完成作业间的同步，更多请参考：[http://elasticjob.io/docs/elastic-job-lite/02-guide/job-listener/][http_elasticjob.io_docs_elastic-job-lite_02-guide_job-listener]

更多源码请参考：

[https://github.com/ypmc/spring-cloud/tree/master/spring-elastic-job][https_github.com_ypmc_spring-cloud_tree_master_spring-elastic-job]

[Elastic Job _ Spring Boot_Elastic Job _Script Job]: https://blog.csdn.net/kangkanglou/article/details/82822213
[http_elasticjob.io_docs_elastic-job-lite_02-guide_job-listener]: http://elasticjob.io/docs/elastic-job-lite/02-guide/job-listener/
[https_github.com_ypmc_spring-cloud_tree_master_spring-elastic-job]: https://github.com/ypmc/spring-cloud/tree/master/spring-elastic-job