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

快速了解Zookeeper和etcd实现的分布式锁

快速了解Zookeeper和etcd实现的分布式锁

Zookeeper 实现分布式锁
简单来说

Zookeeper 通过创建临时顺序节点来实现分布式锁。客户端尝试创建一个特定路径下的临时顺序节点,创建成功后,检查自己创建的节点是否是该路径下序号最小的节点。若是,则获取锁;否则,监听比自己序号小的前一个节点的删除事件,当前一个节点被删除时,再检查自己是否为最小节点以获取锁。

详细来说
  • 创建节点:客户端连接到 Zookeeper 集群后,在指定的锁节点路径下创建一个临时顺序节点。例如,锁节点路径为 “/locks”,客户端创建的节点可能是 “/locks/lock-00000001” 等类似形式的节点,节点名称中的序号是由 Zookeeper 自动生成的。

  • 获取锁判断:客户端创建节点后,会获取锁节点路径下的所有子节点,并按照节点序号进行排序。然后检查自己创建的节点是否是序号最小的节点。如果是,则表示客户端获取了锁,可以执行相应的业务逻辑。

  • 等待锁:如果客户端创建的节点不是序号最小的节点,那么它会获取比自己序号小的前一个节点,并对该节点设置监听。当监听到前一个节点被删除时,客户端会再次检查自己是否为最小节点。如果是,则获取锁;否则,继续等待并监听前一个节点的变化。

  • 释放锁:当客户端完成业务逻辑后,会删除自己创建的临时顺序节点,从而释放锁。其他等待锁的客户端会收到节点删除的通知,并重新检查自己是否能够获取锁。

etcd 实现分布式锁
简单来说

etcd 使用租约机制和键值对的比较与交换操作来实现分布式锁。客户端通过创建租约获取一个租约 ID,然后使用该租约 ID 创建一个键值对作为锁。获取锁时,通过比较与交换操作判断锁是否可用,若可用则获取锁并设置键值对,否则等待锁释放后再次尝试获取。

详细来说
  • 创建租约:客户端向 etcd 服务器请求创建一个租约,租约有一个过期时间。etcd 服务器会返回一个租约 ID 给客户端。例如,租约 ID 为 “123456”,过期时间为 30 秒。

  • 创建锁键值对:客户端使用获取到的租约 ID 创建一个键值对作为锁。假设锁的键为 “/lock/mylock”,值为租约 ID “123456”。客户端通过 etcd 的 API 发起一个事务操作,在事务中使用比较与交换操作来尝试创建这个键值对。如果键不存在,则创建成功,表示获取锁;如果键已存在,则创建失败,表示锁已被其他客户端获取。

  • 获取锁等待:如果获取锁失败,客户端可以通过监听键的变化来等待锁的释放。当锁的键值对被删除或者租约过期时,客户端会收到通知,然后再次尝试获取锁。

  • 续租和释放锁:在持有锁的过程中,客户端需要定期向 etcd 服务器续租租约,以防止租约过期导致锁被自动释放。当客户端完成业务逻辑后,通过删除锁的键值对来释放锁,同时租约也会被自动撤销。

通过以上方式,Zookeeper 和 etcd 分别实现了分布式锁的功能,以满足分布式系统中对共享资源的互斥访问需求。

Zookeeper 实现分布式锁的优缺点

  • 优点:

    • 高可靠性:Zookeeper 是一个高可用的分布式协调服务,具有良好的容错性和稳定性。只要集群中大部分节点正常运行,Zookeeper 服务就能正常工作。这使得基于 Zookeeper 实现的分布式锁具有较高的可靠性,适用于对一致性要求较高的场景。例如,在金融交易系统中,数据的一致性至关重要,Zookeeper 分布式锁可以确保交易过程中的数据安全和一致性。

    • 强一致性保证:Zookeeper 保证了数据的强一致性,所有客户端看到的数据都是一致的。在分布式锁的场景下,这意味着一旦一个客户端获得了锁,其他客户端能够立即感知到锁的状态变化,避免了数据不一致导致的并发问题。

    • 简单易用:Zookeeper 的 API 相对简单,易于理解和使用。开发人员可以通过简单的代码实现分布式锁的功能,并且 Zookeeper 提供了丰富的事件通知机制,如 Watcher 机制,使得客户端能够实时感知到锁的状态变化,方便进行相应的处理。

    • 支持多种锁模式:可以实现公平锁和非公平锁等多种锁模式。公平锁保证了按照请求的顺序获取锁,避免了某些客户端长时间等待锁的情况;非公平锁则可以提高系统的并发性能,适用于对响应时间要求较高的场景4。

  • 缺点:

    • 性能较低:在创建和释放锁的过程中,需要频繁地与 Zookeeper 服务器进行网络通信,并且 Zookeeper 中创建和删除节点的操作只能由 leader 服务器执行,然后 leader 服务器还需要将数据同步到所有的 follower 机器上,这导致了较高的延迟和性能开销。在高并发的场景下,可能会成为系统的性能瓶颈。

    • 依赖 Zookeeper 集群:如果 Zookeeper 集群出现故障,那么基于 Zookeeper 的分布式锁也将无法正常工作。因此,使用 Zookeeper 实现分布式锁需要保证 Zookeeper 集群的稳定性和可靠性,这增加了系统的运维成本和复杂度。

    • 存在 “惊群” 效应(可优化):在使用 Zookeeper 实现分布式锁时,如果一个客户端释放了锁,所有等待锁的客户端都会收到通知并尝试获取锁,这可能会导致大量的客户端同时竞争锁,从而产生 “惊群” 效应,影响系统的性能4。不过,可以通过使用临时顺序节点等方式对其进行优化4。

