Java微服務分布式調度Elastic-job環(huán)境搭建及配置

更新時間：2023年02月09日 16:59:33 作者：楊宸楊

Elastic-Job在配置中提供了JobEventConfiguration，支持數(shù)據(jù)庫方式配置，會在數(shù)據(jù)庫中自動創(chuàng)建JOB_EXECUTION_LOG和JOB_STATUS_TRACE_LOG兩張表以及若干索引，來記錄作業(yè)的相關信息

什么是任務調度

任務調度是為了自動完成特定任務，在約定的特定時刻去執(zhí)行人物的過程

為什么需要分布式調度

1.使用Spring定時器，在集群的情況下，可能會導致任務重復執(zhí)行的情況，當我們部署了多臺服務，同時每臺服務又有定時任務時，若不進行合理的控制在同一時間，只有一個定時任務啟動執(zhí)行了，這時，定時執(zhí)行的結果就可能存在混亂和錯誤了，考慮使用分布式鎖，保證任務不會重復執(zhí)行

2.大大提高了可用性，當做了集群之后，某個項目掛了，任務應該要由另外一個項目繼續(xù)進行

3.單機處理始終有極限，假設該主服務器有ABCD四個任務，可以將任務分配給自己底下的從服務器，將它們調動起來一起來完成任務

Elastic-Job

zookeeper是一個注冊中心，在Elastic-job過程中進行一個選舉的功能，以及對節(jié)點的監(jiān)聽，誰被選舉成leader誰才可以執(zhí)行任務，一旦leader掛了，將會進行重新的選舉，依賴zookeeper里面的信息

環(huán)境搭建

第一步：Zookeeper安裝并運行

1)解壓zookeeper-3.4.11.tar.進入conf目錄，復制zoo_sample.cfg文件，命名為zoo.cfg

2)進入bin目錄，運行zkServer.cmd就可以了

3)解壓ZooInspector運行文件

第二步：創(chuàng)建maven項目添加如下依賴

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

第三步：創(chuàng)建任務類

public class MyElasticJob implements SimpleJob {
    public void execute(ShardingContext shardingContext){
        System.out.println("執(zhí)行任務"+new Date());
    }
}

第四步：創(chuàng)建配置類

public class JobDemo {
    public static void main(String[] args) {
        //JobScheduler(注冊中心對象，任務配置對象)
        new JobScheduler(createRegistryCenter(),createJobConfiguration()).init();
    }
    //定時任務配置
    private static LiteJobConfiguration createJobConfiguration() {
        //定義作業(yè)核心配置newBuilder("任務名稱","corn表達式","分片數(shù)量")
        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder("myElasticJob","0/5 * * * * ?",1).build();
        // 定義SIMPLE類型配置 cn.wolfcode.MyElasticJob
        System.out.println("MyElasticJob.class.getCanonicalName---->"+ MyElasticJob.class.getCanonicalName());
        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig,MyElasticJob.class.getCanonicalName());
        //定義Lite作業(yè)根配置
        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
        return simpleJobRootConfig;
    }
    //注冊中心配置
    private static CoordinatorRegistryCenter createRegistryCenter() {
        ZookeeperConfiguration zookeeperConfiguration = new ZookeeperConfiguration("43.143.161.59:2181", "elastic-job-demo");
        //設置節(jié)點超時時間
        zookeeperConfiguration.setSessionTimeoutMilliseconds(100);
        //zookeeperConfiguration("zookeeper地址","項目名")
        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(zookeeperConfiguration);
        regCenter.init();
        return regCenter;
    }
}

運行結果：

啟動多臺機器的時候，只有一臺機器運行

當leader終止后，再次進行選取執(zhí)行任務

更改Zookeeper配置

雖然自己想每十秒執(zhí)行一次，但運行結果

原因是zookeeper里面不允許覆蓋里面配置的，要是想覆蓋，就要

否則zookeeper還是讀取里面的配置

SpringBoot集成ElasticJob

第一步:添加Maven依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>cn.wolfcode</groupId>
  <artifactId>elstaic-job-boot</artifactId>
  <version>1.0.0</version>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.3.RELEASE</version>
  </parent>
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
  </properties>
  <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
      <groupId>com.dangdang</groupId>
      <artifactId>elastic-job-lite-spring</artifactId>
      <version>2.1.5</version>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
    </dependency>
  </dependencies>
</project>

第二步：創(chuàng)建啟動類

@SpringBootApplication
public class ElasticJobServer {
    public static void main(String[] args) {
        SpringApplication.run(ElasticJobServer.class,args);
    }
}

第三步：創(chuàng)建任務類

