SpringBoot中基于MongoDB的findAndModify原子操作实现分布式锁原理详解

❃博主首页 : 「码到三十五」 ,同名公众号 :「码到三十五」,wx号 : 「liwu0213」
☠博主专栏 : <mysql高手> <elasticsearch高手> <源码解读> <java核心> <面试攻关>
♝博主的话 : 搬的每块砖,皆为峰峦之基;公众号搜索「码到三十五」关注这个爱发技术干货的coder,一起筑基

分布式系统中,分布式锁是一种常用的同步机制,通过MongoDB提供的findAndModify原子操作,可以有效地实现分布式锁的功能。

文章目录

    • 一、MongoDB的锁机制
    • 二、分布式锁的需求
    • 三、基于MongoDB的分布式锁实现原理
      • 1. 锁集合的创建
      • 2. 尝试获取锁
      • 3. 锁的重入和超时
      • 4. 释放锁
      • MongoDB findAndModify原理
    • 四、Spring Boot中简单实现
        • 1. 定义锁文档
        • 2. 实现锁服务
        • 3. 使用锁服务
    • 五、注意

一、MongoDB的锁机制

MongoDB的锁机制主要用于保护数据的一致性和正确性。当多个客户端同时对同一文档进行操作时,MongoDB通过锁机制来确保每个操作的顺序和结果都是正确的。锁机制通过对文档进行加锁来实现,包括读锁和写锁。读锁允许多个客户端同时读取文档,但写锁则是互斥的,即同一时间只能有一个客户端持有写锁。

findAndModify是MongoDB提供的一个非常强大的命令,它允许你同时执行查询和更新操作,并且这个操作是原子的。这意味着在findAndModify执行期间,没有其他客户端可以修改被查询的文档,直到该命令完成。这个特性使其成为实现分布式锁的理想选择。

二、分布式锁的需求

在分布式系统中,分布式锁需要满足以下几个基本要求:

  1. 互斥性:在任意时刻,只有一个客户端能够持有锁。
  2. 不会死锁:客户端在持有锁期间如果崩溃或断开连接,锁必须能够被释放,以防止死锁。
  3. 容错性:在分布式环境下,部分节点或网络故障不应影响锁的正常工作。
  4. 高性能:锁的获取和释放操作应该尽可能快,以减少对系统性能的影响。

三、基于MongoDB的分布式锁实现原理

1. 锁集合的创建

首先,在MongoDB中创建一个专门的集合(如locks)来存储锁信息。每个锁由一个文档表示,文档中包含了锁的关键信息,如锁名(lockName)、持有者(holder)、锁定时间(lockedAt)、过期时间(expiresAt)等。

2. 尝试获取锁

当客户端需要获取锁时,它执行以下步骤:

  • 使用findAndModify命令查询locks集合中的对应锁文档。
  • 查询条件包括锁名和当前持有者为空(表示锁未被占用)且当前时间小于过期时间(如果存在过期时间字段)。
  • 更新操作设置持有者为当前客户端的标识,设置锁定时间,并可选地设置过期时间。
  • 如果findAndModify命令成功更新了文档,则表示客户端成功获取了锁;如果更新失败(因为其他客户端已经设置了持有者或已过期时间已过),则表示锁已被占用或已过期。

3. 锁的重入和超时

  • 重入性:可以通过在文档中增加一个重入计数器来实现锁的重入性。当客户端尝试重新获取已被自己持有的锁时,重入计数器增加。
  • 超时机制:设置过期时间(expiresAt)来防止客户端在持有锁期间崩溃而无法释放锁。当过期时间到达时,其他客户端可以清除该锁(通过检查并更新expiresAtholder字段)。

4. 释放锁

当客户端完成操作后,它执行以下步骤来释放锁:

  • 再次使用findAndModify命令查询并更新locks集合中的对应锁文档。
  • 更新操作将文档的持有者设置为空(或某个特定的释放标识),并可能更新锁定时间或重入计数器(如果实现了重入性)。
  • 如果需要,还可以更新过期时间字段以清除过期的锁。

在分布式系统中,实现锁机制是一项关键任务,用于控制对共享资源的访问,防止数据不一致。MongoDB的findAndModify命令是一种强大的原子操作,可以用于实现简单的分布式锁。下面详细介绍其原理,并在Spring Boot环境中给出一个实现案例。

MongoDB findAndModify原理

findAndModify是MongoDB中的一个命令,它用于查找并更新一个文档,这个操作是原子的,意味着在查找和更新文档期间,不会有其他操作可以修改这个文档。利用这个特性,我们可以创建一个简单的分布式锁:

  1. 锁定机制

    • 在数据库中创建一个集合(例如locks),每个锁由一个文档表示。
    • 每个文档包含锁的关键信息,如锁名(lockName)、持有者(holder)、锁定时间(lockedAt)等。
    • 当需要锁定某个资源时,使用findAndModify尝试更新集合中的一个文档,设置holderlockedAt。如果更新成功,则表示获得了锁;如果失败(例如,因为其他客户端已经设置了holder),则表示锁已被占用。
  2. 释放机制

    • 持有锁的客户端在完成操作后,需要释放锁。这通常通过另一个findAndModify操作来完成,将文档的holder设置为null或某个特定的释放标识。

