当前位置: 首页 > news >正文

Zookeeper(58)如何在Zookeeper中实现分布式锁?

在 Zookeeper 中实现分布式锁是一种常见的用例。Zookeeper 提供了强一致性、高可用性的分布式协调服务,使得它非常适合用来实现分布式锁。以下是详细的步骤和代码示例,展示如何在 Zookeeper 中实现分布式锁。

1. Zookeeper 分布式锁的基本原理

Zookeeper 分布式锁的实现主要依赖于以下几点:

  1. 临时顺序节点:每个客户端在尝试获取锁时,会在特定节点下创建一个临时顺序节点。
  2. 节点排序:所有客户端创建的节点会按顺序排列,最小的节点获得锁。
  3. 监视前一个节点:每个客户端监视它前一个节点的变化,当前一个节点被删除时,当前客户端重新检查自己是否是最小的节点,如果是,则获得锁。

2. 添加依赖

首先,需要在项目中添加 Zookeeper 的依赖。以下是 Maven 和 Gradle 的依赖配置:

Maven

pom.xml 中添加 Zookeeper 依赖:

<dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.7.0</version>
</dependency>
Gradle

build.gradle 中添加 Zookeeper 依赖:

dependencies {implementation 'org.apache.zookeeper:zookeeper:3.7.0'
}

3. 实现分布式锁

以下是一个完整的实现分布式锁的示例代码。

