一文搞懂java中的定时任务框架-分布式(xxl-job)
XXL-JOB是一个分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展。
以下是一个简单的XXL-JOB分布式任务的示例代码:
- 首先,需要在项目的
pom.xml
中添加XXL-JOB的依赖:
<dependency>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-core</artifactId>
<version>版本号</version>
</dependency>
- 创建一个任务执行类,实现
com.xxl.job.core.handler.annotation.XxlJob
注解:
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class SampleXxlJob {
private static final Logger logger = LoggerFactory.getLogger(SampleXxlJob.class);
@XxlJob("demoJobHandler")
public void execute() throws Exception {
// 任务逻辑
logger.info("XXL-JOB开始执行任务...");
// 任务代码
// ...
// 任务结束
logger.info("XXL-JOB任务执行结束.");
}
}
- 在
application.properties
或application.yml
中配置XXL-JOB:
# xxl-job admin address
xxl.job.admin.addresses=http://localhost:8080/xxl-job-admin
# xxl-job executor address
xxl.job.executor.ip=127.0.0.1
xxl.job.executor.port=9999
xxl.job.accessToken=
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
xxl.job.executor.logretentiondays=30
- 在启动类上添加@XxlJobConfig注解启动XxlJob:
import com.xxl.job.core.executor.XxlJobExecutor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class XxlJobConfig {
@Bean(initMethod = "start", destroyMethod = "destroy")
public XxlJobExecutor xxlJobExecutor() {
XxlJobExecutor xxlJobExecutor = new XxlJobExecutor();
// 这里配置的属性需要和上面的配置文件对应
return xxlJobExecutor;
}
}
- 在XXL-JOB管理界面配置相应的任务,并指定任务处理器(demoJobHandler)。
以上步骤可以配置一个基本的XXL-JOB任务,在分布式环境中可以通过XXL-JOB管理界面来管理和监控这些任务的执行情况。
评论已关闭