springboot中使用注解实现分布式锁
下面将详细介绍如何在 Spring Boot 里借助注解实现分布式锁，以login_lock:作为锁的 key 前缀，使用请求参数里的phone值作为 key，等待时间设为 0 秒，锁的持续时间为 10 秒。我们会使用 Redis 来实现分布式锁，同时借助 Spring AOP 与自定义注解达成基于注解的锁机制。
1. 添加依赖
在pom.xml文件中添加必要的依赖，包括 Spring Boot Redis 和 Spring Boot AOP：
xml
<dependencies><!-- Spring Boot Redis 依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><!-- Spring Boot AOP 依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId></dependency>
</dependencies>
2. 配置 Redis
在application.properties或者application.yml中配置 Redis 连接信息，以application.yml为例：
yaml
spring:redis:host: localhostport: 6379# 若 Redis 有密码，需添加此项# password: yourpassword
3. 定义分布式锁注解
创建自定义注解DistributedLock，用于标记需要加锁的方法：
java
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface DistributedLock {String keyPrefix() default "login_lock:";String keyField() default "phone";long waitTime() default 0;long leaseTime() default 10;
}
4. 实现分布式锁切面
创建切面类DistributedLockAspect，处理加锁和解锁逻辑：
java
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.data.redis.core.script.RedisScript;
import org.springframework.stereotype.Component;import java.lang.reflect.Field;
import java.util.Collections;
import java.util.concurrent.TimeUnit;@Aspect
@Component
public class DistributedLockAspect {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;private static final RedisScript<Long> UNLOCK_SCRIPT;static {StringBuilder script = new StringBuilder();script.append("if redis.call('get', KEYS[1]) == ARGV[1] then");script.append(" return redis.call('del', KEYS[1])");script.append("else");script.append(" return 0");script.append("end");UNLOCK_SCRIPT = new DefaultRedisScript<>(script.toString(), Long.class);}@Around("@annotation(com.example.demo.DistributedLock)")public Object around(ProceedingJoinPoint joinPoint) throws Throwable {MethodSignature signature = (MethodSignature) joinPoint.getSignature();DistributedLock distributedLock = signature.getMethod().getAnnotation(DistributedLock.class);String keyPrefix = distributedLock.keyPrefix();String keyField = distributedLock.keyField();long waitTime = distributedLock.waitTime();long leaseTime = distributedLock.leaseTime();Object[] args = joinPoint.getArgs();String keyValue = null;for (Object arg : args) {try {Field field = arg.getClass().getDeclaredField(keyField);field.setAccessible(true);keyValue = String.valueOf(field.get(arg));break;} catch (NoSuchFieldException | IllegalAccessException e) {// 忽略异常，继续尝试下一个参数}}if (keyValue == null) {throw new IllegalArgumentException("Could not find the key field in the method arguments.");}String lockKey = keyPrefix + keyValue;String requestId = java.util.UUID.randomUUID().toString();long startTime = System.currentTimeMillis();boolean locked = false;do {locked = redisTemplate.opsForValue().setIfAbsent(lockKey, requestId, leaseTime, TimeUnit.SECONDS);if (locked) {break;}// 检查是否超过等待时间if (System.currentTimeMillis() - startTime >= waitTime * 1000) {break;}// 短暂休眠后重试Thread.sleep(100);} while (true);if (!locked) {throw new RuntimeException("Failed to acquire the lock after waiting.");}try {return joinPoint.proceed();} finally {// 使用 Lua 脚本释放锁，保证原子性redisTemplate.execute(UNLOCK_SCRIPT, Collections.singletonList(lockKey), requestId);}}
}5. 使用分布式锁注解
在需要加锁的方法上添加DistributedLock注解：
java
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;@RestController
public class LoginController {@PostMapping("/login")@DistributedLockpublic String login(@RequestBody User user) {// 模拟业务逻辑try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}return "Login success";}
}class User {private String phone;public String getPhone() {return phone;}public void setPhone(String phone) {this.phone = phone;}
}
代码解释
DistributedLock注解：用于标记需要加锁的方法，可通过keyPrefix、keyField、waitTime和leaseTime属性配置锁的相关信息。DistributedLockAspect切面类：- 运用
@Around注解拦截所有标记了DistributedLock注解的方法。 - 从方法参数里提取
phone值，组合成 Redis 锁的 key。 - 借助
redisTemplate.opsForValue().setIfAbsent方法尝试获取锁，若获取失败则抛出异常。 - 使用 Lua 脚本释放锁，确保操作的原子性，防止误删其他线程的锁。
- 运用
LoginController控制器：在login方法上添加DistributedLock注解，保证同一手机号在同一时间只有一个请求能进入该方法。
通过以上步骤，你就能在 Spring Boot 项目中使用注解实现分布式锁。
相关文章：
springboot中使用注解实现分布式锁
下面将详细介绍如何在 Spring Boot 里借助注解实现分布式锁，以login_lock:作为锁的 key 前缀，使用请求参数里的phone值作为 key，等待时间设为 0 秒，锁的持续时间为 10 秒。我们会使用 Redis 来实现分布式锁，同时借助 S…...
Android TabLayout 使用进阶（含源码）
android:layout_height“match_parent” android:orientation“vertical” tools:context“.mode2.ClassificationActivity”> <com.google.android.material.tabs.TabLayout android:id“id/tab_layout” android:layout_width“match_parent” android:layout_he…...
数据库系统概论的第六版与第五版的区别，附pdf
我用夸克网盘分享了「数据库系统概论第五六版资源」，点击链接即可保存。 链接：https://pan.quark.cn/s/21a278378dee 第6版教材修订的主要内容 为了保持科学性、先进性和实用性，在第5版教材基础上对全书内容进行了修改、更新和充实。 在科…...
管理etcd的存储空间配额
如何管理etcd的存储空间配额 - 防止集群存储耗尽指南 本文基于etcd v3.4官方文档编写 为什么需要空间配额？ 在分布式系统中，etcd作为可靠的键值存储，很容易成为系统瓶颈。当遇到以下情况时： 应用程序频繁写入大量数据未及时清理…...
深入浅出 NRM：加速你的 npm 包管理之旅
文章目录 前言一、NRM 是什么？二、为什么需要 NRM？三、NRM 的优势四、NRM 的安装与使用4.1 安装 NRM4.2 查看可用的 npm 源4.3 切换 npm 源4.4 测试 npm 源速度4.5 添加自定义 npm 源4.6 删除 npm 源 五、NRM 的进阶使用六、总结 前言 作为一名 JavaScr…...
ESP32开发学习记录---》GPIO
she 2025年2月5日，新年后决定开始充电提升自己，故作此记,以前没有使用过IDF开发ESP32因此新年学习一下ESP32。 ESPIDF开发环境配置网上已经有很多的资料了，我就不再赘述，我这里只是对我的学习经历的一些记录。 首先学习一个…...
stm32点灯 GPIO的输出模式
目录 1.选择RCC时钟 2.SYS 选择调试模式 SW 3.GPIO 配置 4.时钟树配置（ 默认不变）HSI 高速内部时钟8Mhz 5.项目配置 6.代码 延时1s循环LED亮灭 1.选择RCC时钟 2.SYS 选择调试模式 SW 3.GPIO 配置 4.时钟树配置（ 默认不变）…...
[paddle] 矩阵的分解
特征值 设 A A A 是一个 n n n \times n nn 的方阵， λ \lambda λ 是一个标量， v \mathbf{v} v 是一个非零向量。如果满足以下方程： A v λ v A\mathbf{v} \lambda\mathbf{v} Avλv 则称 λ \lambda λ 为矩阵 A A A 的一个 特征值…...
【基于SprintBoot+Mybatis+Mysql】电脑商城项目之修改密码和个人资料
🧸安清h：个人主页 🎥个人专栏：【Spring篇】【计算机网络】【Mybatis篇】 🚦作者简介：一个有趣爱睡觉的intp，期待和更多人分享自己所学知识的真诚大学生。 目录 🎃1.修改密码 -持久…...
【深度学习】DataLoader自定义数据集制作
第一步 导包 import os import matplotlib.pyplot as plt %matplotlib inline import numpy as np import torch from torch import nn import torch.optim as optim import torchvision from torchvision import transforms,models,datasets import imageio import time impo…...
【Elasticsearch】Geo-distance聚合
geo_distance聚合的形状是圆形。它基于一个中心点（origin）和一系列距离范围来计算每个文档与中心点的距离，并将文档分配到相应的距离范围内。这种聚合方式本质上是以中心点为圆心，以指定的距离范围为半径的圆形区域来划分数据。 为…...
【R语言】apply函数族
在R语言中使用循环操作时是使用自身来实现的，效率较低。所以R语言有一个符合其统计语言出身的特点：向量化。R语言中的向量化运用了底层的C语言，而C语言的效率比高层的R语言的效率高。 apply函数族主要是为了解决数据向量化运算的问题&#x…...
Vue - shallowRef 和 shallowReactive
一、shallowRef 和 shallowReactive （一）shallowRef 在 Vue 3 中，shallowRef 是一个用于创建响应式引用的 API，它与 ref 相似，但它只会使引用的基本类型（如对象、数组等）表现为响应式…...
双目标定与生成深度图
基于C#联合Halcon实现双目标定整体效果 一，标定 1，标定前准备工作 （获取描述文件与获取相机参数） 针对标准标定板可以直接调用官方提供描述文件，也可以自己生成描述文件后用PS文件打印 2，相机标定 &…...
实名制-网络平台集成身份证实名认证接口/身份证查询-PHP
在当今数字化快速发展的时代，线上平台的安全性和用户体验成为了衡量其成功与否的关键因素。其中，身份证实名认证接口的集成显得尤为重要，它不仅为用户提供了更加安全、可靠的网络环境，同时也增强了平台的信任度和合规性。 对于任…...
全面解析机器学习优化算法中的进化策略
全面解析机器学习优化算法中的进化策略 全面解析机器学习优化算法中的进化策略引言什么是进化策略？基本概念核心组件算法流程数学基础高斯扰动期望值更新与其他优化方法的比较梯度下降法（Gradient Descent, GD）遗传算法（Genetic Algorithm, GA）Python案例基本实现改进版：…...
go数据结构学习笔记
本博文较为完整的实现了go的链表、栈，队列，树，排序，链表包括顺序链表，双向链表，循环链表，队列是循环队列，排序包含冒牌、选择 1.链表 1.1 顺序链表 type LNode struct {data intn…...
【深度学习】DeepSeek模型介绍与部署
原文链接：DeepSeek-V3 1. 介绍 DeepSeek-V3，一个强大的混合专家 (MoE) 语言模型，拥有 671B 总参数，其中每个 token 激活 37B 参数。 为了实现高效推理和成本效益的训练，DeepSeek-V3 采用了多头潜在注意力 (MLA) 和 De…...
使用SpringBoot发送邮件|解决了部署时连接超时的bug|网易163|2025
使用SpringBoot发送邮件 文章目录 使用SpringBoot发送邮件1. 获取网易邮箱服务的授权码2. 初始化项目maven部分web部分 3. 发送邮件填写配置EmailSendService [已解决]部署时连接超时附：Docker脚本Dockerfile创建镜像启动容器 1. 获取网易邮箱服务的授权码 温馨提示…...
【工具篇】深度揭秘 Midjourney：开启 AI 图像创作新时代
家人们，今天咱必须好好唠唠 Midjourney 这个在 AI 图像生成领域超火的工具！现在 AI 技术发展得那叫一个快，各种工具层出不穷，Midjourney 绝对是其中的明星产品。不管你是专业的设计师、插画师，还是像咱这种对艺术创作有点小兴趣的小白，Midjourney 都能给你带来超多惊喜，…...
构成正方形的数量：算法深度剖析与实践
目录 引言算法核心概念 定义正方形的构成条件数据结构与输入形式算法数学原理 几何关系的数学表达坐标运算与判定逻辑Python 实现 代码展示代码解析Python 实现的优势与局限C 语言实现 代码展示代码解析C 语言实现的性能特点性能分析与优化 性能分析 时间复杂度空间复杂度优化思…...
)
Spring设计模式（9种）(详细篇)
总体分为三大类： 创建型模式：工厂方法模式、单例模式。 结构型模式：适配器模式、代理模式、装饰器模式。 行为型模式：观察者模式、策略模式、模板方法模式。 一、简单工厂模式（Simple Factory） 概述&…...
使用Express.js和SQLite3构建简单TODO应用的后端API
使用Express.js和SQLite3构建简单TODO应用的后端API 引言环境准备代码解析1. 导入必要的模块2. 创建Express应用实例3. 设置数据库连接4. 初始化数据库表5. 配置中间件6. 定义数据接口7. 定义路由7.1 获取所有TODO项7.2 创建TODO项7.3 更新TODO项7.4 删除TODO项 8. 启动服务器 …...
2025年2月6日（anaconda cuda 学习 基本命令）
查看电脑的显卡型号是否支持CUDA的安装 https://developer.nvidia.com/zh-cn/cuda-gpus 查看可以安装的CUDA版本 https://docs.nvidia.com/cuda/cuda-toolkit-release-notes/index.html CUDA安装地址 https://developer.nvidia.com/cuda-toolkit-archive Anaconda下载地址 htt…...
大数据方向知识图谱及发展前景分析
目录 一、知识体系 二、大数据领域前景分析： 1. 市场需求 2. 技术趋势 3. 职业发展路径 4. 学习路线建议 5. 推荐认证体系 一、知识体系 大数据知识体系 ├── 基础理论 │ ├── 数学基础：概率统计、线性代数、离散数学 │ ├── 计算机基…...
Docker深度解析：安装各大环境
安装 Nginx 实现负载均衡： 挂载 nginx html 文件： 创建过载目录： mkdir -p /data/nginx/{conf,conf.d,html,logs} 注意：在挂载前需要对 conf/nginx.conf 文件进行编写 worker_processes 1;events {worker_connections 1024; …...
Verilog语言学习总结
Verilog语言学习！ 目录 文章目录 前言 一、Verilog语言是什么？ 1.1 Verilog简介 1.2 Verilog 和 C 的区别 1.3 Verilog 学习 二、Verilog基础知识 2.1 Verilog 的逻辑值 2.2 数字进制 2.3 Verilog标识符 2.4 Verilog 的数据类型 2.4.1 寄存器类型 2.4.2 …...
K8S Deployment 实现 蓝绿 发布
一、何为蓝绿发布 蓝绿发布（Blue - Green Deployment）是一种软件部署策略，旨在最大程度减少应用程序停机时间，确保新老版本系统平稳过渡。以下为详细介绍： 1.1、基本概念 存在两个完全相同的生产环境，通…...
2025新鲜出炉--前端面试题（一）
文章目录 1. vue3有用过吗, 和vue2之间有哪些区别2. vue-router有几种路由, 分别怎么实现3. webpack和rollup这两个什么区别, 你会怎么选择4. 你能简单介绍一下webpack项目的构建流程吗5. webpack平时有手写过loader和plugin吗6. webpack这块你平时做过哪些优化吗？7…...
【ArcGIS Pro 简介1】
ArcGIS Pro 是由 Esri （Environmental Systems Research Institute）公司开发的下一代桌面地理信息系统（GIS）软件，是传统 ArcMap 的现代化替代产品。它结合了强大的空间分析能力、直观的用户界面和先进的三维可视化技术…...
CentOS 6.5编译Rsyslog 8.1903.0
个人博客地址：CentOS 6.5编译Rsyslog 8.1903.0 | 一张假钞的真实世界 个人很早之前的博文，迁移至此作为历史记录。 源码下载参考我的另外一片博文：CentOS 7.3 编译 Rsyslog 8.1903.0。 本篇博文从创建构建环境开始填坑/(ㄒoㄒ)/~~。通过上…...
SQLAlchemy-2.0中模型定义和alembic的数据库迁移工具
SQLAlchemy-2.0中模型定义和alembic的数据库迁移工具 一、SQLAIchemy的介绍二、数据库引擎1、支持的数据库1.1、sqlite数据库1.2、MySQL数据库1.3、数据库引擎的参数 三、定义模型类1、定义模型2、engine负责数据库迁移 四、alembic数据库迁移⼯具1、安装alembic2、初始化alemb…...
打印A4半张纸方法)
两种文件类型(pdf/图片)打印A4半张纸方法
环境:windows10、Adobe Reader XI v11.0.23 Pdf: 1.把内容由横排变为纵排： 2.点击打印按钮： 3.选择打印页范围和多页： 4.内容打印在纸张上部 图片： 1.右键图片点击打印： 2.选择打印类型： 3.打印配置&am…...
【React】合成事件语法
React 合成事件是 React 为了处理浏览器之间的事件差异而提供的一种跨浏览器的事件系统。它封装了原生的 DOM 事件，提供了一致的事件处理机制。 合成事件与原生事件的区别： 合成事件是 React 自己实现的，封装了原生事件。合成事件依然可以通…...
深入解析：如何利用 Python 爬虫获取商品 SKU 详细信息
在电商领域，SKU（Stock Keeping Unit，库存单位）详细信息是电商运营的核心数据之一。它不仅包含了商品的规格、价格、库存等关键信息，还直接影响到库存管理、价格策略和市场分析等多个方面。本文将详细介绍如何利用 Pyth…...
)
Unity 加载OSGB(webgl直接加载，无需转换格式！)
Unity webgl加载倾斜摄影数据 前言效果图后续不足 前言 Unity加载倾斜摄影数据，有很多的插件方便好用，但是发布到网页端均失败，因为webgl 的限制，IO读取失效。 前不久发现一个开源项目: UnityOSGB-main 通过两种方式在 Unity 中…...
Maven架构项目管理工具
1.1什么是Maven 翻译为“专家”，“内行”Maven是跨平台的项目管理工具。主要服务于基于Java平台的项目构建，依赖管理和项目信息管理。什么是理想的项目构建？ 高度自动化，跨平台，可重用的组件，标准化的 什么…...
【漫画机器学习】083.安斯库姆四重奏（Anscombe‘s Quartet）
安斯库姆四重奏（Anscombes Quartet） 1. 什么是安斯库姆四重奏？ 安斯库姆四重奏（Anscombes Quartet）是一组由统计学家弗朗西斯安斯库姆（Francis Anscombe） 在 1973 年 提出的 四组数据集。它们…...
【梦想终会实现】Linux驱动学习5
加油加油坚持住！ 1、 Linux驱动模型：驱动模型即将各模型中共有的部分抽象成C结构体。Linux2.4版本前无驱动模型的概念，每个驱动写的代码因人而异，随后为规范书写方式，发明了驱动模型，即提取公共信息组成一…...
QT修仙之路1-1--遇见QT
文章目录 遇见QT二、QT概述2.1 定义与功能2.2 跨平台特性2.3 优点汇总 三、软件安装四、QT工具介绍(重要)4.1 Assistant4.2 Designer4.3 uic.exe4.4 moc.exe4.5 rcc.exe4.6 qmake4.7 QTcreater 五、QT工程项目解析(作业)5.1 配置文件（.pro）5.2 头文件&am…...
【实战篇】Android安卓本地离线实现视频检测人脸
实战篇Android安卓本地离线实现视频检测人脸 引言项目概述核心代码类介绍人脸检测流程项目地址总结 引言 在当今数字化时代，人脸识别技术已经广泛应用于各个领域，如安防监控、门禁系统、移动支付等。本文将以第三视角详细讲解如何基于bifan-wei-Face/De…...
【图像处理】- 基本图像操作
基本图像操作详解 基本图像操作是图像处理的基础，涵盖了对图像进行简单但重要的变换。以下是几种常见的基本图像操作及其详细说明： 1. 裁剪 (Cropping) 描述：从原始图像中提取一个矩形区域。 实现方法： 使用图像的坐标系指定…...
代码随想录算法训练营| 二叉树总结
代码随想录 二叉树的理论基础：二叉树种类、存储方式、遍历方式、定义方式 二叉树遍历：深度优先和广度优先 二叉树属性：对称、深度、节点、平衡、路径、回溯 修改与构造：反转、构造、合并 涉及到二叉树的构造，无论普…...
Sentinel的安装和做限流的使用
一、安装 Release v1.8.3 alibaba/Sentinel GitHubA powerful flow control component enabling reliability, resilience and monitoring for microservices. (面向云原生微服务的高可用流控防护组件) - Release v1.8.3 alibaba/Sentinelhttps://github.com/alibaba/Senti…...
八、Spring Boot 日志详解
目录 一、日志的用途 二、日志使用 2.1 打印日志 2.1.1 在程序中获取日志对象 2.1.2 使用日志对象打印日志 2.2、日志框架介绍 2.2.1 门面模式(外观模式) 2.2.2 门面模式的实现 2.2.3 SLF4J 框架介绍 2.3 日志格式的说明 2.4 日志级别 2.4.1 日志级别的分类 2.4.2…...
vue2：如何动态控制el-form-item之间的行间距
需求 某页面有查看和编辑两种状态： 编辑： 查看： 可以看到，查看时，行间距太大导致页面不紧凑，所以希望缩小查看是的行间距。 行间距设置 行间距通常是通过 CSS 的 margin 或 padding 属性来控制的。在 Element UI 的样式表中，.el-form-item 的下边距（margin-bottom）…...
智能门铃市场：开启智能家居新时代
在科技日新月异的今天，智能家居产品正以前所未有的速度融入我们的生活，而智能门铃作为其中的重要一员，不仅为我们的家居生活带来了极大的便利，更在安全方面提供了坚实的保障。它就像一位忠诚的守门人，无论白天黑夜&…...
)
C基础寒假练习(6)
一、终端输入行数，打印倒金字塔 #include <stdio.h> int main() {int rows;printf("请输入倒金字塔的行数: ");scanf("%d", &rows);for (int i rows; i > 0; i--) {// 打印空格for (int j 0; j < rows - i; j) {printf(&qu…...
【深度学习】基于MXNet的多层感知机的实现
多层感知机 结构组成 大致由三层组成：输入层-隐藏层-输出层，其中隐藏层大于等于一层 其中，隐藏层和输出层都是全连接 隐藏层的层数和神经元个数也是超参数 多层隐藏层，在本质上仍等价于单层神经网络（可从输出方程…...
Mac 终端命令大全
—目录操作— ꔷ mkdir 创建一个目录 mkdir dirname ꔷ rmdir 删除一个目录 rmdir dirname ꔷ mvdir 移动或重命名一个目录 mvdir dir1 dir2 ꔷ cd 改变当前目录 cd dirname ꔷ pwd 显示当前目录的路径名 pwd ꔷ ls 显示当前目录的内容 ls -la ꔷ dircmp 比较两个目录的内容 di…...