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

全面解析锁服务设计：内存锁、数据库锁与分布式锁的选择与实现

news 来源：原创 2025/6/8 13:33:48

在构建分布式系统时，锁服务通常用于控制多个线程或进程对共享资源的访问。为了灵活适配不同的锁实现方式，我们可以设计一个基础的锁服务接口，然后根据需求提供不同的实现。例如，内存锁、数据库锁和分布式锁。

1. 锁服务基础接口设计

锁服务的基础接口需要定义一些基本操作，如锁的获取、释放等。我们可以通过一个统一的接口来定义这些操作，后续可以根据具体场景实现不同的锁服务。

锁服务基础接口 `LockService`

public interface LockService {/*** 获取锁** @param key 锁的标识* @return 是否成功获取锁*/boolean lock(String key);/*** 释放锁** @param key 锁的标识* @return 是否成功释放锁*/boolean unlock(String key);/*** 判断是否已经获取了锁** @param key 锁的标识* @return 是否已经获取锁*/boolean isLocked(String key);
}

LockService 接口定义了三个核心方法：

lock(String key)：获取锁，如果锁被其他线程或进程占用，则返回 false。
unlock(String key)：释放锁，将锁标记为可用。
isLocked(String key)：判断是否已经有线程或进程占用了该锁。

2. 不同实现方式的锁服务

根据不同的需求，下面展示三种常见的锁服务实现：内存锁、数据库锁和分布式锁。

2.1 内存锁实现

内存锁适用于单机环境，性能较高。我们可以使用 ReentrantLock 来实现内存锁。

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.HashMap;
import java.util.Map;public class InMemoryLockService implements LockService {private final Map<String, Lock> lockMap = new HashMap<>();private synchronized Lock getLock(String key) {if (!lockMap.containsKey(key)) {lockMap.put(key, new ReentrantLock());}return lockMap.get(key);}@Overridepublic boolean lock(String key) {Lock lock = getLock(key);lock.lock();return true;}@Overridepublic boolean unlock(String key) {Lock lock = getLock(key);lock.unlock();return true;}@Overridepublic boolean isLocked(String key) {Lock lock = getLock(key);return lock.tryLock();}
}

2.2 数据库锁实现

数据库锁适用于需要跨多个进程或系统的分布式环境。这里我们使用 SELECT FOR UPDATE 来确保对某个数据行的唯一访问。

import java.sql.*;public class DbLockService implements LockService {private Connection connection;public DbLockService(Connection connection) {this.connection = connection;}@Overridepublic boolean lock(String key) {try {connection.setAutoCommit(false);String query = "SELECT * FROM locks WHERE lock_key = ? FOR UPDATE";PreparedStatement stmt = connection.prepareStatement(query);stmt.setString(1, key);ResultSet rs = stmt.executeQuery();if (!rs.next()) {String insertQuery = "INSERT INTO locks (lock_key, locked, lock_time) VALUES (?, TRUE, NOW())";PreparedStatement insertStmt = connection.prepareStatement(insertQuery);insertStmt.setString(1, key);insertStmt.executeUpdate();} else {boolean isLocked = rs.getBoolean("locked");if (isLocked) {connection.rollback();return false;}String updateQuery = "UPDATE locks SET locked = TRUE, lock_time = NOW() WHERE lock_key = ?";PreparedStatement updateStmt = connection.prepareStatement(updateQuery);updateStmt.setString(1, key);updateStmt.executeUpdate();}connection.commit();return true;} catch (SQLException e) {try {connection.rollback();} catch (SQLException ex) {ex.printStackTrace();}e.printStackTrace();return false;}}@Overridepublic boolean unlock(String key) {try {String updateQuery = "UPDATE locks SET locked = FALSE WHERE lock_key = ?";PreparedStatement updateStmt = connection.prepareStatement(updateQuery);updateStmt.setString(1, key);updateStmt.executeUpdate();connection.commit();return true;} catch (SQLException e) {e.printStackTrace();return false;}}@Overridepublic boolean isLocked(String key) {try {String query = "SELECT locked FROM locks WHERE lock_key = ?";PreparedStatement stmt = connection.prepareStatement(query);stmt.setString(1, key);ResultSet rs = stmt.executeQuery();return rs.next() && rs.getBoolean("locked");} catch (SQLException e) {e.printStackTrace();return false;}}
}

