在做这个例子之前先安装好数据库，Zookeeper等软件，这里例子部署3个job执行。
一，使用SPRING INITIALIZR https://start.spring.io/ 生成项目，然后添加Elastic-job-lite相关依赖。pom如下：
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.4.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<elastic-job.version>2.1.5</elastic-job.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.mariadb.jdbc</groupId>
<artifactId>mariadb-java-client</artifactId>
<version>2.2.6</version>
</dependency>
<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
<version>3.2.0</version>
</dependency>
<dependency>
<groupId>com.dangdang</groupId>
<artifactId>elastic-job-lite-core</artifactId>
<version>${elastic-job.version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.dangdang/elastic-job-lite-spring -->
<dependency>
<groupId>com.dangdang</groupId>
<artifactId>elastic-job-lite-spring</artifactId>
<version>${elastic-job.version}</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.2</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
二，写job
@Slf4j
public class MyElasticJob implements SimpleJob {
@Override
public void execute(ShardingContext context) {
switch (context.getShardingItem()) {
case 0:
// do something by sharding item 0
log.info("" + context.getShardingItem() + "," + context.getShardingTotalCount() + "," + context.getShardingParameter());
break;
case 1:
// do something by sharding item 1
log.info("" + context.getShardingItem() + "," + context.getShardingTotalCount() + "," + context.getShardingParameter());
break;
case 2:
// do something by sharding item 2
log.info("" + context.getShardingItem() + "," + context.getShardingTotalCount() + "," + context.getShardingParameter());
break;
// case n: ...
}
}
}
自定义异常处理类
/**
* 自定义异常处理
* @author
*/
public class CustomJobExceptionHandler implements JobExceptionHandler {
private Logger logger = LoggerFactory.getLogger(CustomJobExceptionHandler.class);
@Override
public void handleException(String jobName, Throwable cause) {
logger.error(String.format("Job '%s' exception occur in job processing", jobName), cause);
//这里自定义异常处理逻辑
}
}
三，创建数据库
CREATE DATABASE IF NOT EXISTS `batch_log`
四，配置job.xml文件
<?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
">
<!--configure registry center -->
<reg:zookeeper id="regCenter" server-lists="localhost:2181" namespace="dd-job" base-sleep-time-milliseconds="1000" max-sleep-time-milliseconds="3000" max-retries="3" />
<bean id="elasticJobLog" class="com.zaxxer.hikari.HikariDataSource" destroy-method="close">
<property name="driverClassName" value="org.mariadb.jdbc.Driver"/>
<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/batch_log"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
</bean>
<!--configure job -->
<job:simple id="myElasticJob" class="com.vcredit.elasticjobdemo.job.MyElasticJob"
registry-center-ref="regCenter"
cron="0/59 * * * * ?"
sharding-total-count="3"
sharding-item-parameters="0=上海,1=北京,2=深圳"
description="我的第一个简单作业"
overwrite="true"
event-trace-rdb-data-source="elasticJobLog"
job-exception-handler="com.vcredit.elasticjobdemo.job.CustomJobExceptionHandler"/>
</beans>
五，在启动类上引入配置文件
@ImportResource(value = {"classpath:job.xml"})
@SpringBootApplication
public class ElasticJobDemoApplication {
public static void main(String[] args) {
SpringApplication.run(ElasticJobDemoApplication.class, args);
}
}
六，配置yml文件
spring:
profiles:
active: peer1
---
spring:
profiles: peer1
server:
port: 8080
---
spring:
profiles: peer2
server:
port: 8081
---
spring:
profiles: peer3
server:
port: 8082
七，启动程序
java -jar elastic-job-lite-demo-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer1
java -jar elastic-job-lite-demo-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer2
java -jar elastic-job-lite-demo-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer3
八，这一步使用elastic-job-lite-console以图形化的方式查看job。
首先到https://gitee.com/elasticjob/elastic-job下载源码，然后打包elastic-job-lite-console，到target目录，可以看到生成了压缩文件，拷贝压缩文件，解压缩，执行bin目录里面的start.bat或者start.sh，账号配置在conf目录下的auth.properties中，默认管理员账号密码都是root。
首先在全局配置>注册中心配置页面添加zookeeper配置，配置好之后点击右边连接按钮。
elastic-job-lite-console.png
然后在全局配置>事件追踪数据源配置页面添加数据库配置，配置好之后点击右边连接按钮。
1535026235(1).png
然后在作业操作>作业维度就可以看到你的job配置信息。点击修改按钮可以修改job配置。
1535026491(1).png
1535026594(1).png
在作业历史>历史轨迹中可以查看作业执行情况。
网友评论