JDK11+
具体版本,可以上Maven中央仓库查询
<dependency>
<groupId>com.heanbian.block</groupId>
<artifactId>heanbian-elasticjob</artifactId>
<version>1.0.2</version>
</dependency>
配置 application.yml
heanbian:
elasticjob:
zookeeper-nodes: 192.168.1.101:2181,192.168.1.102:2181,192.168.1.103:2181
zookeeper-namespace: elasticjob_fgFDGdfg45435SDFsfb #自定义
Spring Boot 启动类添加注解:
@EnableElasticJob
Java代码片段:
@Component
@ElasticJobClient(cron = "*/10 * * * * ?")
public class TestTask implements SimpleJob {
@Override
public void execute(ShardingContext shardingContext) {
}
}
说明:适用于 Spring Boot 项目。