@Component
public class MyElasticJob implements SimpleJob {
    @Override
    public void execute(ShardingContext shardingContext) {
        System.out.println("定時調度:"+new Date());
    }
}

第四步：創(chuàng)建任務配置類

@Configuration
public class JobConfig {
    @Bean
    public static CoordinatorRegistryCenter registryCenter(@Value("${zookeeper.url}") String url,@Value("${zookeeper.groupName}") String groupName) {
        ZookeeperConfiguration zookeeperConfiguration = new ZookeeperConfiguration(url, groupName);
        //設置節(jié)點超時時間
        zookeeperConfiguration.setSessionTimeoutMilliseconds(100);
        //zookeeperConfiguration("zookeeper地址","項目名")
        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(zookeeperConfiguration);
        regCenter.init();
        return regCenter;
    }
    //功能的方法
    public static LiteJobConfiguration createJobConfiguration(Class clazz,String corn,int shardingCount) {
        //定義作業(yè)核心配置newBuilder("任務名稱","corn表達式","分片數(shù)量")
        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(clazz.getSimpleName(),corn,shardingCount).build();
        // 定義SIMPLE類型配置 cn.wolfcode.MyElasticJob
        System.out.println("MyElasticJob.class.getCanonicalName---->"+ MyElasticJob.class.getCanonicalName());
        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig,clazz.getCanonicalName());
        //定義Lite作業(yè)根配置
        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
        return simpleJobRootConfig;
    }
    @Bean(initMethod = "init")
    public SpringJobScheduler testScheduler(MyElasticJob job,CoordinatorRegistryCenter registryCenter){
        LiteJobConfiguration jobConfiguration = createJobConfiguration(job.getClass(),"0/5 * * * * ?",1);
        return new SpringJobScheduler(job,registryCenter,jobConfiguration);
    }
}

第五步：配置文件

zookeeper:
url: 43.143.161.59:2181
groupName: elastic-job-boot

到此這篇關于Java微服務分布式調度Elastic-job環(huán)境搭建及配置的文章就介紹到這了,更多相關Java Elastic-job內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

java 中HashMap實現(xiàn)原理深入理解
這篇文章主要介紹了java 中HashMap實現(xiàn)原理深入理解的相關資料,需要的朋友可以參考下
2017-03-03
java外部類與內部類的關系詳解
本文詳細講解了java外部類與內部類的關系，用代碼演示了外部類調用內部類的方法。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
2021-12-12
Java的字符串常量池StringTable詳解
這篇文章主要介紹了Java的字符串常量池StringTable詳解,JVM為了提高性能和減少內存開銷,在實例化字符串常量的時候進行了一些優(yōu)化,為了減少在JVM中創(chuàng)建的字符串的數(shù)量,字符串類維護了一個字符串池,需要的朋友可以參考下
2023-11-11
Java中HashMap集合的常用方法詳解
本篇文章給大家?guī)淼膬热菔顷P于Java中HashMap集合的常用方法詳解，有一定的參考價值，有需要的朋友可以參考一下，希望對你有所幫助。下面我們就來學習一下吧
2021-11-11
springboot+dynamicDataSource動態(tài)添加切換數(shù)據(jù)源方式
這篇文章主要介紹了springboot+dynamicDataSource動態(tài)添加切換數(shù)據(jù)源方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2022-01-01
SpringBoot多模塊如何統(tǒng)一管理
本文詳細介紹了SpringBoot多模塊項目的統(tǒng)一管理方法,包括核心思想、Maven和Gradle的統(tǒng)一管理實踐以及最佳實踐和技巧,通過集中化配置、約定優(yōu)于配置、減少重復性工作,可以提高多模塊項目的可維護性、一致性和可擴展性
2025-03-03
Lombok注解-@SneakyThrows的使用
這篇文章主要介紹了Lombok注解-@SneakyThrows的使用，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2022-08-08
SpringBoot 中使用JSP的方法示例
本篇文章主要介紹了SpringBoot 中使用JSP的方法示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2018-06-06
一文詳解gRPC快速整合SpringCloud
這篇文章主要為大家介紹gRPC快速整合SpringCloud的實現(xiàn)示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2023-03-03
JAVA基于靜態(tài)數(shù)組實現(xiàn)棧的基本原理與用法詳解
這篇文章主要介紹了JAVA基于靜態(tài)數(shù)組實現(xiàn)棧的基本原理與用法,結合實例形式詳細分析了JAVA基于靜態(tài)數(shù)組實現(xiàn)棧相關原理、用法與操作注意事項,需要的朋友可以參考下
2020-03-03