本文介紹了springboot集成elaticjob定時器的實現(xiàn)代碼，分享給大家，具體如下:
pom文件配置
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
<?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一樣的）
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
# 配置配置數(shù)據(jù)源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# 配置zookeeperregcenter: serverlist: localhost:2181 namespace: hulk_order_task# 配置定時器規(guī)則simplejob: cron: 0/5 * * * * ? shardingtotalcount: 1 shardingitemparameters: 0=1 |
開始寫代碼
registrycenterconfig
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
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;/** * 注冊中心配置 * 用于注冊和協(xié)調(diào)作業(yè)分布式行為的組件，目前僅支持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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
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;/** * 如果想把作業(yè)運行的內(nèi)容寫到db中，我們需要用到另一個構(gòu)造器， * 同時定義自己的jobeventconfiguration， * 目前來說實現(xiàn)這個接口的只有一個類jobeventrdbconfiguration， * 通過這個可以將作業(yè)運行的痕跡進行持久化到db的操作。 * @author shudalei */@configurationpublic class jobeventconfig { @resource private datasource datasource; @bean public jobeventconfiguration jobeventconfiguration() { return new jobeventrdbconfiguration(datasource); }} |
simplejobconfig
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
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;@configurationpublic class simplejobconfig { /** * 注冊中心 */ @resource private zookeeperregistrycenter regcenter; /** * job事件配置 */ @resource private jobeventconfiguration jobeventconfiguration; /** * 微信access token獲取任務(wù)對象 * */ @resource private testsimplejob simplejob; /** * * @param cron 定時任務(wù)cron配置 * @param shardingtotalcount 任務(wù)分片數(shù) * @param shardingitemparameters 任務(wù)分片參數(shù) * @return jobscheduler 任務(wù)調(diào)度器 */ @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 任務(wù)調(diào)度類 * @param cron 定時任務(wù)cron配置 * @param shardingtotalcount 任務(wù)分片數(shù) * @param shardingitemparameters 任務(wù)分片參數(shù) * @return litejobconfiguration 任務(wù)配置 */ 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，定時器任務(wù)本身
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
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;@componentpublic class testsimplejob implements simplejob { private int count; //任務(wù)就是每5秒執(zhí)行一次控制臺輸出1，2，3…… @override public void execute(shardingcontext shardingcontext) { count++; system.out.println("task " + count); }} |
最后在docker下安裝 zookeeper
安裝腳本compose文件如下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
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 |
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://www.jianshu.com/p/62ebedc764b7