Etcd 实现分布式锁的优缺点

  • 优点:

    • 强一致性和高可靠性:Etcd 基于 Raft 算法实现,保证了数据的强一致性和高可靠性。在分布式锁的场景下,这意味着一旦一个客户端获得了锁,其他客户端能够准确地感知到锁的状态变化,避免了数据不一致导致的并发问题。并且,Etcd 的副本机制保证了即使部分节点出现故障,系统仍然能够正常工作2。

    • 高性能:与 Zookeeper 相比,Etcd 在读写性能方面具有一定的优势。它采用了高效的存储引擎和数据结构,能够快速地处理大量的并发请求。在高并发的场景下,Etcd 能够提供较好的性能表现,适用于对性能要求较高的分布式系统。

    • 简单易用:Etcd 提供了简单易用的 API,开发人员可以方便地使用 Etcd 实现分布式锁的功能。同时,Etcd 还支持 HTTP 和 gRPC 等多种通信协议,方便与不同的应用程序进行集成。

    • 支持租约机制:Etcd 支持租约(Lease)机制,可以为锁设置过期时间。当客户端获得锁后,如果在租约到期前没有续租,锁将自动释放,避免了客户端因异常情况导致锁无法释放的问题3。

    • 监听机制高效:Etcd 的监听(Watch)机制非常高效,客户端可以实时监听锁的状态变化,一旦锁被释放,客户端能够立即收到通知并尝试获取锁。相比于轮询等方式,监听机制能够大大减少不必要的网络通信和资源消耗3。

  • 缺点:

    • 学习成本较高:对于不熟悉 Raft 算法和 Etcd 内部原理的开发人员来说,学习和理解 Etcd 的工作原理和 API 可能需要一定的时间和成本。

    • 资源占用较高:Etcd 在存储数据时会占用一定的内存和磁盘空间,并且在高并发的情况下,对系统的资源占用可能会更高。因此,在使用 Etcd 时需要合理地配置资源,以避免对系统性能产生影响。

    • 功能相对单一:与其他分布式存储系统相比,Etcd 的功能相对较为单一,主要用于存储关键数据和实现分布式锁等功能。如果需要更多的功能,可能需要与其他系统进行集成。

应用场景
  • Zookeeper 分布式锁适用场景

    • 对数据一致性要求极高的系统:如金融系统中的资金交易处理。在这种场景下,需要严格保证在同一时刻只有一个交易操作获取到关键资源(如账户余额更新)的锁,Zookeeper 的强一致性能够确保系统数据的准确性和完整性,避免出现数据不一致的情况。

    • 需要实现复杂协调逻辑的分布式系统:例如,在分布式任务调度系统中,当有多个任务需要对共享的任务队列进行操作时,Zookeeper 分布式锁可以用来协调任务对队列资源的访问,保证任务调度的有序性。

    • 有顺序要求的资源访问场景:例如在分布式日志系统中,多个节点可能需要对同一个日志文件进行写入操作,通过 Zookeeper 实现公平锁,可以保证节点按照请求的顺序获取锁,从而有序地进行日志写入,避免日志混乱。

  • etcd 分布式锁适用场景

    • 高并发场景下的资源锁定:例如在大规模的分布式微服务架构中的配置中心,多个微服务实例可能会同时请求更新配置信息。etcd 分布式锁可以快速地处理这些并发请求,通过高性能的读写操作和高效的监听机制,及时获取或释放锁,以确保配置更新的一致性。

    • 需要自动过期释放机制的场景:在云计算环境下,虚拟机或容器可能会因为各种原因(如网络故障、节点故障等)异常退出。如果这些实例获取了某种资源的锁,etcd 的租约机制可以确保当实例异常退出后,锁会自动过期释放,避免资源被长期占用,方便其他实例获取资源。

    • 对性能敏感的分布式存储系统:在分布式存储系统中,当多个客户端同时请求写入同一块存储区域时,etcd 分布式锁可以快速协调资源访问,并且由于其高性能特点,不会对存储系统的整体性能造成太大影响,保证存储操作的高效进行。