四、Spring Boot中简单实现

Spring Boot中可以使用Spring Data MongoDB与MongoDB的交互。

1. 定义锁文档
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;@Document(collection = "locks")
public class Lock {@Idprivate String id;private String lockName;private String holder;private Date lockedAt;// Getters and Setters
}
2. 实现锁服务
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.FindAndModifyOptions;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Service;@Service
public class LockService {@Autowiredprivate MongoTemplate mongoTemplate;public boolean tryLock(String lockName, String clientId) {Query query = new Query();query.addCriteria(Criteria.where("lockName").is(lockName).and("holder").isNull());Update update = new Update();update.set("holder", clientId);update.set("lockedAt", new Date());FindAndModifyOptions options = new FindAndModifyOptions();options.returnNew(true);Lock lock = mongoTemplate.findAndModify(query, update, options, Lock.class);return lock != null && lock.getHolder().equals(clientId);}public void releaseLock(String lockName, String clientId) {Query query = new Query();query.addCriteria(Criteria.where("lockName").is(lockName).and("holder").is(clientId));Update update = new Update();update.set("holder", null);mongoTemplate.findAndModify(query, update, Lock.class);}
}
3. 使用锁服务

在服务层或控制器中,注入LockService并调用tryLockreleaseLock方法来控制对共享资源的访问。

五、注意

  • 锁的粒度:根据实际需求选择合适的锁粒度,避免过细或过粗的锁粒度导致的性能问题或资源竞争。
  • 锁的过期时间:合理设置锁的过期时间,以确保在客户端崩溃或其他异常情况下能够释放锁。
  • 网络延迟和分区:在分布式系统中,网络延迟和分区问题可能会导致findAndModify操作的延迟或失败。需要考虑这些因素对锁的性能和可靠性的影响。

关注公众号[码到三十五]获取更多技术干货 !

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

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

相关文章

计算机网络技术专业SDN(软件定义网络)实训室解决方案

一、前言 随着信息技术的飞速发展&#xff0c;网络架构正经历着前所未有的变革&#xff0c;其中软件定义网络&#xff08;SDN, Software-Defined Networking&#xff09;作为未来网络的核心技术之一&#xff0c;正逐步成为计算机网络技术专业教学与科研的重要方向。唯众&#…

Openwrt 安装 AX210 无线网卡

安装 TTYD 我安装的是官方原版的 Openwrt&#xff0c;首先需要安装 YYTD 来从网页控制 Openwrt。 安装驱动 参考这个链接&#xff0c;跟着做。 iwlwifi-firmware-ax210 我买设备技术提供代码如下&#xff0c;但是没有安装 成功&#xff0c;中间报错。 opkg update opkg i…

Vue(十一)默认插槽、具名插槽、作用域插槽

文章目录 一、需求二、插槽1. 默认插槽2. 具名插槽3. 作用域插槽 一、需求 有三个Category组件&#xff0c;展示不同的内容。 需求&#xff1a;美食模块需要展示图片&#xff0c;游戏模块还是文字&#xff0c;电影模块展示预告片。 <!--App组件--> <template>&l…

一.海量数据实时分析-Doris入门和安装

前言 停了一个月又开始写文章啦&#xff0c;因为公司数据量达到了几十亿&#xff0c;老板需要做实时数据分析&#xff0c;报表看板。这么大的数据量比较好的选择是使用Doris来做&#xff0c;他可以脱离hadoop生态独立使用所以大受企业喜爱&#xff0c;也因为如此就有了这个系列…

springboot学习11 (菜品缓存redis)

缓存逻辑分析 目的&#xff1a;减轻数据库压力每个分类下的菜品保存一份缓存数据数据库中菜品数据有变更时清理缓存数据 keyvaluedish_1string(...)dish_2string(...)dish_3string(...) GetMapping("/list")ApiOperation("根据分类id查询菜品")public Res…

敏捷需求管理,推动敏捷项目成功——Leangoo领歌敏捷工具

在敏捷项目管理中&#xff0c;需求管理是决定项目成功的关键环节。准确捕捉和高效管理需求&#xff0c;不仅能避免项目偏航&#xff0c;还能确保最终交付的产品与客户预期高度契合。Leangoo领歌敏捷工具&#xff0c;正是为此而生&#xff0c;助力团队轻松实现需求管理的每一步。…

分贝通助力元气森林企业支出一体化降本提效

凭借着“0糖0脂0卡”这句广告语,元气森林几乎是一锤砸中了年轻消费者的内心,让“好喝不胖”深入人心,成为了国内饮品消费的新风向标。如果我们从近两年的快消饮品中选出几款深受消费者喜爱的“国货品牌”的话,相信「元气森林」一定上榜。 元气森林成立于2016年,旗下拥有元气森林…

C语言典型例题59

《C程序设计教程&#xff08;第四版&#xff09;——谭浩强》 题目&#xff1a; 例题4.11 译密码。为使电文保密&#xff0c;往往按一定规律将其转换为密码&#xff0c;收报人再按约定的规律将其译回原文。 例如&#xff0c;可以按以下规律将电文变为密码&#xff1a; 将字母A…

