首页 > 其他分享> > XXLJob与SpringCloud整合

XXLJob与SpringCloud整合

2022-06-20 16:05:02 作者：互联网

图示

下载,建表
网上链接一堆,自己找去,下载完了解压之后是个聚合工程,复制doc>db>.sql文件里面的内容,打开数据库的可视化工具,新建查询粘贴,执行

admin配置,logback.xml配置
配置端口号我习惯用7001…
配置contextpath…随便
配置datasource…改驱动改用户名和密码
配置警示邮件…随便写
其他不用动

logback.xml不改它

启动admin是否成功成功的话直接打包就ok

新建SpringCloud项目
注册中心->提供者->消费者
怎么配?SpringCloud案例我这里面说的很清楚了不再赘述
值得一提的是刚才xxljob那个工程中的sample-springboot中的resource给拷一份

到消费方的Resource中,就像下面这样

SpringCloud项目目录

今天的关键在这里

首先需要引入pom依赖,就是刚才打包到maven仓库里的xxljob

<dependency>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-core</artifactId><version>2.3.0</version>
</dependency>

讲一下这里面XXLJobConfig 和XXLJobHandler

XXLJobConfig
@Configuration
@ComponentScan(basePackages = "com.shanghai.xxljob.handler")

public class XXLJobConfig {
private Logger logger = LoggerFactory.getLogger(XXLJobConfig.class);

@Value("${xxl.job.admin.addresses}")
private String adminAddresses;

@Value("${xxl.job.executor.appname}")
private String appName;

@Value("${xxl.job.executor.ip}")
private String ip;

@Value("${xxl.job.executor.port}")
private int port;

@Value("${xxl.job.accessToken}")
private String accessToken;

@Value("${xxl.job.executor.logpath}")
private String logPath;

@Value("${xxl.job.executor.logretentiondays}")
private int logRetentionDays;

@Bean(initMethod = "start", destroyMethod = "destroy")
public XxlJobSpringExecutor xxlJobExecutor() {
logger.info("====xxl-job config init====");
XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
xxlJobSpringExecutor.setAppname(appName);
xxlJobSpringExecutor.setIp(ip);
xxlJobSpringExecutor.setPort(port);
xxlJobSpringExecutor.setAccessToken(accessToken);
xxlJobSpringExecutor.setLogPath(logPath);
xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
return xxlJobSpringExecutor;
}
}

XXLJobHandler
@Component
public class XXLJobHandler {