如何在SpringBoot中使用ElaticJob定时器

如何在SpringBoot中使用ElaticJob定时器？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。

成都创新互联公司专注于鄂尔多斯网站建设服务及定制，我们拥有丰富的企业做网站经验。 热诚为您提供鄂尔多斯营销型网站建设，鄂尔多斯网站制作、鄂尔多斯网页设计、鄂尔多斯网站官网定制、微信小程序定制开发服务，打造鄂尔多斯网络公司原创品牌,更为您提供鄂尔多斯网站排名全网营销落地服务。

POM文件配置

  4.0.0

  com.example
  demojob
  0.0.1-SNAPSHOT
  jar

  demojob
  Demo project for Spring Boot

  
    org.springframework.boot
    spring-boot-starter-parent
    2.0.2.RELEASE
     
  

  
    UTF-8
    UTF-8
    1.8
  

  

    
      org.springframework.boot
      spring-boot-starter-web
    

    
      org.springframework.boot
      spring-boot-starter-test
      test
    


    
    
      elastic-job-common-core
      com.dangdang
      2.1.5
    
    
      elastic-job-lite-core
      com.dangdang
      2.1.5
    
    
      elastic-job-lite-spring
      com.dangdang
      2.1.5
    
    
      elastic-job-cloud-executor
      com.dangdang
      2.1.5
    


    
    
      org.mariadb.jdbc
      mariadb-java-client
      1.5.4
    
    
    
      com.alibaba
      druid-spring-boot-starter
      1.1.9
    
    
    
      com.baomidou
      mybatisplus-spring-boot-starter
      1.0.5
    
    
      com.baomidou
      mybatis-plus
      2.1.9
    


  

  
    
      
        org.springframework.boot
        spring-boot-maven-plugin
      
    
  

yaml文件配置（也可以用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 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();
  }
}

TestSimpleJob，定时器任务本身

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是什么

springboot一种全新的编程规范，其设计目的是用来简化新Spring应用的初始搭建以及开发过程，SpringBoot也是一个服务于框架的框架，服务范围是简化配置文件。

看完上述内容，你们掌握如何在SpringBoot中使用ElaticJob定时器的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注创新互联行业资讯频道，感谢各位的阅读！