分布式定时任务，封装了elastic-job-lite&elastic-job-lite-console，支持手动触发任.zip

# scheduled-task-spring-boot-starter 基于Zookeeper的最最轻量级的分布式定时任务,一个Start就搞定!!! 封装的**elastic-job-lite** & **elastic-job-lite-console**. + 支持手动触发Job + 支持手动添加Job + 支持一次性Job + 查看Job以及服务器状态 + 快捷的修改以及删除Job设置 + 启用和禁用Job + 跨注册中心查看Job + 查看Job运行轨迹和运行状态 > **💡提示:** 初始代码Copy自:`number68/scheduled-task` ## 依赖引入 ### 通过Maven的`pom.xml`引入。 ```xml <?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.4.12</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>org.wjw.job</groupId> <artifactId>testscheduledtask</artifactId> <version>1.0.0</version> <name>TestScheduledTask</name> <description>test scheduledtask</description> <properties> <java.version>1.8</java.version> <elastic-job.version>2.1.5</elastic-job.version> <mysql.version>5.1.49</mysql.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-tomcat</artifactId> <scope>provided</scope> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>com.github.wjw465150</groupId> <artifactId>scheduled-task-spring-boot-starter</artifactId> <version>2.1.8</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project> ``` ### 或者通过Gradle的`build.gradle`引入 ```groovy plugins { id 'org.springframework.boot' version '2.4.12' id 'io.spring.dependency-management' version '1.0.11.RELEASE' id 'java' } // jar包的名字 archivesBaseName = 'scheduled-task-test' ext { mysql = [version : '5.1.49'] elasticjob = [version : '2.1.5'] } group = 'org.wjw.starter.test' version = '1.0.0' sourceCompatibility = '1.8' targetCompatibility = '1.8' [compileJava, compileTestJava]*.options*.encoding = 'UTF-8' repositories { mavenLocal() maven { url "http://maven.aliyun.com/nexus/content/groups/public/" } //优先使用阿里的镜像 mavenCentral() } dependencies { implementation 'org.springframework.boot:spring-boot-starter-web' providedRuntime 'org.springframework.boot:spring-boot-starter-tomcat' runtimeOnly "mysql:mysql-connector-java:${mysql.version}" implementation group: 'com.github.wjw465150', name: 'scheduled-task-spring-boot-starter', version: '2.1.8' } ``` ## 编写SpringBoot的启动类 ```java package TestScheduledTask import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.web.servlet.ServletComponentScan; import org.springframework.context.annotation.EnableAspectJAutoProxy; @SpringBootApplication public class ScheduledTaskApplication { private static final Logger log = LoggerFactory.getLogger(ScheduledTaskApplication.class); public static void main(String[] args) { SpringApplication.run(ScheduledTaskApplication.class, args); log.info("------------scheduled-task started successfully-------------"); } } ``` ## 编写一个SimpleJob类来测试: ```java package TestScheduledTask.job; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.cloud.task.annotation.ScheduledTask; import com.dangdang.ddframe.job.api.ShardingContext; import com.dangdang.ddframe.job.api.simple.SimpleJob; /** * SimpleJob类型的的例子 * @author White Stone * * 2021年12月14日 */ @ScheduledTask(name = "SimpleJobExample", cron = "0/30 * * * * ?", shardingTotalCount = 3, shardingItemParameters="0=Beijing,1=Shanghai,2=Guangzhou", overwrite = true) public class SimpleJobExample implements SimpleJob { private final Logger logger = LoggerFactory.getLogger(this.getClass()); @Override public void execute(ShardingContext shardingContext) { //打印出任务相关信息，JobParameter用于传递任务的ID logger.info("JobName：{}, ShardingTotalCount：{}, JobParameter={}, ShardingItem: {}, ShardingParameter: {}", shardingContext.getJobName(), shardingContext.getShardingTotalCount(), shardingContext.getJobParameter(), shardingContext.getShardingItem(), shardingContext.getShardingParameter() ); } } ``` ## 编写application配置文件`application.yml` ```yaml spring: application: name: scheduled-task server: port: 8090 logging: level: root: info --- spring: datasource: driver-class-name: com.mysql.jdbc.Driver url: jdbc:mysql://localhost:3306/scheduled-task?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&characterEncoding=UTF-8 username: root password: 11111111 hikari: minimum-idle: 5 maximum-pool-size: 10 #控制台认证 auth: username: admin password: 123456 #连接到zookeeper的配置 zookeeper: serviceLists: 127.0.0.1:2181 namespace: scheduled-task baseSleepTimeMilliseconds: 5000 maxSleepTimeMilliseconds: 5000 maxRetries: 3 scheduledTask: #定时任务监控预警 monitor: enable: true time: interval: 3 ``` ## 启动: 运行启动类`ScheduledTaskApplication`启动项目 输出如下: ```bash !!!!!!=================Spring DefaultProfiles:[default]=================!!!!!! !!!!!!=================Spring ActiveProfiles:[dev]=================!!!!!! . ____ _ __ _ _ /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \ ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \ \\/ ___)| |_)| | | | | || (_| | ) ) ) ) ' |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v2.4.12) 2021-12-14 20:09:11.519 [main] INFO TestScheduledTask.TestApplication - [logStarting,55] - Starting TestApplication using Java 1.8.0_301 on WJW-T14 with PID 21332 (C:\WJW_Z\eclipse_scheduled-task\scheduled-task\scheduled-task-test\bin\main started by 86189 in C:\WJW_Z\eclipse_scheduled-task\scheduled-task\scheduled-task-test) 2021-12-14 20:09:11.522 [main] INFO TestScheduledTask.TestApplication - [logStartupProfileInfo,668] - The following profiles are active: dev 2021-12-14 20:09:12.421 [main] INFO o.s.boot.web.embedded.tomcat.TomcatWebServer - [initialize,108] - Tomcat initialized with port(s): 8090 (http) 2021-12-14 20:09:12.431 [main] INFO org.apache.coyote.http11.Http11NioProtocol - [log,173] - Initializing ProtocolHandler ["http-nio-8090"] 2021-12-14 20:09:12.431 [main] INFO org.apache.catalina.core.StandardService - [log,173] - Starting service [Tomcat] 2021-12-14 20:09:12.431 [main] INFO org.apache.catalina.core.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/9.0.54] 2021-12-14 20:09:12.502 [main] INFO o.a.c.core.ContainerBase.[Tomcat].[localhost].[/] - [log,173] - Initializing Spring embedded WebApplicationContext 2021-12-14 20:09:12.503 [main] INFO o.s.b.w.s.c.ServletWebServerApplicationContext - [prepareWebApplicationContext,289] - Root WebApplicationContext: initialization completed in 946 ms 2021-12-14 20:09:12.553 [main] INFO c.c.t.f.TaskAuthFilter$$EnhancerBySpringCGLIB$$cc147867 - [init,41] - AuthF