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、再次启动服务并验证

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

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

执行成功

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


相关文章
|
5月前
|
Java 调度 Maven
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目(下)
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目(下)
118 0
|
6月前
|
监控 Java 调度
分布式系列教程(17) - 分布式任务调度平台XXL-JOB
分布式系列教程(17) - 分布式任务调度平台XXL-JOB
149 0
|
5月前
|
SQL 负载均衡 监控
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目(上)
【分布式任务调度平台 XXL-JOB 急速入门】从零开始将 XXL-JOB 接入到自己的项目
104 0
|
8月前
|
存储 Java Serverless
XXL-JOB零改造迁移
本实验将带大家体验,如何将XXL-JOB零改造迁移到Serverless Job。
120 0
|
10月前
|
SpringCloudAlibaba 负载均衡 JavaScript
分布式任务调度框架:XXL-JOB(入门篇)
将调度行为抽象形成“调度中心”公共平台,而平台自身并不承担业务逻辑,“**调度中心**”负责发起调度请求。将任务抽象成分散的JobHandler,交由“执行器”统一管理,“**执行器**”负责接收调度请求并执行对应的JobHandler中业务逻辑。因此,“调度”和“任务”两部分可以相互解耦,提高系统整体稳定性和扩展性;
520 0
|
12月前
|
分布式计算 前端开发 Java
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架,很不错!
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架,很不错!
|
分布式计算 前端开发 Java
只会用 xxl-job?更强大的新一代分布式任务调度框架来了!
只会用 xxl-job?更强大的新一代分布式任务调度框架来了!
|
分布式计算 前端开发 数据可视化
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架来了,太强大了!
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架来了,太强大了!
650 0
你只会用 xxl-job?一款更强大、新一代分布式任务调度框架来了,太强大了!
|
SQL Java 关系型数据库
分布式任务调度平台XXL-JOB(快速上手)
分布式任务调度平台XXL-JOB(快速上手)
分布式任务调度平台XXL-JOB(快速上手)
|
JavaScript Java 数据库连接
三分钟搞定 XXL-JOB 分布式任务调度平台
三分钟搞定 XXL-JOB 分布式任务调度平台
三分钟搞定 XXL-JOB 分布式任务调度平台