elastic-job搭建

可以直接码云下载 源码及示例

https://gitee.com/elasticjob/elastic-job

1.其中，使用普通jar包，且项目中有example，直接可以使用；笔者公司采用该方式，简单暴力；

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

2.使用springboot 漂亮的-start 方式。可从更简洁使用elasticjob

搭建

1.引入pom

com.github.kuhn-he elastic-job-lite-spring-boot-starter 2.1.5

2.application.properties 配置

elaticjob.zookeeper.server-lists=127.0.0.1:2181

elaticjob.zookeeper.namespace=jobzknamespace

3.编写代码

package com.elatic.demo.demo.aa;

import com.dangdang.ddframe.job.api.ShardingContext;

import com.dangdang.ddframe.job.api.simple.SimpleJob;

import com.dangdang.elasticjob.lite.annotation.ElasticSimpleJob;

import org.springframework.stereotype.Component;

import javax.annotation.Resource;

import java.text.SimpleDateFormat;

import java.util.Date;

@ElasticSimpleJob("* * * * * ?")

@Component

public class TestJob implements SimpleJob {

    @Override

    public void execute(final ShardingContext shardingContext) {

        System.out.println(String.format("Item: %s | Time: %s | Thread: %s | %s",

                shardingContext.getShardingItem(), new SimpleDateFormat("HH:mm:ss").format(new Date()), Thread.currentThread().getId(), "SIMPLE"));

        System.out.println("the job is working .... ");

    }

}

4.外部依赖zk

下载    官网地址 http://zookeeper.apache.org/

  解压

修改配置文件conf 下的zoo_sample.cfg 改为zoo.cfg

启动 zkserver.cmd

5,启动springboot  控制台打印日志；

6.使用运维平台

elastic-job 下 elastic-job-lite下的 console mvn：install

[INFO] Building tar : G:\mySpace\opensource\elastic-job\elastic-job-lite\elastic-job-lite-console\target\elastic-job-lite-console-2.1.4.tar.gz

获取tar包；

解压tar包；

运行 bin\start.bat。打开浏览器访问http://127.0.0.1:8899/即可访问控制台。8899为默认端口号，可通过启动脚本输入-p自定义端口号。密码 root root

账号密码在 console 项目的resource/conf/auth.properties中配置