定时任务

cdp-task/pom.xml

@@ -15,5 +15,39 @@
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
     </properties>
+    <dependencies>
+        <dependency>
+            <groupId>com.example</groupId>
+            <artifactId>elastic-job-springboot</artifactId>
+            <version>2.0-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.zookeeper</groupId>
+            <artifactId>zookeeper</artifactId>
+            <version>3.4.13</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-log4j12</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+        <dependency>
+            <groupId>com.dangdang</groupId>
+            <artifactId>elastic-job-lite-core</artifactId>
+            <version>2.1.5</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+        </dependency>
+
+        <!--Mysql依赖包-->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+    </dependencies>
 
 </project>

cdp-task/src/main/java/com/baiye/JobApplication.java

@@ -0,0 +1,16 @@
+package com.baiye;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+/**
+ * @author jt
+ */
+@SpringBootApplication
+@EnableScheduling
+public class JobApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(JobApplication.class, args);
+    }
+}

cdp-task/src/main/java/com/baiye/job/TestJob.java

@@ -0,0 +1,17 @@
+package com.baiye.job;
+
+import com.dangdang.ddframe.job.api.ShardingContext;
+import com.dangdang.ddframe.job.api.simple.SimpleJob;
+import com.example.autoconfig.ElasticSimpleJob;
+import org.springframework.stereotype.Component;
+
+@ElasticSimpleJob(
+        jobName = "TestJob", cron = "0 0/1 * * * ?", shardingTotalCount = 1, overwrite = true, jobEvent = false)
+@Component
+public class TestJob implements SimpleJob {
+
+    @Override
+    public void execute(ShardingContext shardingContext) {
+        System.out.println("测试定时");
+    }
+}

cdp-task/src/main/resources/config/application-dev.yml

@@ -0,0 +1,7 @@
+
+spring:
+  datasource:
+    driver-class-name: com.mysql.jdbc.Driver
+    url: jdbc:mysql://8.130.96.163:3306/db_tiktok?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&zeroDateTimeBehavior=convertToNull
+    username: root
+    password: y7z7noq2

cdp-task/src/main/resources/config/application.yml

@@ -0,0 +1,16 @@
+server:
+  port: 7353
+
+elasticjob:
+  zookeeper:
+    namespace: springboot-elasticjob
+    server-list: localhost:2181
+spring:
+  main:
+    allow-bean-definition-overriding: true
+  application:
+    name: @artifactId@
+  freemarker:
+    check-template-location: false
+  profiles:
+    active: dev