xxl-job任务调度2.0.2升级到2.3.0版本,执行器改造过程中经验总结

简介: xxl-job任务调度2.0.2升级到2.3.0版本,执行器改造过程中经验总结

一、背景

现在要对一批老项目中的执行器进行升级,原来老项目中的执行器,依赖的任务调度中心xxl-job版本是2.0.2-SNAPSHOT版本,现在要依赖2.3.0版本的xxl-job任务调度中心

二、开始改造

老项目的执行器,使用的是spring版本,需要tomcat来启动服务,这里拿一个纯净的spring项目来演示,具体如下:

1、修改pom.xml

打开pom.xml文件,原文件是这样的

如下:

<parent>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-executor-samples</artifactId>
    <version>2.0.2-SNAPSHOT</version>
  </parent>

修改执行器依赖xxl-job-core的版本,改为2.3.0版本

如下:

<parent>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-executor-samples</artifactId>
    <version>2.3.0</version>
  </parent>

2、修改Handler

升级到2.3.0版本之后,我们发现Handler类报错了

原因就是因为,新版本的xxl-job,已经弃用了@JobHandler注解,采用了@XxlJob注解,并且@XxlJob注解只能作用在方法上面哦。

改造步骤:

  • 1、去掉@JobHandler注解
  • 2、去掉 extends IJobHandler
  • 3、方法上加上@XxlJob注解
  • 4、返回值 SUCCESS 改为 ReturnT.SUCCESS

代码参考:

package com.xxl.job.executor.service.jobhandler;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
@Component
public class DemoJobHandler {
  @XxlJob("demoJobHandler")
  public ReturnT<String> execute(String param) throws Exception {
    XxlJobLogger.log("XXL-JOB, Hello World.");
    for (int i = 0; i < 5; i++) {
      XxlJobLogger.log("beat at:" + i);
      TimeUnit.SECONDS.sleep(2);
    }
    return ReturnT.SUCCESS;
  }
}

3、启动服务并验证

版本也升级了,handler类也改造好了,貌似没什么问题了,那我们直接启动tomcat服务,来验证一下。

启动之后,我们看一下控制台日志

Connected to server
[2023-10-20 10:34:31,713] Artifact xxl-job-executor-sample-spring:war exploded: Artifact is being deployed, please wait...
20-Oct-2023 10:34:38.787 信息 [RMI TCP Connection(5)-127.0.0.1] org.apache.jasper.servlet.TldScanner.scanJars At least one JAR was scanned for TLDs yet contained no TLDs. Enable debug logging for this logger for a complete list of JARs that were scanned but no TLDs were found in them. Skipping unneeded JARs during scanning can improve startup time and JSP compilation time.
20-Oct-2023 10:34:38.885 严重 [RMI TCP Connection(5)-127.0.0.1] org.apache.catalina.core.StandardContext.startInternal One or more listeners failed to start. Full details will be found in the appropriate container log file
20-Oct-2023 10:34:38.887 严重 [RMI TCP Connection(5)-127.0.0.1] org.apache.catalina.core.StandardContext.startInternal Context [] startup failed due to previous errors
[2023-10-20 10:34:38,903] Artifact xxl-job-executor-sample-spring:war exploded: Error during artifact deployment. See server log for details.

如果这个看不出来,可以看一下另外的输出日志

org.apache.catalina.core.ApplicationContext.log No Spring WebApplicationInitializer types detected on classpath
20-Oct-2023 10:34:38.834 严重 [RMI TCP Connection(5)-127.0.0.1] org.apache.catalina.core.StandardContext.listenerStart Error configuring application listener of class org.springframework.web.util.Log4jConfigListener
 java.lang.ClassNotFoundException: org.springframework.web.util.Log4jConfigListener

4、解决异常

刚刚启动服务的时候,报错了,比较核心的错误日志是这一句:

java.lang.ClassNotFoundException: org.springframework.web.util.Log4jConfigListener

就是说tomcat启动的时候,没有找到spring中的Log4jConfigListener类,OK,我们先看一下spring的版本,升级到2.3.0之后,spring-webmvc的版本也跟着改变了,变成了5.3.3版本