Harbor部署docker私人仓库

1、新建虚拟机rhel9 2、配置网络 #修改内核参数使网卡名称为ethxxx grubby --update-kernel ALL --args net.ifnames0reboot #配置网络 vim /etc/NetworkManager/system-connections/eth0.connection 内容为&#xff1a;[connection] ideth0 typeethernet interface-nameeth0…

储能电站变流器设计与仿真研究(文章复现matlab)

为了有效解决交流子网与直流子网间的功率传输&#xff0c; 降低电流谐波&#xff0c; 基于三相电压源型变流器及变流器的控制方法&#xff0c; 在 MATLAB R2018a 环境下搭建了储能变流器的整体仿真模型。 电路主要由三相电网、 三相 PWM 变流器、Buck/Boost 变换器和蓄电池构成…

使用Dify搭建企业知识库聊天机器人

本文简介 在当今数字化时代&#xff0c;企业知识库的建设和维护对于提升工作效率和服务质量至关重要。AI聊天机器人作为知识库的交互界面&#xff0c;可以提供24/7的即时服务。 本文将介绍如何使用 Dify 这一工具快速搭建企业知识库聊天机器人&#xff0c;它可以当你企业的职…

sqli-libs第四关详解

首先判断是数字型注入还是字符型注入 正常显示&#xff0c;说明是字符型注入&#xff0c;那么尝试单引号闭合 还是正常显示&#xff0c;尝试双引号闭合 有报错信息&#xff0c;含有括号&#xff0c;这时就应该想到&#xff0c;sql代码是("$id")这样写的了。直接采取闭…

HTML5有格调的个人介绍网站源码

文章目录 1.设计来源1.1 主界面1.2 个人信息界面1.3 项目统计界面1.4 我的相册界面1.5 朋友评价界面1.6 保持联系界面 2.效果和源码2.1 动态效果2.2 源代码 源码下载万套模板&#xff0c;程序开发&#xff0c;在线开发&#xff0c;在线沟通 作者&#xff1a;xcLeigh 文章地址&a…

第L2周:机器学习-线性回归

&#x1f368; 本文为&#x1f517;365天深度学习训练营 中的学习记录博客&#x1f356; 原作者&#xff1a;K同学啊 目标&#xff1a; 学习简单线性回归模型和多元线性回归模型通过代码实现&#xff1a;通过鸢尾花花瓣长度预测花瓣宽度 具体实现&#xff1a; &#xff08;一&…

【JS】事件捕获和事件冒泡的区别

事件捕获和事件冒泡是指在 DOM 树中处理事件时的两种不同的传播方式。它们之间的主要区别在于事件传播的方向和顺序&#xff1a; 事件捕获&#xff08;Capture&#xff09; 方向&#xff1a; 从最外层的祖先元素向目标元素传播。顺序&#xff1a; 事件首先从最外层的祖先元素…

随机化 bbr probebw cycle phase

常打磨常新&#xff0c;bbr 和 inflight 守恒算法的模型和仿真也在不断优化。 再次给出 bbr 模型&#xff0c;这次修改了 d x d t \dfrac{dx}{dt} dtdx​ 的表达式&#xff0c;由 g 2 ⋅ x ⋅ r m i n g_2\cdot x\cdot r_{min} g2​⋅x⋅rmin​计算。同时加入了微观建模 pro…

5.注册中心的其他实现-Nacos

文章目录 1.Nacos简介2.Nacos的安装2.1Nacos Windows本地启动不成功&#xff1f;2.2Linux环境下载并启动 3. Nacos的使用4.Nacos的负载均衡5.Nacos 健康检查6.Nacos 环境隔离7.Nacos 配置中心7.1为什么需要配置中心7.2 Nacos配置中心使用7.3 Data id7.4Nacos 上Linux部署服务7.…

XSS LABS - Level 13 过关思路

关注这个靶场的其他相关笔记&#xff1a;XSS - LABS —— 靶场笔记合集-CSDN博客 0x01&#xff1a;过关流程 进入靶场&#xff0c;老样子&#xff0c;右击&#xff0c;查看页面源码&#xff0c;找找不同&#xff1a; 可以看到&#xff0c;本关又多了一个新字段 t_cook&#xf…

#C++ 笔记二

四、运算符重载 1.友元 1.1 概念 类实现了数据的隐藏和封装&#xff0c;类的数据成员一般定义为私有成员&#xff0c;仅能通过类的公有成员函数才能进行读写。 如果数据成员定义成公共的&#xff0c;则又破坏了封装性。但是在某些情况下&#xff0c;需要频繁的读写数据成员…

【Transformer】基本概述

文章目录 提出背景核心思想—注意力机制流程解析参考资料 提出背景 在Transformer模型出现之前&#xff0c;循环神经网络&#xff08;RNN&#xff09;及其变体&#xff0c;如长短期记忆网络&#xff08;LSTM&#xff09;和门控循环单元&#xff08;GRU&#xff09;&#xff0c;…