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

本文主要是介绍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操作的延迟或失败。需要考虑这些因素对锁的性能和可靠性的影响。

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

这篇关于SpringBoot中基于MongoDB的findAndModify原子操作实现分布式锁原理详解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1132017

相关文章

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权,允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true (Spring security默认会带有ROLE_前缀),去

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类,它们之间的依赖,构建起了整个框架。想要理解整个架构,最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文(security context)的信息。当前操作的用户是谁,该用户是否已经被认证,他拥有哪些角色权限…这些都被保

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

深入探索协同过滤:从原理到推荐模块案例

文章目录 前言一、协同过滤1. 基于用户的协同过滤(UserCF)2. 基于物品的协同过滤(ItemCF)3. 相似度计算方法 二、相似度计算方法1. 欧氏距离2. 皮尔逊相关系数3. 杰卡德相似系数4. 余弦相似度 三、推荐模块案例1.基于文章的协同过滤推荐功能2.基于用户的协同过滤推荐功能 前言     在信息过载的时代,推荐系统成为连接用户与内容的桥梁。本文聚焦于