分布式锁(Distributed Lock)介绍(基于数据库(mysql);基于缓存(redis);基于ZooKeeper等分布式协调服务)

文章目录

  • 分布式锁介绍
    • 1. 分布式锁的工作原理
      • 1.1 锁的基本概念
      • 1.2 工作机制
    • 2. 分布式锁的实现方式
      • 2.1 基于数据库的分布式锁
      • 2.2 基于Redis的分布式锁
      • 2.3 基于ZooKeeper的分布式锁
    • 3. 分布式锁的挑战
      • 3.1 死锁问题
      • 3.2 锁粒度问题
        • 粗粒度锁
        • 细粒度锁
        • 锁粒度的选择
      • 3.3 锁的公平性问题
        • 1. 使用中心化的服务
        • 2. 时间戳排序
        • 3. 队列机制
    • 4. 总结

分布式锁介绍

分布式锁是一种在分布式环境下,对共享资源提供访问限制的方法。其主要目的是防止多个进程同时操作同一资源,造成数据的不一致性。分布式锁通过在多个节点上运行的进程之间引入协调机制,来解决这个问题。

1. 分布式锁的工作原理

1.1 锁的基本概念

在开始之前,先简单了解一下锁的基本概念。锁是一种保护共享资源不被并发操作破坏的技术。当一个进程想要访问共享资源时,必须首先获取锁。如果其他进程已经持有锁,那么该进程必须等待,直到锁被释放。

1.2 工作机制

在分布式系统中,分布式锁的实现比单机环境更为复杂。因为在分布式环境下,不同的进程可能在不同的物理机器上运行。因此,我们需要一种跨越多台机器,能够实现共享状态的方式来实现分布式锁。常见的实现方式包括基于数据库、基于缓存(如Redis)或者是基于ZooKeeper等系统。

2. 分布式锁的实现方式

接下来,将详细介绍一些常见的分布式锁实现方式。

2.1 基于数据库的分布式锁

这种实现方式通常是在数据库中创建一个表,用于存储锁信息。当一个进程想要获取锁时,会在该表中插入一条记录。如果插入成功,则表示获取锁成功;如果因为主键冲突等原因插入失败,则表示获取锁失败。

CREATE TABLE `Locks` (`key` varchar(64) NOT NULL,PRIMARY KEY (`key`)
) ENGINE=InnoDB;

2.2 基于Redis的分布式锁

Redis具有很好的性能和原子操作支持,因此也常被用于实现分布式锁。通过SETNX(Set if Not eXists)命令,我们可以尝试获取一个锁。如果该锁不存在,那么设置成功,获取锁;否则获取失败。

SET resource_name my_random_value NX PX 30000

2.3 基于ZooKeeper的分布式锁

ZooKeeper是一个开源的分布式协调服务,它提供了一种高效且可靠的分布式锁实现方式。通过创建短暂的顺序ZNode节点,可以让多个客户端争抢锁。只有序号最小的客户端才能获得锁。

public void lock() {if (!tryLock()) {waitForLock(waitNode, SESSION_TIMEOUT);lock();}
}

3. 分布式锁的挑战

虽然分布式锁看起来很理想,但在实际使用中还是有许多需要注意的地方。

3.1 死锁问题

死锁是分布式锁可能会遇到的一个问题。如果持有锁的进程在释放锁之前崩溃了,那么其他所有等待获取锁的进程都将永远阻塞。为了解决这个问题,一种常见的方法是设置锁的超时时间。

3.2 锁粒度问题

锁粒度是指在数据库管理系统中,对共享资源加锁时,可以选择的最小单位。它描述了一个锁定对象所占用的数据量大小。锁粒度的大小直接影响到并发控制机制的效率。

粗粒度锁

粗粒度锁,也被称为表级锁,是一种将整个表作为一个锁定对象的策略。当一个事务需要访问某个表中的任何数据时,都需要获取该表的锁。这种策略的优点是实现简单,管理开销较小,因为即使表中有数以百万计的行,也只需要维护一个锁。但是,由于一个事务获得锁后,其他所有事务都无法访问该表,导致并发性能较差。

细粒度锁

细粒度锁,又被称为行级锁,是一种将每一行数据作为一个独立的锁定对象的策略。在这种策略下,如果一个事务需要访问某个表中的某行数据,那么只需要获取该行数据的锁即可。这样可以大大提高并发性能,因为不同的事务可以同时访问表中的不同行。然而,这种策略的缺点是,由于需要为表中的每一行都维护一个锁,因此管理开销较大。

锁粒度的选择

选择适当的锁粒度是一项重要的任务。如果选择过大的锁粒度,可能会限制并发性能;而选择过小的锁粒度,可能会增加锁管理的开销。在实际应用中,需要根据系统的具体需求和环境来选择合适的锁粒度。

3.3 锁的公平性问题

公平性指的是请求锁的顺序应该与获取锁的顺序相同。然而,在实际的分布式环境中,由于网络延迟等因素,实现公平的分布式锁并不容易。

