Redis+IDEA极速了解和实现单机锁和分布式锁

单机下：

 

只适用于单机环境下（单个JVM），多个客户端访问同一个服务器

1.synchronized

package com.cloud.SR.controller;import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;@RestController
public class TestConrtoller1 {@Value("${server.port}")private String serverPort;@Resourceprivate StringRedisTemplate stringRedisTemplate;@GetMapping("/buy1")public String shopping(){synchronized (this){String result = stringRedisTemplate.opsForValue().get("goods:001");int total = result == null? 0 :Integer.parseInt(s);if(total > 0){int realTotal = total - 1;stringRedisTemplate.opsForValue().set("goods:001",String.valueOf(realCount ));System.out.println("剩余商品为："+realCount +",提供服务的端口号："+serverPort);return "剩余商品为："+realTotal +",提供服务的端口号："+serverPort;}else{System.out.println("购买商品失败！");}return "购买商品失败！";}}
}

2.ReentrantLock

@RestController
public class TestConrtoller2 {@Value("${server.port}")private String serverPort;// 使用ReentrantLock锁解决单体应用的并发问题Lock lock = new ReentrantLock();@AutowiredStringRedisTemplate stringRedisTemplate;@RequestMapping("/buy2")public String index() {lock.lock();try {String result = stringRedisTemplate.opsForValue().get("goods:001");int total = result == null ? 0 : Integer.parseInt(result);if (total > 0) {int realTotal = total - 1;stringRedisTemplate.opsForValue().set("goods:001", String.valueOf(realTotal));System.out.println("购买商品成功，库存还剩：" + realTotal + "，服务端口为:"+serverPort);return "购买商品成功，库存还剩：" + realTotal + "，服务端口为："+serverPort;} else {System.out.println("购买商品失败！");}} catch (Exception e) {lock.unlock();} finally {lock.unlock();}return "购买商品失败！";}
}

分布式下：

而在服务器分布式集群下，，单个服务器的synchronized和ReentrantLock

 

1.SETNX

SET key value [EX seconds] [PX milliseconds] [NX|XX]
  • EX seconds – 设置键key的过期时间，单位时秒
  • PX milliseconds – 设置键key的过期时间，单位时毫秒
  • NX – 只有键key不存在的时候才会设置key的值
  • XX – 只有键key存在的时候才会设置key的值

例子：

1.set lock01 01 NX ：意思就是说只要谁把key为lock01的值设置为01且key不存在的时候就能拿到锁

2. set lock01 01 NX EX 30 ：在例1的基础上把锁设置的时间设置为30秒后过期。避免有服务挂了而没有释放锁的情况、或者业务处理完但一直拿着锁不释放导致死锁。

项目中使用SETNX：

  • template.opsForValue().setIfAbsent()

测试的话就得本机模拟集群，当然有虚拟机的也可以用两台虚拟机，但此处用两台JVM即可完成简易集群
本机实现集群的可以看这篇文章：http://t.csdn.cn/jvZFx

 先让集群跑起来，然后启动Nginx，再通过Jmeter实现高并发的秒杀环节

 用template.opsForValue().setIfAbsent()命令进行加锁。加上了过期时间后就解决了key无法删除的问题，但如果key设置的时间太短，当业务处理的时间长于key设置的时间，key过期后其他请求就可以设置这个key而当这个线程再回来处理这个程序的时候就会把人家设置的key给删除了，因此我们规定谁设置的锁只能由谁删除。

