第一章 - 分布式定时任务框架ElasticJob之JavaApi整合Simple作业

冷不防 2023-10-03 09:34 1阅读 0赞

#### 分布式定时任务框架ElasticJob之JavaApi整合Simple作业 ####

*  前言
 *  一、 开发环境准备
 *  二、使用步骤
 *   *  1.安装zookeeper
     *  2.创建maven工程，引入ElasticJob依赖
     *  3.编写代码
 *  总结

--------------------

## 前言 ##

分布式定时任务框架ElasticJob是当当网已经开源的框架，已经用于很多中大型企业用于分布式定时任务的场景开发之中，ElasticJob具有支持分布式、集群、弹性扩容等优点，它具有的这些特点在于它具有分片的功能，目前仅支持zookeeper注册中心。本章节介绍ElasticJob框架中最基本也是使用最广的一种作业类型SimpleJob整合JavaApi来实现基本的定时任务。

--------------------

## 一、 开发环境准备 ##

**1.Eclipse/IDEA**  
**2.zookeeper**  
**3.JDK1.8**  
**4.maven3.6.3**

## 二、使用步骤 ##

### 1.安装zookeeper ###

点击[下载zookeeper][zookeeper]进入下载页面，选择第一项下载  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70]  
下载完成后，解压到D盘根目录。进入config目录  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 1]  
将zoo\_sample.cfg文件复制一份重命名为zoo.cfg  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 2]  
单机版暂时不用过多的配置，然后进入bin目录下，双击zkServer.cmd运行zookeeper.  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 3]  
看到这样的效果就可以了  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 4]

### 2.创建maven工程，引入ElasticJob依赖 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 5]  
引入ElasticJob依赖，

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

### 3.编写代码 ###

在App.java中编写simpleJob作业配置方法：

public static LiteJobConfiguration configuration() {
        
    	
    	//第一步job核心配置
    	JobCoreConfiguration jcc = JobCoreConfiguration
    			.newBuilder("mySimpleJob", "0/2 * * * * ?", 2)
    			.build();
    	
    	//第二步job类型配置
    	JobTypeConfiguration jtc = new SimpleJobConfiguration(jcc, 
    			MySimpleJob.class.getCanonicalName());
    	
    	//第三步job根的配置
    	LiteJobConfiguration ljc = LiteJobConfiguration.newBuilder(
    			jtc
    					)
    			.overwrite(true)
    			.build();
    	return ljc;
    }

zookeeper注册中心：

public static CoordinatorRegistryCenter zkCenter() {
        
    	ZookeeperConfiguration zc = new ZookeeperConfiguration("localhost:2181"
    			, "java-simple-job");
    	
    	CoordinatorRegistryCenter crc = new ZookeeperRegistryCenter(zc);
    	//注册中心初始化
    	crc.init();
    	return crc;
    }

将作业注册到JobSchedule：

new JobScheduler(zkCenter(), configuration()).init();

simpleJob作业：

public class MySimpleJob implements SimpleJob{
        
    
    	@Override
    	public void execute(ShardingContext shardingContext) {
        
    		// TODO Auto-generated method stub
    		LocalTime localTime = LocalTime.now();
    		System.out.println(localTime+"我是分片项："+shardingContext.getShardingItem()+",总分片项："+shardingContext.getShardingTotalCount());
    	}
    
    }

--------------------

## 总结 ##

本章介绍了ElasticJob中最基本的作业SimpleJob的基本使用，下章节介绍流式作业DataflowJob的基本使用。

[zookeeper]: https://downloads.apache.org/zookeeper/current/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210629220754215.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210629220954592.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20210629221136561.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20210629221629233.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/2021062922171485.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20210629221955883.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMTg3NzAy,size_16,color_FFFFFF,t_70