SpringBoot集成ElaticJob定时器的实现代码

2024-07-28 16:00:55

本文介绍了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>

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<? 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();
  }
}

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使用定时器使用方法添加@Scheduled注解设计cron参数即可 package com.clsystem.Comm; import org.springframework.scheduling.annotation.Scheduled; /** * Created by pudding on 2017-11-10.(打卡记录定时任务) */ @Component public class ClockTiming { /** * 定时器 */ @Scheduled(cro
SpringBoot集成ElaticJob定时器的实现代码

本文介绍了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:sch
SpringBoot集成slf4j+log4j2的示例代码

本文介绍了SpringBoot集成slf4j+log4j2的示例代码,分享给大家,具体如下: Maven依赖  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-log4j2</artifactId> </dependency> <dependency&g
springboot 集成支付宝支付的示例代码

最简单的springboot集成支付宝 1 注册沙箱沙箱是一个模拟环境登录,百度蚂蚁金服开放平台,支付宝扫码登录如下然后沙箱需要注册一下,非常之简单,注册好以后进入到如下页面,选沙箱工具,然后下载一个生成密钥的工具.然后解压按照里面的readme生成公私密钥, 选择沙箱应用上传公钥即可..沙箱到这里就基本完成了,里面还有沙箱版本的的android app可以下载下来. java 程序 1 新建一个springboot项目因为我们创建的是一个web工程,所以,仅仅演示支付宝的demo,只需
SpringBoot集成Auth0 JWT的示例代码

目录前言 session认证与Token认证 session认证 Token认证 JWT简介 JWT定义 JWT的类库具体实现 JWT配置 JWT工具类测试接口前言说说JWT,先说下互联网服务常见的两种用户认证方式: session认证与Token认证 session认证传统的Session认证的大体流程可以表示为用户提供用户名和密码登录后由服务器存储一份用户登录信息并传递给浏览器保存为Cookie,并在下次请求中根据Cookie来识别用户,但这种方式缺陷明显: Session都是保
springboot集成微软teams的实例代码

前言最近做了一个有关微软的平台teams开发,在国内用微软teams聊天工具的少之又少,整个亚洲也没什么开发的实例,官方文档写的有点乱,在没有第三方支持下开发有点头疼.需求是做一个管理后台跟teams打通,支持各种通告发送,以及撤回.没时间具体些,用的东西丢在上面用上的可以参考. 添加依赖 <dependency> <groupId>com.microsoft.graph</groupId> <artifactId>microsoft-graph</
springboot集成spring cache缓存示例代码

本文介绍如何在springboot中使用默认的spring cache, 声明式缓存 Spring 定义 CacheManager 和 Cache 接口用来统一不同的缓存技术.例如 JCache. EhCache. Hazelcast. Guava. Redis 等.在使用 Spring 集成 Cache 的时候,我们需要注册实现的 CacheManager 的 Bean. Spring Boot 为我们自动配置了 JcacheCacheConfiguration. EhCacheCacheCo
SpringBoot集成kaptcha验证码

本文实例为大家分享了SpringBoot集成kaptcha验证码的具体代码,供大家参考,具体内容如下 1.kaptcha相关介绍 Kaptcha是一个基于SimpleCaptcha的验证码开源项目. 2.集成方案 ①pom.xml中配置依赖  <dependency> <groupId>com.github.penggle</groupId> <artifactId>kaptcha</artifactId> &l
springboot集成activemq的实例代码

ActiveMQ ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线.ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位. 特性多种语言和协议编写客户端.语言: Java,C,C++,C#,Ruby,Perl,Python,PHP.应用协议: OpenWire,Stomp REST,WS Notification,XMPP,AMQP
SpringBoot集成swagger的实例代码

Swagger 是一款RESTFUL接口的文档在线自动生成+功能测试功能软件.本文简单介绍了在项目中集成swagger的方法和一些常见问题.如果想深入分析项目源码,了解更多内容,见参考资料. Swagger 是一个规范和完整的框架,用于生成.描述.调用和可视化 RESTful 风格的 Web 服务.总体目标是使客户端和文件系统作为服务器以同样的速度来更新.文件的方法,参数和模型紧密集成到服务器端的代码,允许API来始终保持同步.Swagger 让部署管理和使用功能强大的API从未如此简单. 对于
SpringBoot集成JPA的示例代码

本文介绍了SpringBoot集成JPA的示例代码,分享给大家,具体如下: 1.创建新的maven项目 2. 添加必须的依赖  <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.9.RELEASE

SpringBoot集成ElaticJob定时器的实现代码

相关推荐

随机推荐