finally {// 谁加的锁，谁才能删除if(template.opsForValue().get(REDIS_LOCK).equals(value)){template.delete(REDIS_LOCK);}

而新的问题就是finally块的判断和del删除操作不是原子操作，并发的时候也会出问题。因此采用lua（原子性）来进行删除

finally {// 谁加的锁，谁才能删除，使用Lua脚本，进行锁的删除Jedis jedis = null;try{jedis = RedisUtils.getJedis();String script = "if redis.call('get',KEYS[1]) == ARGV[1] " +"then " +"return redis.call('del',KEYS[1]) " +"else " +"   return 0 " +"end";Object eval = jedis.eval(script, Collections.singletonList(REDIS_LOCK), Collections.singletonList(value));if("1".equals(eval.toString())){System.out.println("-----del redis lock ok....");}else{System.out.println("-----del redis lock error ....");}}catch (Exception e){}finally {if(null != jedis){jedis.close();}}

总的代码： 

@RestController
public class TestConrtoller3 {@Value("${server.port}")private String serverPort;public static final String REDIS_LOCK = "good_lock";@AutowiredStringRedisTemplate stringtemplate;@RequestMapping("/buy3")public String shopping(){// 每个人进来先要进行加锁，key值为"good_lock",且用UUID保证每个人的锁不同String value = UUID.randomUUID().toString().replace("-","");try{// 为key加一个过期时间Boolean flag = stringtemplate.opsForValue().setIfAbsent(REDIS_LOCK, value,10L,TimeUnit.SECONDS);// 加锁失败if(!flag){return "抢锁失败！";}System.out.println( value+ " 抢锁成功");String result = stringtemplate.opsForValue().get("goods:001");int total = result == null ? 0 : Integer.parseInt(result);if (total > 0) {// 如果在此处需要调用其他微服务，处理时间较长。。。int realTotal = total - 1;stringtemplate.opsForValue().set("goods:001", String.valueOf(realTotal));System.out.println("购买商品成功，库存还剩：" + realTotal + "，服务端口为"+serverPort);return "购买商品成功，库存还剩：" + realTotal + "服务端口为"+serverPort;} else {System.out.println("购买商品失败");}return "购买商品失败！";}finally {// 谁加的锁，谁才能删除，使用Lua脚本，进行锁的删除Jedis jedis = null;try{jedis = RedisUtils.getJedis();String script = "if redis.call('get',KEYS[1]) == ARGV[1] " +"then " +"return redis.call('del',KEYS[1]) " +"else " +"   return 0 " +"end";Object eval = jedis.eval(script, Collections.singletonList(REDIS_LOCK), Collections.singletonList(value));if("1".equals(eval.toString())){System.out.println("-----del redis lock ok....");}else{System.out.println("-----del redis lock error ....");}}catch (Exception e){}finally {if(null != jedis){jedis.close();}}}}
}

2.Redisson(推荐)

考虑缓存续命，以及Redis集群部署下，异步复制造成的锁丢失：主节点没来得及把刚刚set进来这条数据给从节点，就挂了。所以直接上RedLock的Redisson落地实现

@RestController
public class TestConrtoller4 {@Value("${server.port}")private String serverPort;public static final String REDIS_LOCK = "good_lock";@AutowiredStringRedisTemplate stringtemplate;@AutowiredRedisson redisson;@RequestMapping("/buy4")public String shopping(){RLock lock = redisson.getLock(REDIS_LOCK);lock.lock();// 每个人进来先要进行加锁，key值为"good_lock"String value = UUID.randomUUID().toString().replace("-","");try{String result = stringtemplate.opsForValue().get("goods:001");int total = result == null ? 0 : Integer.parseInt(result);if (total > 0) {// 如果在此处需要调用其他微服务，处理时间较长int realTotal = total - 1;stringtemplate.opsForValue().set("goods:001", String.valueOf(realTotal));System.out.println("购买商品成功，库存还剩：" + realTotal + "件， 服务端口为"+serverPort);return "购买商品成功，库存还剩：" + realTotal + "件， 服务端口为"+serverPort;} else {System.out.println("购买商品失败");}return "购买商品失败";}finally {if(lock.isLocked() && lock.isHeldByCurrentThread()){lock.unlock();}}}
}

Redis工具类

 
import com.myfutech.common.util.constant.RedisPrefix;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.RedisStringCommands;
import org.springframework.data.redis.connection.ReturnType;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.types.Expiration;import java.nio.charset.StandardCharsets;
import java.util.UUID;/*** 基于redis分布式锁*/
@Slf4j
public class RedisLockUtils {/*** 默认轮休获取锁间隔时间， 单位：毫秒*/private static final int DEFAULT_ACQUIRE_RESOLUTION_MILLIS = 100;private static final String UNLOCK_LUA;static {StringBuilder sb = new StringBuilder();sb.append("if redis.call(\"get\",KEYS[1]) == ARGV[1] ");sb.append("then ");sb.append("    return redis.call(\"del\",KEYS[1]) ");sb.append("else ");sb.append("    return 0 ");sb.append("end ");UNLOCK_LUA = sb.toString();}/*** 获取锁，没有获取到则一直等待，异常情况则返回null** @param redisTemplate     redis连接* @param key               redis key* @param expire            锁过期时间, 单位 秒* @return                  当前锁唯一id，如果没有获取到，返回 null*/public static String lock(RedisTemplate redisTemplate, final String key, long expire){return lock(redisTemplate, key, expire, -1);}/*** 获取锁，acquireTimeout时间内没有获取到，则返回null，异常情况返回null** @param redisTemplate     redis连接* @param key               redis key* @param expire            锁过期时间, 单位 秒* @param acquireTimeout    获取锁超时时间, -1代表永不超时, 单位 秒* @return                  当前锁唯一id，如果没有获取到，返回 null*/public static String lock(RedisTemplate redisTemplate, final String key, long expire, long acquireTimeout){try {return acquireLock(redisTemplate, key, expire, acquireTimeout);} catch (Exception e) {log.error("acquire lock exception", e);}return null;}/*** 获取锁，没有获取到则一直等待，没有获取到则抛出异常** @param redisTemplate     redis连接* @param key               redis key* @param expire            锁过期时间, 单位 秒* @return                  当前锁唯一id，如果没有获取到，返回 null*/public static String lockFailThrowException(RedisTemplate redisTemplate, final String key, long expire){return lockFailThrowException(redisTemplate, key, expire, -1);}/*** 获取锁，到达超时时间时没有获取到，则抛出异常** @param redisTemplate     redis连接* @param key               redis key* @param expire            锁过期时间, 单位 秒* @param acquireTimeout    获取锁超时时间, -1代表永不超时, 单位 秒* @return                  当前锁唯一id，如果没有获取到，返回 null*/public static String lockFailThrowException(RedisTemplate redisTemplate, final String key, long expire, long acquireTimeout){try {String lockId = acquireLock(redisTemplate, key, expire, acquireTimeout);if (lockId != null) {return lockId;}throw new RuntimeException("acquire lock fail");} catch (Exception e) {throw new RuntimeException("acquire lock exception", e);}}private static String acquireLock(RedisTemplate redisTemplate, String key, long expire, long acquireTimeout) throws InterruptedException {long acquireTime = -1;if (acquireTimeout != -1) {acquireTime = acquireTimeout * 1000 + System.currentTimeMillis();}synchronized (key) {String lockId = UUID.randomUUID().toString();while (true) {if (acquireTime != -1 && acquireTime < System.currentTimeMillis()) {break;}//调用tryLockboolean hasLock = tryLock(redisTemplate, key, expire, lockId);//获取锁成功if (hasLock) {return lockId;}Thread.sleep(DEFAULT_ACQUIRE_RESOLUTION_MILLIS);}}return null;}/***  释放锁** @param redisTemplate     redis连接* @param key               redis key* @param lockId            当前锁唯一id*/public static void unlock(RedisTemplate redisTemplate, String key, String lockId) {try {RedisCallback<Boolean> callback = (connection) ->connection.eval(UNLOCK_LUA.getBytes(StandardCharsets.UTF_8),ReturnType.BOOLEAN, 1,(RedisPrefix.LOCK_REDIS_PREFIX + key).getBytes(StandardCharsets.UTF_8), lockId.getBytes(StandardCharsets.UTF_8));redisTemplate.execute(callback);} catch (Exception e) {log.error("release lock exception", e);}}/*** 获取当前锁的id** @param key       redis key* @return          当前锁唯一id*/public static String get(RedisTemplate redisTemplate, String key) {try {RedisCallback<String> callback = (connection) -> {byte[] bytes = connection.get((RedisPrefix.LOCK_REDIS_PREFIX + key).getBytes(StandardCharsets.UTF_8));if (bytes != null){return new String(bytes, StandardCharsets.UTF_8);}return null;};return (String)redisTemplate.execute(callback);} catch (Exception e) {log.error("get lock id exception", e);}return null;}private static boolean tryLock(RedisTemplate redisTemplate, String key, long expire, String lockId) {RedisCallback<Boolean> callback = (connection) ->connection.set((RedisPrefix.LOCK_REDIS_PREFIX + key).getBytes(StandardCharsets.UTF_8),lockId.getBytes(StandardCharsets.UTF_8), Expiration.seconds(expire), RedisStringCommands.SetOption.SET_IF_ABSENT);return (Boolean)redisTemplate.execute(callback);}
}

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

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

相关文章

UE4 关闭steamvr自启动

UE4 关闭steamvr自启动

在我们打开项目时&#xff0c;如果安装过steamvr会自动启动&#xff0c;因为steamvr插件是默认启用的&#xff0c;所以把引擎目录下的steamvr插件默认启动改为false就可以了 用记事本打开SteamVR.uplugin文件 把true改成false
阅读更多...
node基于express+mongodb项目的整体结构搭建和逻辑抽离

node基于express+mongodb项目的整体结构搭建和逻辑抽离

一、为什么需要逻辑抽离 这是我用express实现的一个缩减版的注册功能,如下&#xff1a; app.js const express require("express"); const app express();// 连接数据库 const mongoose require("mongoose"); // 连接数据库myTest mongoose.connect(…
阅读更多...
Stable Diffusion - After Detailer 插件 脸部和手部 重绘算法与应用

Stable Diffusion - After Detailer 插件 脸部和手部 重绘算法与应用

欢迎关注我的CSDN&#xff1a;https://spike.blog.csdn.net/ 本文地址&#xff1a;https://spike.blog.csdn.net/article/details/131699857 After Detailer 是一个用于 Stable Diffusion Webui 的扩展插件&#xff0c;可以自动检测、遮盖和修复图片中的人脸、手部或全身&#…
阅读更多...
Java 的集合

Java 的集合

一、Collection 1、ArrayList 底层采用数组实现&#xff0c;操作大多基于对数组的操作。 在添加和删除时需要做 System.arraycopy(native层方法) 拷贝工作。 添加元素时可能会扩容&#xff0c;这要大量的拷贝工作&#xff0c;删除元素时&#xff0c;会把后面的元素向前拷贝。…
阅读更多...
【NLP】Transformer模型原理（2）

【NLP】Transformer模型原理（2）

接上文 【NLP】Transformer模型原理（1） 六、零层的transformer 观看涵盖与本节类似内容的视频：0 层理论 在进入更复杂的模型之前，简要考虑一下“零层”变压器很有用。这样的模型获取一个令牌，嵌入它，解嵌它以生成预测下一个令牌的对数： ​
阅读更多...
Ext4文件系统介绍 - 实战篇

Ext4文件系统介绍 - 实战篇

本文主要通过dd&#xff0c;hexdump和dumpe2fs工具分析ext4的磁盘二进制数据&#xff0c;加深对ext4文件系统的印象&#xff0c;要想理解本建议先阅读下Ext4文件系统介绍 - 理论篇_nginux的博客-CSDN博客。 磁盘超级块数据分析 根据理论篇我们知道ext4 layout中前1024字节是x…
阅读更多...
抖音seo源码矩阵系统开发规则开发者分享（一）

抖音seo源码矩阵系统开发规则开发者分享（一）

抖音SEO矩阵系统源码开发&#xff0c;需要遵循一下步骤 1. 确定需求和功能&#xff1a;明确系统的主要目标和需要实现的功能&#xff0c;包括关键词研究、短视频制作、外链建设、数据分析、账号设置优化等方面。 2. 设计系统架构&#xff1a;根据需求和功能确定系统的架构&am…
阅读更多...
数据结构--绪论

数据结构--绪论

这里写目录标题 前言数据结构研究内容基本概念与术语数据元素与数据对象的区别数据结构逻辑结构存储结构 数据类型和抽象数据类型数据类型抽象数据类型定义格式举例 小结研究内容基础概念 抽象数据类型的表示和实现 算法与分析算法的设计要求算法效率事前分析法例子 算法时间的…
阅读更多...
【导航地图DB-kiwi地图格式】

【导航地图DB-kiwi地图格式】

背景知识&#xff1a; kiwi趣闻: kiwi是新西兰的一种鸟的名称&#xff0c;Kiwi鸟是尾巴翅膀极短不会飞的鸟&#xff0c;非常珍贵&#xff0c;只在新西兰僻静的丛林里才能见到&#xff0c;所以成为新西兰的国鸟。Kiwi鸟…
阅读更多...
【iOS内存管理-内存的几大区域】

【iOS内存管理-内存的几大区域】

前言 iOS内存管理的第一篇章&#xff0c;了解iOS内存的五大分区。 总览 iOS中&#xff0c;内存主要分为五大区域&#xff1a;栈区&#xff0c;堆区&#xff0c;全局区/静态区&#xff0c;常量区和代码区。总览图如下。 如上图所示&#xff0c;代码区是在低地址段存放&#x…
阅读更多...
4. CSS用户界面样式

4. CSS用户界面样式

4.1什么是界面样式 所谓的界面样式,就是更改一些用户操作样式,以便提高更好的用户体验。 ●更改用户的鼠标样式 ●表单轮廓 ●防止表单域拖拽 4.2鼠标样式cursor li {cursor: pointer; }设置或检索在对象上移动的鼠标指针采用何种系统预定义的光标形状。 4.3轮廓线outline…
阅读更多...
FTP挂载网络磁盘

FTP挂载网络磁盘

项目中使用存储阵列或NAS等网络存储作为文件存储地址&#xff0c;服务器与存储之间通过网络进行传输&#xff0c;当我把ftp指向的存储地址修改为网络磁盘时&#xff0c;会出现550等读取不到目录问题&#xff1b;以下为解决方案&#xff1a; 1.在服务器中新增windows用户&#x…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023