2.3 分布式锁实现（以 Redis 为例）

Redis 是一种常见的分布式锁实现工具，适用于跨多个机器和进程的锁控制。

import redis.clients.jedis.Jedis;public class RedisLockService implements LockService {private Jedis jedis;public RedisLockService(Jedis jedis) {this.jedis = jedis;}@Overridepublic boolean lock(String key) {String result = jedis.set(key, "LOCKED", "NX", "EX", 60); // 设置键值对，NX 表示只有在 key 不存在时才会设置，EX 表示设置过期时间return "OK".equals(result);}@Overridepublic boolean unlock(String key) {jedis.del(key);return true;}@Overridepublic boolean isLocked(String key) {return jedis.exists(key);}
}

2.4 使用场景对比

实现方式	场景	优点	缺点
内存锁	单机环境	高性能，简单实现	只能在单机环境中使用，不适合分布式
数据库锁	分布式数据库	保证数据一致性，适用于跨多个进程的场景	性能较低，依赖数据库，增加负载
分布式锁 (Redis)	分布式系统	支持跨进程和跨机器，具有高可用性	依赖 Redis 等中间件，可能增加延迟

通过实现 LockService 接口，可以统一管理不同类型的锁服务。对于单机应用，内存锁能够提供最好的性能；对于需要跨进程或分布式环境的系统，数据库锁和 Redis 等分布式锁则提供了更好的解决方案。通过将锁服务封装成接口，可以灵活选择适合的实现方式，并且能够在未来需要时轻松地切换实现，保证了系统的扩展性和灵活性。

在实际项目中，选择合适的锁实现应考虑系统的性能需求、可靠性、可扩展性以及维护成本等因素。

全面解析锁服务设计：内存锁、数据库锁与分布式锁的选择与实现

在构建分布式系统时，锁服务通常用于控制多个线程或进程对共享资源的访问。为了灵活适配不同的锁实现方式，我们可以设计一个基础的锁服务接口，然后根据需求提供不同的实现。例如，内存锁、数据库锁和分布式锁。 1. 锁服务基础接口设…...

编程日记 2025/6/3 14:07:54

jenkins-系统配置概述

一. 引文： Jenkins除了强大的功能插件实现的持续交付集成外， 本身也是有一些比较重要的可配项。接下来我们来看一看。配置入口: 系统管理-->系统设置二. 基础配置： 1.主目录(home directory): Jenkins所有的数据文件存放路径(可通过…...

编程日记 2025/6/3 14:06:50

《数据思维》之数据可视化_读书笔记

文章目录系列文章目录前言一、pandas是什么？二、使用步骤 1.引入库2.读入数据总结前言数据之道，路漫漫其修远兮，吾将上下而求索。一、数据可视化最基础的数据可视化方法就是统计图。一个好的统计图应该满足四个标准：准确、有…...

编程日记 2025/6/3 14:07:22

kafka消费堆积问题探索

背景我们的商城项目用PHP写的，原本写日志方案用的是PHP的方案，但是，这个方案导致资源消耗一直降不下来，使用了20个CPU。后面考虑使用通过kafka的方案写日志，商城中把产生的日志丢到kafka中，在以go写的项目…...

编程日记 2025/6/3 11:02:07

一文掌握Docker

目录 1.快速入门 1.1.部署MySQL 1.2.命令解读 2.Docker基础 2.1.常见命令 2.1.1.命令介绍 2.1.2.演示 2.1.3.命令别名 2.2.数据卷 2.2.1.什么是数据卷 2.2.2.数据卷命令 2.2.3.挂载本地目录或文件 2.3.镜像 2.3.1.镜像结构 2.3.2.Dockerfile构建镜像 2.3.3.构建…...

编程日记 2025/6/3 3:20:17

慧集通（DataLinkX）iPaaS集成平台-系统管理之UI库管理、流程模板

UI库管理 UI库管理分为平台级和自建两种，其中平台级就是慧集通平台自己内置的一些ui库所有客户均可调用，自建则是平台支持使用者自己根据规则自己新增对应的UI库。具体界面如下： 自建UI库新增界面： 注：平台级UI库不支…...

编程日记 2025/6/3 11:04:18

【学习笔记】Macbook管理多个不同的Python版本

在MacBook上管理不同项目的不同Python版本，可以使用多种方法。以下是一些常见的方法： 1. 使用 pyenv pyenv 是一个非常流行的工具，可以让你轻松安装和切换多个Python版本。以下是安装和使用 pyenv 的步骤： 安装 pyenv 安装依赖…...

编程日记 2025/6/3 7:15:51

前端如何设计一个回溯用户操作的方案

同一个项目，为什么我本地无法复现，只有客户的设备才复现？ 如何获取用户的操作路径呢？ 两种方案：埋点和rrweb 埋点就很简单了，将所有可能操作的节点都进行预埋数据；但埋点简单并不省心&#xff…...

编程日记 2025/6/3 11:04:02

WPF、控件模板(ControlTemplate)和数据模板(DataTemplate)

前言在 WPF 中，控件种类丰富且功能非常完善。一个显著的优点是 WPF 提供了强大的自定义能力和灵活的用户界面表现，能够满足各种复杂的应用需求。其中，ControlTemplate 和 DataTemplate 是两个非常重要的概念，分别用于自定义控件…...

编程日记 2025/6/3 11:02:23

MAC上安装Octave

1. 当前最新版Octave是9.3版本，需要把mac os系统升级到14版本（本人之前的版本是10版本） https://wiki.octave.org/Octave_for_macOS octave的历史版本参考此文档：Octave for macOS (outdated) - Octavehttps://wiki.octave.org/Oc…...

编程日记 2025/6/3 11:02:58

RabbitMQ(三)

RabbitMQ中的各模式及其用法工作队列模式一、生产者代码1、封装工具类2、编写代码3、发送消息效果二、消费者代码1、编写代码2、运行效果发布订阅模式一、生产者代码二、消费者代码1、消费者1号2、消费者2号三、运行效果四、小结路由模式一、生产者代码二、消费者代码1、消…...

编程日记 2025/6/3 11:03:46

一体机cell服务器更换内存步骤： #1、确认grdidisk状态 cellcli -e list griddisk attribute name,asmmodestatus,asmdeactivationoutcome #2、offline griddisk cellcli -e alter griddisk all inactive #3、确认全部offline后进行关机操作 shutdown -h now #4、开…...

编程日记 2025/6/2 13:39:34

年后找工作需要注意的事项

大家好！我是 [数擎 AI]，一位热爱探索新技术的前端开发者，在这里分享前端和 Web3D、AI 技术的干货与实战经验。如果你对技术有热情，欢迎关注我的文章，我们一起成长、进步！ 开发领域：前端开发 | A…...

编程日记 2025/6/3 11:03:14

【网络 MAC 学习专栏 -- 如何理解 PHY 的 Link Up】

编程日记 2025/6/4 8:42:19

鸿蒙UI开发——文本级联选择器

1、概述 ArkUI提供了一个文本选择器（showTextPickerDialog），可以方便的实现文本级联选择，例如：省->市->区，示意如下： 下面针对文本选择器做简单介绍。 2、接口介绍定义文本滑动选择器…...

编程日记 2025/6/3 6:32:52

后盾人JS -- JS运算符与流程控制

嘻嘻赋值运算符与算术运算符没什么好说的，等号谁都会用比较运算符注意事项如果一个是字符一个是数字也是可以比较的（） 是判断值和类型是否相等 <!DOCTYPE html> <html lang"en"><head><meta charset…...

编程日记 2025/5/31 21:57:38

Hive SQL必刷练习题：留存率问题

首次登录算作当天新增，第二天也登录了算作一日留存。可以理解为，在10月1号登陆了。在10月2号也登陆了，那这个人就可以算是在1号留存今日留存率 （今日登录且明天也登录的用户数） / 今日登录的总用户数 * 100% 解决思…...

编程日记 2025/6/4 8:43:24

笔记本电脑选购回收特权模式使用指南

笔记本电脑 factor 无线网卡：有些笔记本无法检测到特定频段的信息，会导致连不上校园网 sudo iwlist wlp2s0 scan | grep Frequency > net.txt cat net.txt>表示用终端输出覆盖后续文件，>>表示添加到后续文件的末尾一种更简…...

编程日记 2025/6/4 8:43:40

基于PyQt - 6的医疗多模态大模型医疗研究系统中的创新构建与应用（上 .文章部分）

一、引言 1.1 研究背景与意义在当今数智化时代，医疗行业正经历着深刻的变革，对智能化、高效化的需求日益迫切。传统的医疗模式在面对海量的医疗数据、复杂的诊断流程以及个性化的治疗需求时，逐渐显露出局限性。随着人工智能技术的飞速发展，多模态大模型作为一种前沿技术…...

编程日记 2025/6/4 8:42:36

下载文件，浏览器阻止不安全下载

背景： 在项目开发中，遇到需要下载文件的情况，文件类型可能是图片、excell表、pdf、zip等文件类型，但浏览器会阻止不安全的下载链接。效果展示： 下载文件的两种方式： 一、根据接口的相对url，拼…...

编程日记 2025/6/4 8:42:53

1.15学习

web ctfhub-网站源码打开环境，查看源代码无任何作用，但是其提醒就在表面暗示我们用dirsearch进行目录扫描，登录kali的root端，利用终端输入dirsearch -u 网址的命令扫描该网址目录，扫描成功后获得信息，在…...

编程日记 2025/6/1 23:55:49

shell练习2

需求：判断192.168.1.0/24网络中，当前在线的ip有哪些，并编写脚本打印出来。 #!/bin/bashnmap -sn 192.168.1.0/24 | grep Nmap scan report for | awk {print $5} 注意：当运行 bash ip.sh 时出现 nmap: command not found 的错误…...

编程日记 2025/6/4 8:43:09

MySQL学习笔记5【SQL优化/视图/存储过程/触发器】

MySQL学习笔记 SQL优化 1. 插入数据优化普通插入： 采用批量插入： 每次插入不建议超过1000条记录，这样可以减少事务开销，提高性能。示例： INSERT INTO tb_user (name, age) VALUES (Alice, 25), (Bob, 30), ...;手动提…...

编程日记 2025/6/1 14:05:30

C++单例模式的设计

单例模式（Singleton Pattern）是一种设计模式，用于确保一个类只有一个实例，并提供一个全局访问点来访问该实例。在C中，单例模式通常用于管理全局资源或共享状态。以下是C中实现单例模式的几种常见方式： 懒…...

编程日记 2025/6/4 15:14:44

【Linux系统编程】—— 自动化构建工具Makefile指南

文章目录背景基本使用推导过程适度扩展语法背景 Makefile 是衡量开发者是否具备完成大型工程能力的一个重要标志。在一个工程中，源文件的数量可能极多，这些文件会按照类型、功能或模块分布在多个目录中。Makefile 通过定义一系列规则，指定…...

编程日记 2025/5/30 18:14:56

【SpringBoot应用篇】SpringBoot+MDC+自定义Filter操作traceId实现日志链路追踪

【SpringBoot应用篇】SpringBootMDC自定义Filter操作traceId实现日志链路追踪解决的问题解决方案MDC具体逻辑ymllogback-spring.xmlTraceIdUtil操作工具类TraceIdFilter自定义过滤器GlobalExceptionHandler全局异常处理类TraceIdAspect切面UserController测试验证多线程处理M…...

编程日记 2025/6/3 7:08:39

少一点If/Else - 状态模式（State Pattern）

状态模式（State Pattern） 状态模式（State Pattern）状态模式（State Pattern）概述状态模式（State Pattern）结构图状态模式（State Pattern）涉及的角色 talk is c…...

编程日记 2025/5/31 18:59:59

【SVN】版本发布快捷操作

摘要：因为每次发版都需要制作一份相同的文件夹，而大部分的包都不需要变更，但是文件又非常大，记录自己的操作经验。首先在SVN Repository Browser 界面把上一次的版本复制一份，复制的时候重命名为新的版本号右击要复…...

编程日记 2025/6/4 6:15:02

nacos环境搭建以及SpringCloudAlibaba脚手架启动环境映射开发程序

1：下载nacos 地址：https://github.com/alibaba/nacos/tags 2:选择server的zip包下载 3:启动mysql服务，新建数据库：nacos_yh 4：解压下载的nacos_server 进入conf目录 5：mysql运行sql脚本变得到下面的表 6&a…...

编程日记 2025/5/31 9:58:50

【笔记整理】记录参加骁龙AIPC开发者技术沙龙的笔记

AIoT 首先了解了一个概念叫AIoT，我的理解就是AI IoT 5G，通过AI的发展使得边缘计算、数据整合和处理变得快捷方便，不仅限于传统的云端数据处理，在边缘的IoT设备上也可以进行智能化打造，通过5G的通信能力扩展可以实现…...

编程日记 2025/6/2 1:57:17

Kotlin 协程基础十 —— 协作、互斥锁与共享变量

Kotlin 协程基础系列： Kotlin 协程基础一 —— 总体知识概述 Kotlin 协程基础二 —— 结构化并发（一） Kotlin 协程基础三 —— 结构化并发（二） Kotlin 协程基础四 —— CoroutineScope 与 CoroutineContext Kotlin 协程…...

编程日记 2025/6/2 12:02:16

DAMA CDGA 备考笔记（二）

1. 考点分布 2. 第二章数据处理伦理知识点总结伦理是建立在是非观念上的行为准则。伦理准则通常侧重于公平、尊重、责任、诚信、质量、可靠性、透明度和信任等方面。数据伦理是一项社会责任问题不是法律问题。度量指标：培训员工人数、合规/不合规事件、企业高管…...

编程日记 2025/5/31 9:15:43

【Lua学习之旅】之单行/多行注释

Lua的注释单行注释多行注释单行注释 lua中的单行注释采用两个短横线"--" --这是lua单行注释多行注释写法一： --[[ 这个lua的多行注释， 很多资料说多行注释不可以嵌套， 根据我的测试，这种写法的多行注释在lua54版…...

编程日记 2025/6/2 3:44:34

【线性代数】行列式的概念

d e t ( A ) ∑ i 1 , i 2 , ⋯ , i n ( − 1 ) σ ( i 1 , ⋯ , i n ) a 1 , i 1 a 2 , i 2 , ⋯ , a n , i n det(A) \sum_{i_1,i_2,\cdots,i_n } (-1)^{\sigma(i_1,\cdots,i_n)} a_{1,i_1}a_{2,i_2},\cdots, a_{n,i_n} det(A)i1,i2,⋯,in∑(−1)σ(i1,⋯,in)a1…...

编程日记 2025/5/31 8:31:01

react中hooks之useEffect 用法总结

1. 什么是函数的副作用（Side Effects） 副作用是指在组件渲染过程中，除了返回 JSX 之外的其他操作，例如： 数据获取（API 调用）订阅数据源手动修改 DOM设置定时器存储数据日志记录纯函数是特定的…...

编程日记 2025/6/2 18:30:12

小型、中型无人机执照学习和考试区别详解

小型、中型无人机执照的学习和考试在多个方面存在区别。以下是对两者的详细对比： 一、定义与适用范围 1. 小型无人机： 通常指起飞重量在7kg至25kg之间的无人机。适用于多种应用场景，包括商业飞行、航拍、农业植保等。必须持有民航局无人…...

编程日记 2025/6/4 6:43:55

【Go】Go Gin框架初识（一）

1. 什么是Gin框架 Gin框架：是一个由 Golang 语言开发的 web 框架，能够极大提高开发 web 应用的效率！ 1.1 什么是web框架 web框架体系图（前后端不分离）如下图所示： 从上图中我们可以发现一个Web框架最重要…...

编程日记 2025/5/31 1:29:18

计算机网络的五层协议

计算机网络的五层协议 ‌计算机网络的五层协议模型包括物理层、数据链路层、网络层、传输层和应用层，每一层都有其特定的功能和相关的协议。‌‌1 ‌物理层‌：负责传输原始的比特流，通过线路（有线或无线）将数据转换为…...

编程日记 2025/6/3 15:14:05

QT中，在子线程中更新UI，会出现哪些问题，如何避免这种情况发生。

在Qt中，直接从子线程更新UI（用户界面）通常会导致各种问题，主要是因为Qt的UI组件（如QWidget及其子类）并不是线程安全的。具体来说，可能会出现以下问题： 崩溃和未定义行为：…...

编程日记 2025/6/2 9:38:56

C++并发编程之多线程环境下使用无锁数据结构的重要准则

在多线程环境中使用无锁数据结构（Lock-Free Data Structures）能够显著提高程序的并发性能，因为它们避免了传统锁机制带来的竞争和阻塞问题。然而，无锁编程本身也带来了许多挑战，如内存管理、数据一致性和正确性等问题。…...

编程日记 2025/6/3 4:29:42

Vue篇-07

Vue UI组件库一、移动端常用的UI组件库 1.1、Vant 1.2、Cube UI 1.3、Mint UI 二、PC端常用的UI组件库 2.1、Element UI Element - The worlds most popular Vue UI framework 安装： 按需引入： 135_尚硅谷Vue技术_element-ui按需引入_哔哩哔哩_b…...

编程日记 2025/6/4 7:32:46

Zookeeper 数据迁移实战：基础环境搭建与高效迁移方案全览

文章目录一、Zookeeper数据迁移简介二、迁移zookeeper数据基础环境三、利用快照迁移zookeeper数据1、Node1最新的zk快照文件和日志文件2、将被迁移方node2的zookeeper的集群全部stop3、将源node1集群数据和日志拷贝到指定目录下4、验证优先启动拷贝的数据、日志的zookeeper节点…...

编程日记 2025/6/2 16:26:17

内联变量（inline variables）：在多个文件中共享全局常量

在 C17 中，引入了内联变量（inline variables） 的概念，可以用于在多个文件中共享全局常量。内联变量允许在头文件中定义变量，而不会导致链接错误（如重复定义）。这种方式非常适合用于定义跨多个文…...

编程日记 2025/6/2 2:58:30

WOA-CNN-LSTM-Attention、CNN-LSTM-Attention、WOA-CNN-LSTM、CNN-LSTM四模型对比多变量时序预测

WOA-CNN-LSTM-Attention、CNN-LSTM-Attention、WOA-CNN-LSTM、CNN-LSTM四模型对比多变量时序预测目录 WOA-CNN-LSTM-Attention、CNN-LSTM-Attention、WOA-CNN-LSTM、CNN-LSTM四模型对比多变量时序预测预测效果基本介绍程序设计参考资料预测效果基本介绍基于WOA-CNN-LSTM-A…...

编程日记 2025/6/1 19:54:30

【kubernetes】K8S节点状态的维护

1 节点状态节点是K8S集群中的一类重要资源，节点的状态通常可以作为判断集群异常的重要手段。为了展示节点在各方面的健康程度，在kubectl describe node k8s-master的输出结果中的Conditions部分可以查看k8s-master节点的一些状态数据： N…...

编程日记 2025/6/2 23:07:04

工业视觉2-相机选型

工业视觉2-相机选型一、按芯片类型二、按传感器结构特征三、按扫描方式四、按分辨率大小五、按输出信号六、按输出色彩接口类型这张图片对工业相机的分类方式进行了总结，具体如下： 一、按芯片类型 CCD相机：采用电荷耦合器件（CC…...

编程日记 2025/6/2 4:50:33

Oracle查询-in条件超过1000

目录 1.不分页 2.分页 oracle数据库中，in的查询条件超过1000的话，就会报错，应该怎样处理这样的情况呢？ 1.不分页把查询条件分成几个list，每个list有1000个数据，有几个list查询几次数据库就行了 2.分…...

编程日记 2025/6/2 15:58:25

使用rknn进行retinaface部署（C++）

文章目录 RetinaFace导出ONNX导出RKNN编译运行学生课堂开源数据集RetinaFace RetinaFace是一种基于深度学习的高性能人脸检测方法，由InsightFace团队提出。它的核心思想是在单阶段检测器（如RetinaNet）的基础上，结合多任务学习来实现精确的人脸检测和特征点定位。以下是Ret…...

编程日记 2025/6/2 23:05:59