经过查询,发现org.springframework.web.util.Log4jConfigListener这个类在spring5.0及以上版本已经废弃删除,如果想使用这个类,spring版本需要降低。原来如此,那我们直接将spring的版本降为升级前的版本

<dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>4.3.22.RELEASE</version>
    </dependency>

OK,接下来启动服务,看一下

我们发现虽然报错了,但至少spring容器在加载初始化一些配置了,我们分析一下错误:

Invalid property 'appName' of bean class [com.xxl.job.core.executor.impl.XxlJobSpringExecutor]: Bean property 'appName' is not writable or has an invalid setter method. Did you mean 'appname'?

应该是属性名称不一样,我们找一下源码,打开一下XxlJobSpringExecutor类

public class XxlJobSpringExecutor extends XxlJobExecutor implements ApplicationContextAware, SmartInitializingSingleton, DisposableBean {
    private static final Logger logger = LoggerFactory.getLogger(XxlJobSpringExecutor.class);
    private static ApplicationContext applicationContext;
    public XxlJobSpringExecutor() {
    }
    public void afterSingletonsInstantiated() {
        this.initJobHandlerMethodRepository(applicationContext);
        GlueFactory.refreshInstance(1);
        try {
            super.start();
        } catch (Exception var2) {
            throw new RuntimeException(var2);
        }
    }
    .....

发现没有,继续找他的父类XxlJobExecutor,终于找到了,我们看到appname这个字段是这样命名的

所以,我们回到项目中,看一下项目中的配置文件

原来这个地方写成了appName,所以只要把他改成appname就可以了

5、再次启动服务并验证

我们发现终于启动成功了,再看一下,执行器是否注册到任务调度中心了

我们随便建一个任务执行一下看看

执行成功

至此,执行器的版本升级结束


相关文章
|
7月前
|
Java 调度 Maven
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目(下)
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目(下)
452 0
|
17天前
|
监控 安全 调度
彻底解决5大开源痛点,阿里云发布任务调度 XXL-JOB 版
阿里云任务调度XXL-JOB版 迎来重磅发布,以任务调度SchedulerX为内核,0代码改造,完全兼容开源XXL-JOB客户端接入,解决开源XXL-JOB痛点问题。
130 14
|
监控 Java 调度
分布式系列教程(17) - 分布式任务调度平台XXL-JOB
分布式系列教程(17) - 分布式任务调度平台XXL-JOB
284 0
|
4月前
|
存储 监控 算法
XXL-JOB内部机制大揭秘:让任务调度飞起来
【8月更文挑战第14天】在大数据时代,高效的任务调度系统是支撑业务稳定运行与快速迭代的基石。XXL-JOB,作为一款轻量级、分布式任务调度平台,凭借其灵活的配置、强大的扩展性和高可用特性,在众多任务调度框架中脱颖而出。今天,我们就来深入揭秘XXL-JOB的内部机制,看看它是如何让任务调度“飞起来”的。
287 0
|
7月前
|
SQL 负载均衡 监控
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目(上)
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目
883 0
|
存储 Java Serverless
XXL-JOB零改造迁移
本实验将带大家体验,如何将XXL-JOB零改造迁移到Serverless Job。
|
负载均衡 Java API
分布式任务调度框架:XXL-JOB(入门篇)
将调度行为抽象形成“调度中心”公共平台,而平台自身并不承担业务逻辑,“**调度中心**”负责发起调度请求。将任务抽象成分散的JobHandler,交由“执行器”统一管理,“**执行器**”负责接收调度请求并执行对应的JobHandler中业务逻辑。因此,“调度”和“任务”两部分可以相互解耦,提高系统整体稳定性和扩展性;
1060 0
分布式任务调度框架:XXL-JOB(入门篇)
|
监控 算法 Java
分布式任务调度框架XXL-JOB入门教程
XXL-JOB是一个分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线,开箱即用。
172 0
|
监控 数据可视化 关系型数据库
分布式调度XXL-JOB急速入门
分布式调度XXL-JOB急速入门
分布式调度XXL-JOB急速入门
|
分布式计算 前端开发 数据可视化
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架来了,太强大了!
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架来了,太强大了!
933 0
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架来了,太强大了!