XXLJob与SpringCloud整合 您所在的位置:网站首页 springcloud任务调度 XXLJob与SpringCloud整合

XXLJob与SpringCloud整合

2024-06-29 10:06| 来源: 网络整理| 查看: 265

图示

在这里插入图片描述

下载,建表

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

admin配置,logback.xml配置

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

logback.xml不改它

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

新建SpringCloud项目

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

到消费方的Resource中,就像下面这样 在这里插入图片描述 SpringCloud项目目录 在这里插入图片描述 今天的关键在这里 在这里插入图片描述

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

com.xuxueli xxl-job-core 2.3.0

讲一下这里面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是不是和我们要求录入的日志一致 在这里插入图片描述

总结

很入门的XXLJob的使用,陆续我会介绍如何用代码去动态创建执行暂定停止任务,以及创建执行器



【本文地址】

公司简介

联系我们

今日新闻

    推荐新闻

    专题文章
      CopyRight 2018-2019 实验室设备网 版权所有