powerjob基于springboot2.1.6.RELEASE版本的问题研究

news2024/11/22 21:01:48

项目背景：基于第三代框架的集成问题，如果对于powerjob不熟悉的朋友，可以参考官方文档PowerJob 简介 · 语雀

关于语雀 23 日故障的公告 (qq.com)

简单插一句，针对语雀文档故障的心得，数据恢复，完整性，健壮性是一个项目的立身之本，历时七个小时恢复，也告诫了所有人，针对于千万级客户的文档产品，应该做到更完善的技术风险保障和高可用架构设计是多么重要，尤其面向技术变更操作的可监控，可灰度，可回滚系统的建设和流程审计，定期容灾应急演练，才能提高系统的恢复速度。

回到正题：

为什么写这篇文章？以及解决了哪些问题，如何解决的？再次做一个复盘

正常集成powerjob比较简单，配置一下yaml，启动powerjob服务就OK了

这篇文档是在已有的技术架构下，增加分布式调度任务，替换quartz

配置文件：

## akka 工作端口，可选，默认 27777
powerjob.worker:
  akka-port: 19302
# 接入应用名称，用于分组隔离，推荐填写 本 Java 项目名称
  app-name: admin
# 调度服务器地址，IP:Port 或 域名，多值逗号分隔
  server-address: 192.162.1.200:40003
# 通讯协议，4.3.0 开始支持 HTTP 和 AKKA 两种协议，官方推荐使用 HTTP 协议（注意 server 和 worker 都要开放相应端口）
  protocol: http
# 持久化方式，可选，默认 disk
  store-strategy: disk
# 任务返回结果信息的最大长度，超过这个长度的信息会被截断，默认值 8192
  max-result-length: 4096
# 单个任务追加的工作流上下文最大长度，超过这个长度的会被直接丢弃，默认值 8192
  max-appended-wf-context-length: 4096
# 同时运行的轻量级任务数量上限
  max-lightweight-task-num: 1024
# 同时运行的重量级任务数量上限
  max-heavy-task-num: 64

powerjob集成版本：

 <dependency>
            <groupId>tech.powerjob</groupId>
            <artifactId>powerjob-worker-spring-boot-starter</artifactId>
            <version>4.3.3</version>
        </dependency>

springboot集成版本：

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

第一次出现启动问题：

JsonMapper映射出现问题，大概是JsonUtils解析出现的问题，在源码PowerjobWorker.init初始化的时候，我们了解到在获取配置文件反解析对象的时候，报错，根据错误信息，我们使用的jackson版本2.9.0出现了冲突，那我们的策略是提升版本2.13.5，重新再次运行

  <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.dataformat</groupId>
            <artifactId>jackson-dataformat-cbor</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.dataformat</groupId>
            <artifactId>jackson-dataformat-yaml</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.datatype</groupId>
            <artifactId>jackson-datatype-jdk8</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.datatype</groupId>
            <artifactId>jackson-datatype-jsr310</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.module</groupId>
            <artifactId>jackson-module-parameter-names</artifactId>
            <version>2.13.5</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml</groupId>
            <artifactId>classmate</artifactId>
            <version>1.5.1</version>
        </dependency>

第二个问题：启动又出现新的问题

        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>29.0-jre</version>
        </dependency>

根据上述提示，guava包解析，字节码和源码不匹配，怀疑是guava版本冲突，我们替换了29.0版本覆盖jar包里边的版本，重新启动，成功