Elastic-Job配置步骤

配置手册：

http://elasticjob.io/docs/elastic-job-lite/02-guide/config-manual/

1、ZK注册中心配置（后面继续分析）

2、作业配置（从底层往上层：Core——Type——Lite）

配置级别	配置类	配置内容
Core	JobCoreConfiguration	用于提供作业核心配置信息，如：作业名称、CRON 表达式、分片总数等。
Type	JobTypeConfiguration	有3 个子类分别对应SIMPLE, DATAFLOW 和SCRIPT 类型作业，提供3 种作业需要的不同配置，如：DATAFLOW 类型是否流式处理或SCRIPT 类型的命令行等。Simple 和DataFlow 需要指定任务类的路径。
Root	JobRootConfiguration	有2 个子类分别对应Lite 和Cloud 部署类型，提供不同部署类型所需的配置，如：Lite 类型的是否需要覆盖本地配置或Cloud 占用CPU 或Memory 数量等。可以定义分片策略。 http://elasticjob.io/docs/elastic-job-lite/02-guide/job-sharding-strategy/

public class SimpleJobTest {// TODO 如果修改了代码，跑之前清空ZKpublic static void main(String[] args) {// ZK注册中心CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("localhost:2181", "ejob-standalone"));regCenter.init();// 数据源，使用DBCP
/*        BasicDataSource dataSource = new BasicDataSource();dataSource.setDriverClassName("com.mysql.jdbc.Driver");dataSource.setUrl("jdbc:mysql://localhost:3306/elastic_job_log");dataSource.setUsername("root");dataSource.setPassword("123456");JobEventConfiguration jobEventConfig = new JobEventRdbConfiguration(dataSource);*/// 定义作业核心配置// TODO 如果修改了代码，跑之前清空ZKJobCoreConfiguration coreConfig = JobCoreConfiguration.newBuilder("MySimpleJob", "0/2 * * * * ?", 4).shardingItemParameters("0=RDP, 1=CORE, 2=SIMS, 3=ECIF").failover(true).build();// 定义SIMPLE类型配置SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(coreConfig, MySimpleJob.class.getCanonicalName());// 作业分片策略// 基于平均分配算法的分片策略String jobShardingStrategyClass = AverageAllocationJobShardingStrategy.class.getCanonicalName();// 定义Lite作业根配置// LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).jobShardingStrategyClass(jobShardingStrategyClass).build();LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();// 构建Jobnew JobScheduler(regCenter, simpleJobRootConfig).init();// new JobScheduler(regCenter, simpleJobRootConfig, jobEventConfig).init();}}

作业配置分为 3级，分别是 JobCoreConfiguration，JobTypeConfiguration和LiteJobConfiguration。 LiteJobConfiguration使用 JobTypeConfiguration，JobTypeConfiguration使用 Job CoreConfiguration，层层嵌套。

JobTypeConfiguration根据不同实现类型分为 SimpleJobConfiguration，DataflowJobConfiguration和ScriptJobConfiguration。

E-Job使用 ZK来做分布式协调，所有的配置都会写入到 ZK节点。

Elastic-Job配置步骤相关推荐

Linux下mysql支持中文,linux下mysql环境支持中文配置步骤
sql脚本执行前加上: CREATE DATABASE IF NOT EXISTS mydatabase DEFAULT CHARSET utf8 COLLATE UTF8_GENERAL_CI; u ...
Fortinet网络接入及安全方案配置步骤
http://sec.chinabyte.com/200/12553700.shtml 1.概述: Fortinet无线接入及方案由以下两类设备组成: AC(Wifi接入控制器)及安全网关:Forti ...
系统如何安装到租的服务器,租用服务器后，检查及环境配置步骤
原标题:租用服务器后,检查及环境配置步骤我们从IDC服务商那里拿到我们租的服务器时,一般的服务商都会根据客户的要求,装好系统,那么我们要做的是什么呢? 第一.检查服务器的配置与我们订购的机器配置是否 ...
linux redis数据库安装配置,Linux系统中redis的安装配置步骤
Linux系统中redis的安装配置步骤发布时间:2020-06-23 10:13:36 来源:亿速云阅读:87 作者:Leah 这篇文章将为大家详细讲解有关Linux系统中redis的安装配置步 ...
log4j.properties 详解与配置步骤总结
先提供一个项目中使用log4j.properties配置 #log4j.rootLogger=WARN, stdout, file log4j.rootLogger=INFO,console,dail ...
Cisco设备静态NAT基本配置步骤
以下内容摘自笔者即将出版上市的<金牌网管师--大中型企业网络组建.配置与管理>一书,或者于明年将出版的<Cisco/H3C路由器配置与管理完全手册>一书. 当你与外部网络进行通 ...
apache虚拟机配置步骤和修改访问端口
这篇文章主要介绍了apache虚拟机配置步骤和修改访问端口的方法(虚拟机端口映射),需要的朋友可以参考下一.添加服务端口在文件Apache\conf\httpd.conf中, 1.找到 Liste ...
spring中基于XML的AOP配置步骤
spring中基于XML的AOP配置步骤 IAccountService.java package com.itheima.service;/*** 账户的业务层接口*/ public interfa ...
[SAP PI]ECC系统接收财务凭证IDoc的配置步骤(总账应收应付)
1. 业务场景外围系统,通过IDoc,在SAP系统中创建财务凭证,包括总账,应收和应付. 功能 IDoc 增强财务总账接口 ACC_GL_POSTING. ACC_GL_POSTING ...
mysql主主同步配置_MySQL 主主同步配置步骤
MySQL 主主同步配置服务器名 IP 系统 MySQL odd.example.com 192.168.1.116 rhel-5.8 5.5.16 even.example.com 192.168 ...

Elastic-Job配置步骤

Elastic-Job配置步骤相关推荐

最新文章

热门文章