ZookeeperClient.java
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;public class ZookeeperClient {private static final String ZK_ADDRESS = "localhost:2181";private static final int SESSION_TIMEOUT = 3000;private ZooKeeper zooKeeper;public void connect() throws Exception {zooKeeper = new ZooKeeper(ZK_ADDRESS, SESSION_TIMEOUT, new Watcher() {@Overridepublic void process(WatchedEvent event) {System.out.println("Received event: " + event);}});}public void close() throws InterruptedException {if (zooKeeper != null) {zooKeeper.close();}}public ZooKeeper getZooKeeper() {return zooKeeper;}public static void main(String[] args) {ZookeeperClient client = new ZookeeperClient();try {client.connect();// 在这里可以测试分布式锁client.close();} catch (Exception e) {e.printStackTrace();}}
}
DistributedLock.java
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;import java.util.Collections;
import java.util.List;public class DistributedLock {private static final String LOCK_ROOT = "/locks";private static final String LOCK_NODE = LOCK_ROOT + "/lock_";private ZooKeeper zooKeeper;private String lockPath;public DistributedLock(ZooKeeper zooKeeper) throws Exception {this.zooKeeper = zooKeeper;Stat stat = zooKeeper.exists(LOCK_ROOT, false);if (stat == null) {zooKeeper.create(LOCK_ROOT, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);}}public void acquireLock() throws Exception {lockPath = zooKeeper.create(LOCK_NODE, new byte[0], ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);System.out.println("Lock path: " + lockPath);while (true) {List<String> children = zooKeeper.getChildren(LOCK_ROOT, false);Collections.sort(children);String smallestChild = LOCK_ROOT + "/" + children.get(0);if (lockPath.equals(smallestChild)) {System.out.println("Acquired lock: " + lockPath);return;}String watchNode = null;for (int i = children.size() - 1; i >= 0; i--) {String child = LOCK_ROOT + "/" + children.get(i);if (child.compareTo(lockPath) < 0) {watchNode = child;break;}}if (watchNode != null) {final Object lock = new Object();Watcher watcher = new Watcher() {@Overridepublic void process(WatchedEvent event) {synchronized (lock) {lock.notifyAll();}}};Stat stat = zooKeeper.exists(watchNode, watcher);if (stat != null) {synchronized (lock) {lock.wait();}}}}}public void releaseLock() throws Exception {if (lockPath != null) {zooKeeper.delete(lockPath, -1);System.out.println("Released lock: " + lockPath);lockPath = null;}}public static void main(String[] args) {ZookeeperClient client = new ZookeeperClient();try {client.connect();ZooKeeper zooKeeper = client.getZooKeeper();DistributedLock lock = new DistributedLock(zooKeeper);lock.acquireLock();// 模拟业务逻辑Thread.sleep(5000);lock.releaseLock();client.close();} catch (Exception e) {e.printStackTrace();}}
}

4. 代码说明

ZookeeperClient 类

ZookeeperClient 类负责连接和关闭 Zookeeper 客户端,并提供获取 ZooKeeper 实例的方法。

DistributedLock 类

DistributedLock 类负责实现分布式锁的逻辑,包括获取锁和释放锁。

  • acquireLock() 方法:尝试获取锁,创建临时顺序节点,然后检查自己是否是最小的节点。如果是,则获得锁;否则,监视前一个节点的变化。
  • releaseLock() 方法:释放锁,删除自己创建的临时顺序节点。

5. 测试分布式锁

DistributedLock 类的 main 方法中,创建 ZookeeperClient 实例并连接 Zookeeper,然后创建 DistributedLock 实例并尝试获取和释放锁。可以通过运行多个实例来测试分布式锁的功能。

public static void main(String[] args) {ZookeeperClient client = new ZookeeperClient();try {client.connect();ZooKeeper zooKeeper = client.getZooKeeper();DistributedLock lock = new DistributedLock(zooKeeper);lock.acquireLock();// 模拟业务逻辑Thread.sleep(5000);lock.releaseLock();client.close();} catch (Exception e) {e.printStackTrace();}
}

总结

  1. 添加依赖:在项目中添加 Zookeeper 的依赖。
  2. 实现 ZookeeperClient 类:负责连接和关闭 Zookeeper 客户端,并提供获取 ZooKeeper 实例的方法。
  3. 实现 DistributedLock 类:负责实现分布式锁的逻辑,包括获取锁和释放锁。
  4. 测试分布式锁:通过运行多个实例来测试分布式锁的功能。

通过以上方法,可以在 Zookeeper 中实现分布式锁,确保其高效稳定地运行。根据实际情况和需求,选择适合你的实现方法并进行实施。

相关文章:

Zookeeper(58)如何在Zookeeper中实现分布式锁?

在 Zookeeper 中实现分布式锁是一种常见的用例。Zookeeper 提供了强一致性、高可用性的分布式协调服务&#xff0c;使得它非常适合用来实现分布式锁。以下是详细的步骤和代码示例&#xff0c;展示如何在 Zookeeper 中实现分布式锁。 1. Zookeeper 分布式锁的基本原理 Zookeep…...

Mac端homebrew安装配置

拷打了一下午o3-mini-high&#xff0c;不如这位博主的超强帖子&#xff0c;10分钟结束战斗 跟随该文章即可&#xff0c;2025/2/19亲测可行 mac 安装HomeBrew(100%成功)_mac安装homebrew-CSDN博客文章浏览阅读10w次&#xff0c;点赞258次&#xff0c;收藏837次。一直觉得自己写…...

Spring 接入 DeepSeek

引入依赖 <dependency><groupId>org.springframework.ai</groupId><artifactId>spring-ai-openai-spring-boot-starter</artifactId> </dependency>2.yml配置 spring:ai:openai:api-key: sk-xxxxx // 填写自己申请的keybase-url: http…...

vscode将文件中行尾默认CRLF改为LF

安装prettier npm install --save-dev --save-exact prettier执行命令 npx prettier --write --end-of-line lf .即可将项目中的所有文件行尾序列格式改为lf *在你使用git拉取代码的时候&#xff0c;git会自动将代码当中与你当前系统不同的换行方式转化成你当前系统的换行方…...

python-leetcode 33.排序链表

题目&#xff1a; 给定链表的头结点head,请将其按升序排列&#xff0c;并返回排序后的链表 方法一&#xff1a;自顶向下归并排序 链表自顶向下归并排序的过程&#xff1a; 1.找到链表的中点&#xff0c;以中点为分界&#xff0c;将链表拆分成两个子链表。寻找链表的中点可以…...

【数据结构初阶第十二节】设计循环队列

云边有个稻草人-CSDN博客 必须有为成功付出代价的决心&#xff0c;然后想办法付出这个代价。 还有最后一道关于队列的习题&#xff0c;这题有点难&#xff0c;准备好迎接挑战吧&#xff01; 目录 1.【题目】 2.实现循环队列推荐用数组&#xff0c;Why? 3.Q1&#xff1a;如…...

基于微信小程序的民宿短租系统设计与实现(ssm论文源码调试讲解)

第4章 系统设计 4.1系统设计的目标 系统设计的目标是满足用户的需求和满足系统实现所需要的所有要求。本系统收集了信息浏览、信息删除、信息添加、信息修改、信息查询为一体[17]。改变了用户民宿短租的方式&#xff0c;提高管理员管理效率以及用户预订的效率。为用户、房主提…...

使用 Jetty 构建 HTTPS 服务入门指南

在互联网安全越来越重要的今天,使用 HTTPS 为 Web 服务提供安全传输成为标准配置。Jetty 是一个高性能、易用且功能丰富的开源 Java HTTP 服务器和 Servlet 容器,能够轻松实现 HTTPS 支持。本文将结合代码实例,引导您快速搭建一个基于 Jetty 的 HTTPS 服务。 一、Jetty 简介…...

数据结构《图》

数据结构《图论》 图的性质 一、无向图&#xff08;Undirected Graph&#xff09; 定义 由一组顶点&#xff08;Vertex&#xff09;和一组无向边&#xff08;Edge&#xff09;构成。 每条无向边用一条无方向的线段连接两个顶点&#xff0c;记为 ( (u, v) )&#xff0c;其中…...

用Chrome Recorder轻松完成自动化测试脚本录制

前言 入门自动化测试,录制回放通常是小白测试首先用到的功能。而录制回放工具也一直是各大Web自动化测试必然会着重提供的一块功能。 早期WinRunner、QTP这样的工具,自动化测试可以说是围绕录制回放开展的。近年像Selenium也提供有录制工具 Selenium IDE,Playwright也包含…...

⭐️苹果电脑安装windows10双系统【详细图文步骤保姆级教程】【本教材适用于MAC台式机、笔记本MacBook air和pro】

苹果电脑安装windows10双系统【详细图文步骤保姆级教程】【本教材适用于MAC台式机、笔记本MacBook air和pro】 苹果电脑安装windows10双系统一、准备工作准备项1&#xff1a;U盘作为系统安装盘准备项2&#xff1a;您需要安装的系统镜像 二、启动转换助理步骤1&#xff1a;找到启…...

win10系统上的虚拟机安装麒麟V10系统提示找不到操作系统

目录预览 一、问题描述二、原因分析三、解决方案四、参考链接 一、问题描述 win10系统上的虚拟机安装麒麟V10系统提示找不到操作系统&#xff0c;报错&#xff1a;Operating System not found 二、原因分析 国产系统&#xff0c;需要注意的点&#xff1a; 需要看你的系统类…...

Java 大视界 -- 开源社区对 Java 大数据发展的推动与贡献(91)

&#x1f496;亲爱的朋友们&#xff0c;热烈欢迎来到 青云交的博客&#xff01;能与诸位在此相逢&#xff0c;我倍感荣幸。在这飞速更迭的时代&#xff0c;我们都渴望一方心灵净土&#xff0c;而 我的博客 正是这样温暖的所在。这里为你呈上趣味与实用兼具的知识&#xff0c;也…...

深入浅出C语言内存模型——高阶篇

在C语言编程的征途上&#xff0c;内存管理无疑是最具挑战性的部分之一。今天&#xff0c;我们将深入探讨C语言的内存模型&#xff0c;剖析其高级特性&#xff0c;并通过一系列案例&#xff0c;助你成为内存管理的佼佼者。本文为高阶篇&#xff0c;适合已经有一定C语言基础的读者…...

AI 百炼成神:逻辑回归, 垃圾邮件分类

第二个项目:逻辑回归垃圾邮件分类 项目代码下载地址:https://download.csdn.net/download/m0_56366541/90398247 项目目标 学习逻辑回归的基本概念。使用逻辑回归算法来实现垃圾邮件的分类。理解如何处理文本数据以及如何评估分类模型的性能。项目步骤 准备数据集 我们将使…...

MybatisPlus-扩展功能

逻辑删除乐观锁 MyBatisPlus从入门到精通-3&#xff08;含mp代码生成器&#xff09; Db静态工具类 Spring依赖循环问题 代码生成器 MybatisPlus代码生成器 枚举处理器 我们这里用int来存储状态 需要注解&#xff0c;很不灵活 希望用枚举类来代替这个Integer 这样的话我…...

《计算机视觉》——角点检测和特征提取sift

角点检测 角点的定义&#xff1a; 从直观上理解&#xff0c;角点是图像中两条或多条边缘的交点&#xff0c;在图像中表现为局部区域内的灰度变化较为剧烈的点。在数学和计算机视觉中&#xff0c;角点可以被定义为在两个或多个方向上具有显著变化的点。比如在一幅建筑物的图像…...

DeepSeek模型快速部署教程-搭建自己的DeepSeek

前言&#xff1a;在人工智能技术飞速发展的今天&#xff0c;深度学习模型已成为推动各行各业智能化转型的核心驱动力。DeepSeek 作为一款领先的 AI 模型&#xff0c;凭借其高效的性能和灵活的部署方式&#xff0c;受到了广泛关注。无论是自然语言处理、图像识别&#xff0c;还是…...

Swift CChar元祖转String

iOS有些API是调用C函数&#xff0c;Swift端获得的数据是CChar元祖&#xff0c;需要转成String方便使用&#xff0c;下面的代码以获取手机型号为例 方式一 var systemInfo utsname() uname(&systemInfo) let deviceModel withUnsafePointer(to: systemInfo.machine) { …...

【刷题】leetcode

题目 现有 s e r v e r N u m 台服务器,编号依次为 1 − s e r v e r...

别再乱复位了!嵌入式开发中NOR Flash擦除中断的实战避坑指南

嵌入式开发中NOR Flash擦除中断的实战避坑指南 在嵌入式系统开发中&#xff0c;NOR Flash因其高可靠性和快速随机读取特性&#xff0c;常被用于存储启动代码、操作系统内核等关键数据。然而&#xff0c;当系统遭遇意外复位或电源故障时&#xff0c;正在进行的Flash擦除操作可能…...

告别NMS!RT-DETR实战:用3090显卡5分钟跑通端到端目标检测(附完整代码)

RT-DETR实战&#xff1a;5分钟搭建无需NMS的高效目标检测系统 当你在深夜调试YOLO模型的NMS参数时&#xff0c;是否想过——为什么2023年了&#xff0c;我们还要手动调整这些上世纪90年代就存在的后处理逻辑&#xff1f;上周我在处理一个密集货架检测项目时&#xff0c;NMS导致…...

Qt操作Excel踩坑实录:QAxObject内存泄漏、WPS兼容性与性能优化心得

Qt操作Excel实战避坑指南&#xff1a;内存管理、兼容性与性能优化深度解析 1. QAxObject内存泄漏的精准防控 在Qt框架下操作Excel文档时&#xff0c;QAxObject作为COM接口的封装类&#xff0c;其内存管理机制与传统Qt对象存在显著差异。许多开发者在使用过程中常因忽略对象生命…...

CentOS 7下Qt 5.14.2保姆级安装教程:从.run包到菜单栏图标(含libGL报错解决)

CentOS 7下Qt 5.14.2图形化安装全流程实战指南 在Linux环境下进行Qt开发&#xff0c;CentOS 7依然是许多企业和开发者的首选系统。不同于源码编译的复杂过程&#xff0c;使用官方.run安装包能够快速搭建稳定的开发环境。本文将手把手带你完成从安装包准备到菜单集成的完整流程&…...

RK3588内核模块交叉编译避坑指南:解决‘-mcmodel=kernel’等编译错误

RK3588内核模块交叉编译实战&#xff1a;从错误解析到驱动适配全攻略 当你在RK3588开发板上尝试编译一个简单的WiFi驱动模块时&#xff0c;终端突然抛出"-mcmodelkernel参数不被识别"的错误信息——这可能是许多嵌入式开发者都经历过的"顿挫时刻"。不同于x…...

七种主流网盘直链解析技术深度解析:开源方案的技术实现与架构设计

七种主流网盘直链解析技术深度解析&#xff1a;开源方案的技术实现与架构设计 【免费下载链接】Online-disk-direct-link-download-assistant 一个基于 JavaScript 的网盘文件下载地址获取工具。基于【网盘直链下载助手】修改 &#xff0c;支持 百度网盘 / 阿里云盘 / 中国移动…...

3步告别激活烦恼:KMS智能激活工具完全指南

3步告别激活烦恼&#xff1a;KMS智能激活工具完全指南 【免费下载链接】KMS_VL_ALL_AIO Smart Activation Script 项目地址: https://gitcode.com/gh_mirrors/km/KMS_VL_ALL_AIO 还在为Windows系统频繁弹出激活提示而烦恼吗&#xff1f;Office文档突然变成只读模式让你束…...

从两个“低级错误”反思Verilog代码规范:你的工程里可能也有这些隐患

从两个“低级错误”反思Verilog代码规范&#xff1a;你的工程里可能也有这些隐患 在数字电路设计领域&#xff0c;Verilog作为主流硬件描述语言&#xff0c;其代码质量直接影响着项目的成败。然而&#xff0c;许多团队在开发过程中常常陷入"救火式"调试的困境——花费…...

【花雕学编程】Arduino BLDC 之机器人动态权重分配的混合控制器

基于 Arduino 平台结合 BLDC&#xff08;无刷直流电机&#xff09;的机器人动态权重分配混合控制器&#xff0c;代表了移动机器人控制策略从“单一目标优化”向“多目标动态平衡”的进阶。该系统不再固守固定的控制参数&#xff0c;而是根据机器人的实时状态&#xff08;如速度…...

Java常见报错处理技术文章大纲

一、引言 Java错误处理的重要性:解释错误对程序稳定性的影响。 错误分类概述:简要介绍编译时错误、运行时错误和逻辑错误。 文章目标:帮助开发者快速识别、诊断和解决常见问题。 二、编译时错误处理 常见类型与原因: 语法错误(如缺少分号或括号)。 类型不匹配(如赋值给错…...