微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

XXLJob与SpringCloud整合

图示


下载,建表
网上链接一堆,自己找去,下载完了解压之后是个聚合工程,复制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 {

@XxlJob("yicheSpringCloud")
public void doSomeThing(){
XxlJobHelper.log("哈喽");
}
}

开始定时任务
第一步
运行刚开始admin打成的jar包


第二步
进入控制台

执行器管理->新增执行器(因为我已经增加过了),这里的机器地址要和application.properties中的xxl.job.executor.ip(不写表示本机)+xxl.job.executor.port一致

 

 

第三步注册任务
打开任务管理新建任务,这里面的jobHandler要和@XxlJob中的value值一致

 

 

执行
首先开项目
注册中心->提供方->消费方都启动起来
随后进入xxljob控制台,任务管理操作选择启动

显示已经在执行

看一下是不是调度日志中有执行结果,比如如下


执行日志中有JobHandler中我们写的日志内容注意 不能用@Slf4j 只能用XxlJobHelper.log去打印日志

看是不是和我们jobhandler是不是和我们要求录入的日志一致

原文链接:https://blog.csdn.net/t_t2_3/article/details/115462048

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