SpringBoot 통합 ElaticJob 타이머 구현 코드

11889 단어 SpringBootElaticJob타이머
본 고 는 SpringBoot 통합 ElaticJob 타이머 의 실현 코드 를 소개 하고 여러분 에 게 공유 합 니 다.구체 적 으로 다음 과 같 습 니 다.
POM 파일 설정

<?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>com.example</groupId>
  <artifactId>demojob</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>demojob</name>
  <description>Demo project for Spring Boot</description>

  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.2.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>
  </properties>

  <dependencies>

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>


    <!--elastic-job-->
    <dependency>
      <artifactId>elastic-job-common-core</artifactId>
      <groupId>com.dangdang</groupId>
      <version>2.1.5</version>
    </dependency>
    <dependency>
      <artifactId>elastic-job-lite-core</artifactId>
      <groupId>com.dangdang</groupId>
      <version>2.1.5</version>
    </dependency>
    <dependency>
      <artifactId>elastic-job-lite-spring</artifactId>
      <groupId>com.dangdang</groupId>
      <version>2.1.5</version>
    </dependency>
    <dependency>
      <artifactId>elastic-job-cloud-executor</artifactId>
      <groupId>com.dangdang</groupId>
      <version>2.1.5</version>
    </dependency>


    <!--mariadb-->
    <dependency>
      <groupId>org.mariadb.jdbc</groupId>
      <artifactId>mariadb-java-client</artifactId>
      <version>1.5.4</version>
    </dependency>
    <!--druid-->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>druid-spring-boot-starter</artifactId>
      <version>1.1.9</version>
    </dependency>
    <!--mybatis plus-->
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatisplus-spring-boot-starter</artifactId>
      <version>1.0.5</version>
    </dependency>
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus</artifactId>
      <version>2.1.9</version>
    </dependency>


  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>
</project>
Yml 파일 설정(application.properties 와 같은 것 도 사용 할 수 있 습 니 다)

#        
spring:
 datasource:
  type: com.alibaba.druid.pool.DruidDataSource
  driver-class-name: org.mariadb.jdbc.Driver
  name: elastic-job-event
  url: jdbc:mariadb://127.0.0.1:3306/elasticjob
  username: root
  password: 123456
  druid:
   validationQuery: SELECT 1
   initialSize: 10
   minIdle: 10
   maxActive: 200
   minEvictableIdleTimeMillis: 180000
   testOnBorrow: false
   testWhileIdle: true
   removeAbandoned: true
   removeAbandonedTimeout: 1800
   logAbandoned: true
   poolPreparedStatements: true
   maxOpenPreparedStatements: 100

#   Zookeeper
regCenter:
 serverList: localhost:2181
 namespace: hulk_order_task

#        
simpleJob:
 cron: 0/5 * * * * ?
 shardingTotalCount: 1
 shardingItemParameters: 0=1
코드 쓰기 시작
RegistryCenterConfig

package com.example.demojob.config;

import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 *       
 *                  ，     Zookeeper。
 * @author shudalei
 */
@Configuration
@ConditionalOnExpression("'${regCenter.serverList}'.length() > 0")
public class RegistryCenterConfig {
  @Bean(initMethod = "init")
  public ZookeeperRegistryCenter regCenter(@Value("${regCenter.serverList}") final String serverList,
                       @Value("${regCenter.namespace}") final String namespace) {
    return new ZookeeperRegistryCenter(new ZookeeperConfiguration(serverList, namespace));
  }
}
JobEventConfig

package com.example.demojob.config;

import com.dangdang.ddframe.job.event.JobEventConfiguration;
import com.dangdang.ddframe.job.event.rdb.JobEventRdbConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;
import javax.sql.DataSource;

/**
 *              DB ，            ，
 *        JobEventConfiguration，
 *                 JobEventRdbConfiguration，
 *                     DB   。
 * @author shudalei
 */
@Configuration
public class JobEventConfig {
  @Resource
  private DataSource dataSource;

  @Bean
  public JobEventConfiguration jobEventConfiguration() {
    return new JobEventRdbConfiguration(dataSource);
  }
}
SimpleJobConfig