因为网络延迟和节点之间的时间差异,可能会导致请求顺序和获取顺序不同步。但是,这并不意味着无法解决这个问题。以下是几种常见的策略:

1. 使用中心化的服务

例如ZooKeeper、etcd等提供有序的节点特性,可以按照请求顺序排队。当一个进程释放锁时,按照请求锁的顺序,将锁赋予下一个进程。这种方法可以保证公平性,但对于中心化的服务依赖性较高。

public void lock() {if (!tryLock()) {waitForLock(waitNode, SESSION_TIMEOUT);lock();}
}
2. 时间戳排序

每个锁请求都附带一个时间戳,通过比较时间戳来确定获取锁的顺序。这需要所有参与节点的时钟大致同步,否则可能会影响公平性。

def request_lock():timestamp = get_current_time()send_request_to_lock_server(lock_name, timestamp)
3. 队列机制

创建一个全局的请求队列,每次只从队头取出一个请求进行处理,确保了先进先出(FIFO)的公平性。但这种方法可能会由于单点问题导致整个系统性能瓶颈。

Queue<LockRequest> lockQueue = new LinkedList<>();public void requestLock() {LockRequest request = new LockRequest();lockQueue.add(request);
}

虽然这些策略可以提高分布式锁的公平性,但也可能会增加系统的复杂性和开销。在实际应用中,需要根据具体的需求和环境进行权衡。

4. 总结

分布式锁是一种有效的协调在分布式环境中运行的并发进程的机制。它可以帮助我们避免因并发操作而导致的数据不一致性。然而,设计和实现一个可靠、高效且公平的分布式锁是一项具有挑战性的任务。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/660029.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

关于Spring框架的 @Configuration 与@Service 加载顺序哪个先后(某些环境加载是随机的)

很多资料都说Configuration 优先加载&#xff0c;Service后加载&#xff0c;如下图&#xff1a; 本来也是以为 Configuration 优先加载于 Service &#xff0c;那参数处理放在Configuration注入完后&#xff0c;service构建时就可以拿来用的&#xff0c;在我在IDEA的调试时下断…

喜讯 | 经纬恒润整车电子电气测试实验室通过一汽研发总院外部实验室资质认证!

近日&#xff0c;经纬恒润整车电子电气测试实验室成功通过中国一汽研发总院的资质评定&#xff0c;获得外部实验室认可证书。这是继经纬恒润测试实验室获得一汽智能网联开发院车载以太网测试资质认证之后的又一次认可&#xff0c;它将拓宽经纬恒润与红旗新能源及相关零部件供应…

实现可编辑excel

需要花钱买的插件有这个 SpreadJS 要在Vue项目中创建可编辑的Excel页面&#xff0c;你可以使用一些Vue插件和库帮助你实现此功能。以下是一个简单的步骤指导&#xff1a; 安装所需的依赖项&#xff1a; 在你的Vue项目目录下&#xff0c;使用以下命令安装xlsx和vue-xlsx库&…

sqlite 存放json数据

在SQLite中存放和查询JSON数据&#xff0c;你可以使用SQLite内置的JSON支持&#xff08;从SQLite版本3.9.0开始引入的JSON1扩展&#xff0c;以及在后续版本中增强的功能如JSON函数和操作符&#xff09;。下面是如何在SQLite中存放和查询JSON数据的步骤&#xff1a; 创建表格并…

【SparkML实践5】特征转换FeatureTransformers实战scala版

本节介绍了用于处理特征的算法&#xff0c;大致可以分为以下几组&#xff1a; 提取&#xff08;Extraction&#xff09;&#xff1a;从“原始”数据中提取特征。转换&#xff08;Transformation&#xff09;&#xff1a;缩放、转换或修改特征。选择&#xff08;Selection&…

分组密码工作模式

在密码学中&#xff0c;分组密码工作模式可以提供诸如机密性或真实性的信息服务。 基于分组的对称加密算法&#xff08;DES 、AES等&#xff09;只是描述如何根据加密密钥对一段固 定长度&#xff08;块&#xff09;的数据进行加密&#xff0c;对于比较长的数据&#xff0c;分组…

Spring AOP的基本使用

Spring AOP&#xff08;Aspect-Oriented Programming&#xff0c;面向切面编程&#xff09;是Spring框架的一个重要组成部分&#xff0c;它允许开发者在不修改原有代码的基础上&#xff0c;通过动态代理的方式&#xff0c;在程序的执行过程中插入额外的逻辑。这种编程方式可以有…

C++ 预处理器

预处理器是一些指令&#xff0c;指示编译器在实际编译之前所需完成的预处理。 所有的预处理器指令都是以井号&#xff08;#&#xff09;开头&#xff0c;只有空格字符可以出现在预处理指令之前。预处理指令不是 C 语句&#xff0c;所以它们不会以分号&#xff08;;&#xff09…

