做视频网站需要什么软件有哪些,网站设计素材下载,大名专业做网站,网站屏蔽中国ip解决ElasticJob项目重启ZooKeeper注册冲突以及zkCli删除目录
背景
在现代化的分布式调度系统中#xff0c;ElasticJob 是一个非常流行的选择。它利用 ZooKeeper 作为注册中心来管理任务分片。然而#xff0c;有时在项目重启时#xff0c;会遇到 ZooKeeper 注册冲突的问题ElasticJob 是一个非常流行的选择。它利用 ZooKeeper 作为注册中心来管理任务分片。然而有时在项目重启时会遇到 ZooKeeper 注册冲突的问题即任务名已在注册中心存在。本文将详细讲解如何解决此问题以及如何使用 zkCli 删除ZooKeeper的目录。
问题描述
ElasticJob 重启时的注册冲突
使用 ElasticJob 的最新版本3.0.1时重启项目会碰到 ZooKeeper 注册冲突的问题。具体表现为因定时任务使用了代理导致项目重启时报任务名冲突提示任务已经在注册中心存在。
zkCli 删除目录
删除ZooKeeper节点目录也是我们维护和管理ZooKeeper时常见的操作。当需要清理已经废弃的节点时删除操作显得尤为重要。
解决方案
依赖配置
首先确保项目中使用的是 ElasticJob 的最新版本
dependencygroupIdorg.apache.shardingsphere.elasticjob/groupIdartifactIdelasticjob-lite-spring-boot-starter/artifactIdversion3.0.1/version
/dependency使用自定义的 JobClassNameProvider 问题原因 定时任务使用了代理默认情况下会读取代理类名称而不是原始类名称导致任务名冲突。 解决思路 自定义一个 JobClassNameProvider在项目重启时确保读取到的是原始类名称而不是代理类名称。 实现自定义 JobClassNameProvider
public class CustomJobClassNameProvider implements JobClassNameProvider {Overridepublic String getJobClassName(ElasticJob elasticJob) {String elasticJobClassName ClassUtils.getUserClass(elasticJob).getName();return AopUtils.isAopProxy(elasticJob) ? elasticJobClassName : elasticJob.getClass().getName();}
}在这里我们使用 ClassUtils.getUserClass(elasticJob).getName() 方法获取原始类名这样就避免了代理类引起的冲突问题。
注册自定义类 在项目的 src/main/resources 目录下新建一个 META-INF 目录在 META-INF 目录下创建 services 目录创建一个名为 org.apache.shardingsphere.elasticjob.lite.internal.setup.JobClassNameProvider 的文件内容如下
你的类全路径名例如com.example.CustomJobClassNameProvider使用 zkCli 命令操作ZooKeeper
以下是常用的 zkCli 操作步骤 进入 ZooKeeper 安装目录的 bin 文件夹 cd /var/www/data/zookeeper/zookeeper-3.8.0/bin启动 zkCli ./zkCli.sh查看节点目录 [zk: localhost:2181(CONNECTED) 21] ls /删除节点目录 删除 /elasticjob-admin-api-v0.7 目录及其子目录 [zk: localhost:2181(CONNECTED) 22] deleteall /elasticjob-admin-api-v0.7总结
通过自定义 JobClassNameProvider可以有效解决 ElasticJob 在重启时引起的 ZooKeeper 注册冲突问题。使用 zkCli 也可以方便地管理和删除 ZooKeeper 节点这对于维护一个健康的 ZooKeeper 集群系统至关重要。
希望这篇文章能够帮助你解决 ElasticJob 项目重启冲突以及 ZooKeeper 节点管理的问题。如果你有其他的疑问或更好的解决方案欢迎在评论区留言讨论
