ElasticJob之创建Job与配置Job

妖狐艹你老母 2021-09-29 00:18 809阅读 0赞

Elastic-Job是一个分布式调度相关的项目，由Elastic-Job-Lite和Elastic-Job-Cloud两个相互独立的子项目组成。

Elastic-Job-Lite可通过使用jar包的形式提供分布式任务的协调服务。  
下面就来记录并分享下从任务的创建到通过ElasticJob管理任务的相关流程：  
一、项目实现  
1、在mvn配置文件pom.xml添加依赖

<dependency>
    	<groupId>io.elasticjob</groupId>
    	<artifactId>elastic-job-lite-core</artifactId>
    	<version>${lasted.release.version}</version>
    <dependency>
    <dependency>
    	<groupId>io.elasticjob</groupId>
    	<artifactId>elastic-job-lite-spring</artifactId>
    	<version>${lasted.release.version }</version>
    </dependency>

2、新建一个类，需要继承SimpleJob类，实现execute方法

/**
    * author:wangxueying
    */
    public class TestElasticJob implements SimpleJob {
    	@Override
    	public void execute(ShardingContext context) {
    		switch(context.getShardingItem()) {
    			case 0:
    				//处理
    				break;
    			case 1:
    				//处理
    				break;
    		}
    	}
    }

3、要记得给自己写的类加个配置文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:reg="http://www.dangdang.com/schema/ddframe/reg"
        xmlns:job="http://www.dangdang.com/schema/ddframe/job"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
                            http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.dangdang.com/schema/ddframe/reg
                            http://www.dangdang.com/schema/ddframe/reg/reg.xsd
                            http://www.dangdang.com/schema/ddframe/job
                            http://www.dangdang.com/schema/ddframe/job/job.xsd
                            ">
        
        <reg:zookeeper id="regCenter" server-lists="localhost:2181" namespace="dd-job" base-sleep-time-milliseconds="1000" max-sleep-time-milliseconds="3000" max-retries="3" />
    
        
        <job:simple id="testElasticJob" class="com.test.TestElasticJob" registry-center-ref="regCenter" cron="0/10 * * * * ?"   sharding-total-count="3" sharding-item-parameters="0=A,1=B" />
    </beans>

二、下面就开始操作ElasticJob了。  
1、解压缩elastic-job-lite-console-$\{version\}.tar.gz(也可通过mvn install编译获取)并执行bin\\[start.sh][]  
2、8899为默认端口号，可通过-p自定义端口号，通过访问以下地址，来登陆elasticjob管理页面，有管理员和访客两种用户，管理员拥有全部操作权限，访客仅拥有查看权限。默认管理员用户名和密码是root/root，访客用户名和密码是guest/guest，可通过conf\\auth.properties修改用户名及密码：

http://localhost:8899

3、在Global setting下Registry center页面，点击添加按钮，namespace与上面配置文件内配的要一致呦，其它项具实际填写即可：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDAzMDYz_size_16_color_FFFFFF_t_70]  
4、添加完毕之后，到Job operation页面，就会将你在配置文件内配的定时任务显示出来。  
控制台智能控制作业本身是否运行，不能控制作业进程的启动，因为控制台和作业本身服务器是完全分离的，控制台并不能控制作业服务器。

[start.sh]: http://start.sh
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDAzMDYz_size_16_color_FFFFFF_t_70]: /images/20210923/f639476bbf1e4b87ade0333c6f0477ae.png