package com.example.demojob.config;

import com.dangdang.ddframe.job.config.JobCoreConfiguration;
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
import com.dangdang.ddframe.job.event.JobEventConfiguration;
import com.dangdang.ddframe.job.lite.api.JobScheduler;
import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
import com.dangdang.ddframe.job.lite.spring.api.SpringJobScheduler;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import com.example.demojob.job.TestSimpleJob;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;

@Configuration
public class SimpleJobConfig {

  /**
   *     
   */
  @Resource
  private ZookeeperRegistryCenter regCenter;
  /**
   * job    
   */
  @Resource
  private JobEventConfiguration jobEventConfiguration;

  /**
   *   access token      
   *
   */
  @Resource
  private TestSimpleJob simpleJob;

  /**
   *
   * @param cron     cron  
   * @param shardingTotalCount      
   * @param shardingItemParameters       
   * @return JobScheduler      
   */
  @Bean(initMethod = "init")
  public JobScheduler simpleJobScheduler(@Value("${simpleJob.cron}") final String cron,
                      @Value("${simpleJob.shardingTotalCount}") final int shardingTotalCount,
                      @Value("${simpleJob.shardingItemParameters}") final String shardingItemParameters) {
    return new SpringJobScheduler(simpleJob, regCenter,
        getLiteJobConfiguration(simpleJob.getClass(), cron, shardingTotalCount, shardingItemParameters),
        jobEventConfiguration);
  }

  /**
   *
   * @param jobClass      
   * @param cron     cron  
   * @param shardingTotalCount      
   * @param shardingItemParameters       
   * @return LiteJobConfiguration     
   */
  private LiteJobConfiguration getLiteJobConfiguration(final Class<? extends com.dangdang.ddframe.job.api.simple.SimpleJob> jobClass, final String cron,
                             final int shardingTotalCount, final String shardingItemParameters) {
    return LiteJobConfiguration
        .newBuilder(
            new SimpleJobConfiguration(JobCoreConfiguration.newBuilder(jobClass.getName(), cron, shardingTotalCount)
                .shardingItemParameters(shardingItemParameters).build(), jobClass.getCanonicalName()))
        .overwrite(true).build();
  }
}
TestSimple Job,타이머 작업 자체

package com.example.demojob.job;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import org.springframework.stereotype.Component;

@Component
public class TestSimpleJob implements SimpleJob {

  private int count;
  //     5          1，2，3……
  @Override
  public void execute(ShardingContext shardingContext) {
    count++;
    System.out.println("task " + count);
  }
}
마지막 으로 Docker 밑 에 Zookeeper 를 설치 합 니 다.
스 크 립 트 compose 파일 설치 하기

version: '2'
services:
 zookeeper01:
  image: zookeeper
  restart: always
  hostname: zookeeper01
  ports:
   - 2181:2181
  environment:
   ZOO_MY_ID: 1
   ZOO_SERVERS: server.1=0.0.0.0:2888:3888 server.2=zookeeper02:2888:3888 server.3=zookeeper03:2888:3888
 zookeeper02:
  image: zookeeper
  restart: always
  hostname: zookeeper02
  ports:
   - 2182:2181
  environment:
   ZOO_MY_ID: 2
   ZOO_SERVERS: server.1=zookeeper01:2888:3888 server.2=0.0.0.0:2888:3888 server.3=zookeeper03:2888:3888
 zookeeper03:
  image: zookeeper
  restart: always
  hostname: zookeeper03
  ports:
   - 2183:2181
  environment:
   ZOO_MY_ID: 3
   ZOO_SERVERS: server.1=zookeeper01:2888:3888 server.2=zookeeper02:2888:3888 server.3=0.0.0.0:2888:3888
이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.
SpringBoot+SpringSecurity 문자 인증 코드 로그 인 기능 구현
Python input 함수 인 스 턴 스 분석 사용

좋은 웹페이지 즐겨찾기

개발자 우수 사이트 수집

개발자가 알아야 할 필수 사이트 100선 추천 우리는 당신을 위해 100개의 자주 사용하는 개발자 학습 사이트를 정리했습니다
best100-homepage