区别总结
  • 一致性保证程度

    • Zookeeper:提供强一致性保证,所有客户端看到的数据始终是一致的。这种强一致性是通过 Zookeeper 的 ZAB(Zookeeper Atomic Broadcast)协议实现的,在锁状态发生变化时,能够确保所有节点同步更新状态。

    • etcd:同样提供强一致性保证,基于 Raft 协议实现。Raft 协议保证了在分布式环境下,集群中的节点对于数据的变更能够达成一致,在分布式锁场景下,能保证锁状态的一致性。不过 Zookeeper 和 etcd 的一致性实现细节和协议复杂度有所不同。

  • 性能表现

    • Zookeeper:由于其架构和操作方式(如频繁的节点创建和删除操作需要在集群内同步),性能相对较低,在高并发场景下可能会成为瓶颈。它在处理大量并发锁请求时,延迟较高。

    • etcd:具有较高的读写性能,采用了高效的存储引擎和数据结构,在高并发场景下能够更快速地处理锁的获取和释放操作,性能表现优于 Zookeeper。

  • 实现复杂度和学习成本

    • Zookeeper:API 相对简单,易于理解和使用,通过临时顺序节点等方式实现分布式锁的概念比较直观。但对于 Zookeeper 内部的 ZAB 协议等复杂机制,需要一定的学习成本来深入理解其高可用和一致性的实现原理。

    • etcd:API 也比较简单,但由于其基于 Raft 协议,对于不熟悉 Raft 算法的开发者来说,学习成本相对较高。需要理解 Raft 协议如何保证数据一致性、选举领导者等内部机制,才能更好地使用 etcd 实现分布式锁。

  • 功能特点

    • Zookeeper:支持多种锁模式,如公平锁和非公平锁,可以根据不同的应用场景灵活选择。同时,它的事件通知机制(Watcher)能够方便地让客户端感知锁的状态变化,但可能会出现 “惊群” 效应。

    • etcd:具有租约机制,能够自动释放过期的锁,避免锁资源的浪费和死锁情况。其监听机制也很高效,能够及时通知客户端锁的状态变化,并且在资源占用方面相对 Zookeeper 有一定优势。


http://www.kler.cn/a/398425.html

相关文章:

  • 大数据新视界 -- 大数据大厂之 Impala 性能飞跃:分区修剪优化的应用案例(下)(22 / 30)
  • 如何让手机ip变成动态
  • 【java】链表:判断链表是否成环
  • 【H3C华三 】VRRP与BFD、Track联动配置案例
  • 使用OpenFeign实现HTTP调用的最简单案例
  • 3D意识(3D Awareness)浅析
  • 关于宝塔无法在php中安装fileinfo
  • 信也科技和云杉网络的AI可观测性实践分享
  • 如何将32位数据转化1bit valid,1bit modified,19bit tag, 3 bit index, 8bit数据
  • 海康视频监控云台位置切换与拍照图片下载
  • 应用系统开发(10) 钢轨缺陷的检测系统
  • 十九、Linux网络编程(三)
  • 智能网页内容截图工具:AI助力内容提取与可视化
  • 3D Gaussian Splatting的全面理解
  • vue2+3 —— Day5/6
  • 金融行业国产数据库容灾建设五大难点及解决方案
  • Web3D 与 AI 的结合重塑虚拟世界与智能应用
  • mysql 示例验证demo
  • 多目标优化算法:多目标红嘴蓝鹊优化算法(MORBMO)求解ZDT1、ZDT2、ZDT3、ZDT4、ZDT6,提供完整MATLAB代码
  • 卡尔曼滤波器
  • 调用门提权
  • 两个方法,取消excel数据隐藏
  • 深度学习面试题三
  • C++《类和对象中》:拷贝构造和赋值重载 + 运算符重载详解
  • DimensionX 部署笔记
  • 关于mysql中的锁