【Spring Boot 源码学习】BootstrapRegistry 详解

《Spring Boot 源码学习系列》 BootstrapRegistry 详解 一、引言二、往期内容三、主要内容3.1 源码初识3.2 register 方法3.3 registerIfAbsent 方法3.4 isRegistered 方法3.5 getRegisteredInstanceSupplier 方法3.6 addCloseListener 方法3.7 InstanceSupplier 内部接口类3.7…

使用Go的并发模型

Golang提供了强大的并发支持&#xff0c;可以轻松编写高效的并发程序。以下是一些使用Go并发模型的技巧&#xff1a; Goroutine&#xff1a;通过使用goroutine&#xff0c;您可以并发地执行函数或方法&#xff0c;从而充分利用多核处理器的能力。Channel&#xff1a;使用chann…

故障诊断 | 一文解决,GRU门控循环单元故障诊断(Matlab)

文章目录 效果一览文章概述专栏介绍模型描述源码设计参考资料效果一览 文章概述 故障诊断 | 一文解决,GRU门控循环单元故障诊断(Matlab) 专栏介绍 订阅【故障诊断】专栏,不定期更新机器学习和深度学习在故障诊断中的应用;订阅

基于spring boot实现邮箱发送和邮箱验证

目录 一、邮箱发送实现1. 开通邮箱服务2. 添加邮箱依赖3.添加配置4.添加邮箱通用类5. 测试类 二、邮箱验证实现1.添加依赖2. 添加配置3.添加controller4. 测试 项目地址: https://gitee.com/nssnail/springboot-email 一、邮箱发送实现 1. 开通邮箱服务 使用qq邮箱、163邮箱都…

1月无代码资讯 | 两项低代码无代码行业报告相继重磅发布;GitHub Copilot Chat全面开放使用

栏目导读&#xff1a;无代码资讯栏目从全球视角出发&#xff0c;带您了解无代码相关最新资讯。 TOP3 大事件 1、ResearchAndMarkets.com "低代码无代码开发平台市场—— 2018-2028 年全球行业规模、份额、趋势、机遇及预测"报告发布 据雅虎财经近日资讯显示&#xf…

网络层 IP协议(1)

前置知识 主机:配有IP地址,但是不进行路由控制的设备 路由器:既配置了IP地址,又能进行路由控制的设备 节点:主机和路由器的总称 IP协议主要完成的任务就是 地址管理和路由选择 地址管理:使用一套地址体系,将网络设备的地址描述出来 路由选择:一个数据报如何从源地址到目的地址 …

【LVGL源码移植】

LVGL源码移植 ■ LVGL源码移植一&#xff1a;下载LVGL源码二&#xff1a;修改LVGL文件夹1: 将这5个文件&#xff0c;复制到一个新的文件夹2: 简化文件&#xff0c;减少内存消耗&#xff08;去除不必要的文件&#xff09;3: 为了规范化&#xff0c;我们将下列文件进行重命名 三&…

git使用方法(简易版)

一、git使用过程 1.注册git账号&#xff0c;并新建一个仓库&#xff1b; http://t.csdnimg.cn/ePcsx可以参考链接 2.在电脑文件夹中&#xff0c;右键选择 Git Bash Here,输入git init&#xff08;初始化仓库&#xff09;&#xff1b; git init - 初始化仓库。 Git 使用 git …

【Java万花筒】驶入未来:利用Java库构建智能自动驾驶与车联网系统

加速汽车智能化&#xff1a;解析自动驾驶与车联网的Java库应用技巧 前言 随着自动驾驶和车联网技术的发展&#xff0c;开发人员需要强大的工具和资源来构建智能交通系统。本文将介绍几个重要的Java库&#xff0c;包括Autoware、Apollo、OpenXC、CarSync和V2XLib&#xff0c;它…

webassembly003 MINISIT mnist/convert-h5-to-ggml.py

数据结构 # Convert MNIS h5 transformer model to ggml format # # Load the (state_dict) saved model using PyTorch # Iterate over all variables and write them to a binary file. # # For each variable, write the following: # - Number of dimensions (int) # …

张维迎《博弈与社会》多重均衡与制度和文化(1)多重均衡问题

什么是多重均衡 我曾经在课堂上做过这样一个实验&#xff1a;随机选择男女两位同学参加一个选数字的游戏。游戏的基本规则为&#xff1a;每一个同学随机地从1到10十个数字中任意选择5个。如果两人选择的数字没有任何重复的话&#xff0c;则每人可以得到50元&#xff1b;如果两人…

npm install 安装依赖,为什么有时候会修改项目 package-lock.json,怎么解决?

前端开发时经常会接手一个别人创建的项目已经上线了&#xff0c;后期让我来修复缺陷&#xff0c;或者子新增功能。 上来就使用npm install 安装项目依赖&#xff0c;一看package-lock.json文件被自动修改了&#xff0c;可是我也没有修改package.json文件内容啊&#xff0c;不管…