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管理界面来管理和监控这些任务的执行情况。