11.30_黑马Redis实战篇分布式锁

 实战篇9

设立一个在jvm外的锁监视器，可以处理多线程的问题

 

实战篇10 

 获取锁的时候，要同时发生获取锁以及设置到期时间。

实战篇11 

thinking：JAVA中的自动拆箱与装箱？

【Java基础】自动拆装箱_Elephant_King的博客-CSDN博客

 

 

 

 

 

TRUE.equals():保证不会有空指针异常。 

package com.hmdp.utils;public interface ILock {/*** 尝试获取锁* @param timeoutSec 锁持有的超时时间，过期后自动释放* @return true代表获取锁成功；false代表获取锁失败*/boolean tryLock(long timeoutSec);/*** 释放锁*/void unlock();
}
package com.hmdp.utils;
import org.springframework.data.redis.core.StringRedisTemplate;
import java.util.concurrent.TimeUnit;
public class SimpleRedisLock implements ILock {private String name;private StringRedisTemplate stringRedisTemplate;private static final String KEY_PREFIX = "lock:";public SimpleRedisLock(String name, StringRedisTemplate stringRedisTemplate) {this.name = name;this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean tryLock(long timeoutSec) {//获取线程标示long threadId = Thread.currentThread().getId();//释放锁Boolean success = stringRedisTemplate.opsForValue().setIfAbsent(KEY_PREFIX + name, threadId + "", timeoutSec, TimeUnit.SECONDS);return Boolean.TRUE.equals(success);}@Overridepublic void unlock() {//释放锁stringRedisTemplate.delete(KEY_PREFIX + name);}
}
package com.hmdp.service.impl;import com.hmdp.dto.Result;
import com.hmdp.entity.SeckillVoucher;
import com.hmdp.entity.User;
import com.hmdp.entity.Voucher;
import com.hmdp.entity.VoucherOrder;
import com.hmdp.mapper.VoucherOrderMapper;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.IVoucherOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmdp.utils.RedisIdWorker;
import com.hmdp.utils.SimpleRedisLock;
import com.hmdp.utils.UserHolder;
import org.springframework.aop.framework.AopContext;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import javax.annotation.Resource;
import java.time.LocalDateTime;/*** <p>*  服务实现类* </p>** @author 虎哥* @since 2021-12-22*/
@Service
public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {@Resourceprivate ISeckillVoucherService seckillVoucherService;@Resourceprivate RedisIdWorker redisIdWorker;@Resourceprivate StringRedisTemplate stringRedisTemplate;@Overridepublic Result seckillVoucher(Long voucherId) {//1，查询优惠券SeckillVoucher voucher = seckillVoucherService.getById(voucherId);//2，判断秒杀是否开始if (voucher.getBeginTime().isAfter(LocalDateTime.now())) {//尚未开始return Result.fail("秒杀尚未开始！");}//3，判断秒杀是否已经结束if (voucher.getBeginTime().isBefore(LocalDateTime.now())) {//已经结束return Result.fail("秒杀已经结束！");}//4，判断库存是否充足if (voucher.getStock() < 1) {//库存不足return Result.fail("库存不足！");}//一人一锁，提高效率//intern 保证指定的userId对应指定的锁//先获取锁，再完成以下方法，先完成方法，再释放锁，才能确保线程安全Long userId = UserHolder.getUser().getId();//synchronized(userId.toString().intern()){//获取代理对象（事务）//创建锁对象SimpleRedisLock lock = new SimpleRedisLock("order" + userId, stringRedisTemplate);//获取锁boolean isLock = lock.tryLock(1200);//判断是否获取锁成功if(!isLock){//获取锁失败，返回错误或重试return Result.fail("不允许重复下单");}try {//获取代理对象（事务）IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();return proxy.createVoucherOrder(voucherId);} finally {//释放锁lock.unlock();}// }}//加上事务，因为这里有两张表@Transactionalpublic  Result createVoucherOrder(Long voucherId) {//5，一人一单Long userId = UserHolder.getUser().getId();//5.1 查询订单int count = query().eq("user_id", userId).eq("voucher_id", voucherId).count();//5.2 判断是否存在if (count > 0) {// 用户已经购买过了return Result.fail("用户已经购买过一次！");}//6，扣减库存boolean success = seckillVoucherService.update().setSql("stock = stock - 1").eq("voucher_id", voucherId).gt("stock", 0).update();if (!success) {//扣除失败return Result.fail("库存不足！");}//7，创建订单VoucherOrder voucherOrder = new VoucherOrder();//7.1 订单idlong orderId = redisIdWorker.nextId("order");voucherOrder.setId(orderId);//7.2 用户idvoucherOrder.setUserId(userId);//7.3 优惠券idvoucherOrder.setVoucherId(voucherId);save(voucherOrder);//8，返回订单idreturn Result.ok(orderId);}}

thinking：我怎么知道什么时候要处理异常？ 

 最全最详细的Java异常处理机制_两个系统对接 另一个系统有异常_我是波哩个波的博客-CSDN博客

实战篇12

 设置锁的标识，避免误删别人的锁，以达到避免多线程并发的情况发生

实战篇13

thinking：hutool的UUID？

【工具类用法】Hutool里的生成唯一Id唯的工具类_hutool生成uuid-CSDN博客

 thinking：java中long和string互转？

java中long和string互转_long转换string-CSDN博客

package com.hmdp.utils;
import cn.hutool.core.lang.UUID;
import org.springframework.data.redis.core.StringRedisTemplate;
import java.util.concurrent.TimeUnit;
public class SimpleRedisLock implements ILock {private String name;private StringRedisTemplate stringRedisTemplate;private static final String KEY_PREFIX = "lock:";private static final String ID_PREFIX = UUID.randomUUID().toString(true)+"-";public SimpleRedisLock(String name, StringRedisTemplate stringRedisTemplate) {this.name = name;this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean tryLock(long timeoutSec) {//获取线程标示String threadId = ID_PREFIX + Thread.currentThread().getId();//释放锁Boolean success = stringRedisTemplate.opsForValue().setIfAbsent(KEY_PREFIX + name, threadId, timeoutSec, TimeUnit.SECONDS);return Boolean.TRUE.equals(success);}@Overridepublic void unlock() {//获取线程标示String threadId = ID_PREFIX + Thread.currentThread().getId();//获取锁中的标示String id = stringRedisTemplate.opsForValue().get(KEY_PREFIX + name);//判断标示是否一致if(threadId.equals(id)){//释放锁stringRedisTemplate.delete(KEY_PREFIX + name);}}
}

实战篇14

如果仅仅用id 两个不同的jvm就会出现两个相同的id 也有可能出现bug。因此，要将这块原子性，因为当线程一因为回收垃圾产生阻塞情况，而锁因为超时而释放时，线程二就有机会趁机而入，从而获取锁，从而发生多线程并发的情况

实战篇15

lua的使用手册

Lua 教程 | 菜鸟教程

实战篇16

thinking：没有lua标志？

 

解决方案：下载其中一个就好，不要两个都下载，两个插件效果是一样的。两个都下载会导致idea卡死的哦。

 

LUA：
 

--比较线程标示与锁中的标示是否一致
if(redis.call('get',KEYS[1])== ARGV[1])then--释放锁 del keyreturn redis.call('del',KEYS[1])
end
return 0

 

JAVA：
 

package com.hmdp.utils;
import cn.hutool.core.lang.UUID;
import org.apache.ibatis.javassist.ClassPath;
import org.springframework.core.io.ClassPathResource;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;import java.util.Collection;
import java.util.Collections;
import java.util.concurrent.TimeUnit;
public class SimpleRedisLock implements ILock {private String name;private StringRedisTemplate stringRedisTemplate;private static final String KEY_PREFIX = "lock:";private static final String ID_PREFIX = UUID.randomUUID().toString(true)+"-";//提前读好这个文件，避免多次读取private static final DefaultRedisScript<Long> UNLOCK_SCRIPT;//因为是静态的，因此在静态代码块里面搞static {UNLOCK_SCRIPT = new DefaultRedisScript<>();UNLOCK_SCRIPT.setLocation(new ClassPathResource("unlock.lua"));UNLOCK_SCRIPT.setResultType(Long.class);}public SimpleRedisLock(String name, StringRedisTemplate stringRedisTemplate) {this.name = name;this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean tryLock(long timeoutSec) {//获取线程标示String threadId = ID_PREFIX + Thread.currentThread().getId();//释放锁Boolean success = stringRedisTemplate.opsForValue().setIfAbsent(KEY_PREFIX + name, threadId, timeoutSec, TimeUnit.SECONDS);return Boolean.TRUE.equals(success);}@Overridepublic void unlock() {//调用lua脚本stringRedisTemplate.execute(UNLOCK_SCRIPT, Collections.singletonList(KEY_PREFIX+name),ID_PREFIX + Thread.currentThread().getId());}
//    @Override
//    public void unlock() {
//        //获取线程标示
//        String threadId = ID_PREFIX + Thread.currentThread().getId();
//        //获取锁中的标示
//        String id = stringRedisTemplate.opsForValue().get(KEY_PREFIX + name);
//        //判断标示是否一致
//        if(threadId.equals(id)){
//            //释放锁
//            stringRedisTemplate.delete(KEY_PREFIX + name);
//        }}
 

 
 

 
 

实战篇17
 

 
 

 

这个网站不知道为什么打不开。。
 

实战篇18
 

 <dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.13.6</version></dependency>
 

package com.hmdp.config;import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RedissonConfig {@Beanpublic RedissonClient redissonClient(){//配置Config config = new Config();config.useSingleServer().setAddress("redis://localhost:6379");//创建RedissonClient对象return Redisson.create(config);}
}
 

package com.hmdp.service.impl;import com.hmdp.dto.Result;
import com.hmdp.entity.SeckillVoucher;
import com.hmdp.entity.User;
import com.hmdp.entity.Voucher;
import com.hmdp.entity.VoucherOrder;
import com.hmdp.mapper.VoucherOrderMapper;
import com.hmdp.service.ISeckillVoucherService;
import com.hmdp.service.IVoucherOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmdp.utils.RedisIdWorker;
import com.hmdp.utils.SimpleRedisLock;
import com.hmdp.utils.UserHolder;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.aop.framework.AopContext;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import javax.annotation.Resource;
import java.time.LocalDateTime;/*** <p>*  服务实现类* </p>** @author 虎哥* @since 2021-12-22*/
@Service
public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {@Resourceprivate ISeckillVoucherService seckillVoucherService;@Resourceprivate RedisIdWorker redisIdWorker;@Resourceprivate StringRedisTemplate stringRedisTemplate;@Resourceprivate RedissonClient redissonClient;@Overridepublic Result seckillVoucher(Long voucherId) {//1，查询优惠券SeckillVoucher voucher = seckillVoucherService.getById(voucherId);//2，判断秒杀是否开始if (voucher.getBeginTime().isAfter(LocalDateTime.now())) {//尚未开始return Result.fail("秒杀尚未开始！");}//3，判断秒杀是否已经结束if (voucher.getBeginTime().isBefore(LocalDateTime.now())) {//已经结束return Result.fail("秒杀已经结束！");}//4，判断库存是否充足if (voucher.getStock() < 1) {//库存不足return Result.fail("库存不足！");}//一人一锁，提高效率//intern 保证指定的userId对应指定的锁//先获取锁，再完成以下方法，先完成方法，再释放锁，才能确保线程安全Long userId = UserHolder.getUser().getId();//synchronized(userId.toString().intern()){//获取代理对象（事务）//创建锁对象// SimpleRedisLock lock = new SimpleRedisLock("order:" + userId, stringRedisTemplate);RLock lock = redissonClient.getLock("lock:order:" + userId);//获取锁//不传参数，代表我失败了立即返回boolean isLock = lock.tryLock();//判断是否获取锁成功if(!isLock){//获取锁失败，返回错误或重试return Result.fail("不允许重复下单");}try {//获取代理对象（事务）IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();return proxy.createVoucherOrder(voucherId);} finally {//释放锁lock.unlock();}// }}//加上事务，因为这里有两张表@Transactionalpublic  Result createVoucherOrder(Long voucherId) {//5，一人一单Long userId = UserHolder.getUser().getId();//5.1 查询订单int count = query().eq("user_id", userId).eq("voucher_id", voucherId).count();//5.2 判断是否存在if (count > 0) {// 用户已经购买过了return Result.fail("用户已经购买过一次！");}//6，扣减库存boolean success = seckillVoucherService.update().setSql("stock = stock - 1").eq("voucher_id", voucherId).gt("stock", 0).update();if (!success) {//扣除失败return Result.fail("库存不足！");}//7，创建订单VoucherOrder voucherOrder = new VoucherOrder();//7.1 订单idlong orderId = redisIdWorker.nextId("order");voucherOrder.setId(orderId);//7.2 用户idvoucherOrder.setUserId(userId);//7.3 优惠券idvoucherOrder.setVoucherId(voucherId);save(voucherOrder);//8，返回订单idreturn Result.ok(orderId);}}
 

实战篇20
 

 

 

实战篇21 
 

 

 

 

 












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


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












相关文章










虚幻学习笔记4—文本内容处理








虚幻学习笔记4—文本内容处理




一、前言 本文使用的虚幻引擎5.3.2&#xff0c;在虚幻中已经集成了很多可以直接处理多样化文本的蓝图&#xff0c;比如格式化动态显示、浮点数多样化等。 
二、实现 
2.1、格式化文本显示动态内容&#xff1a;在设置某个文本时可以使用“Format Text”蓝图设置自定义可以的显示…




阅读更多...

















传统算法：使用 Pygame 实现归并排序








传统算法：使用 Pygame 实现归并排序




使用 Pygame 模块实现了归并排序的动画演示。首先，它生成一个包含随机整数的数组，并通过 Pygame 在屏幕上绘制这个数组的条形图。接着，通过归并排序算法对数组进行排序，动画效果可视化每一步的排序过程。在排序的过程中，程序将数组递归地分成两半，分别进行排序，然后再将…




阅读更多...

















Spring Security 6.x 系列（7）—— 源码分析之Builder设计模式








Spring Security 6.x 系列（7）—— 源码分析之Builder设计模式




一、Builder设计模式 
WebSecurity、HttpSecurity、AuthenticationManagerBuilder 都是框架中的构建者&#xff0c;把他们放到一起看看他们的共同特点&#xff1a; 
查看AuthenticationManagerBuilder的继承结构图&#xff1a; 查看HttpSecurity的继承结构图&#xff1a; 查看W…




阅读更多...

















正反转马达驱动芯片 D6287F，驱 动 电 流 达 1.0A，应用于VCRs及 音 频 设 备 等 电 机 的 驱 动 中








正反转马达驱动芯片 D6287F，驱 动 电 流 达 1.0A，应用于VCRs及 音 频 设 备 等 电 机 的 驱 动 中




D6287F 是 一 块 正 反 转 马 达 驱 动 电 路 &#xff0c;两 种 逻 辑 输 入 方 式 可 控 制 马 达 的 正 转 、 反 转 、 停 止 、 中 断 等 。 内 置 马 达 停 止 时 省 电 电 路 及 热 保 护 电 路 。 最 大 驱 动 电 流 达 1.0A  。 广 泛 用 于 VCRs及 音 频 设 备 等 电…




阅读更多...

















FL Studio21.1.1.3750中文版是数字音频工作站 (DAW)








FL Studio21.1.1.3750中文版是数字音频工作站 (DAW)




FL Studio水果音乐编曲软件中文版,一款强大的音乐制作软件,可以进行音乐编曲、剪辑、录音、混音。FL Studio21.1.1.3750中文版是数字音频工作站 (DAW) 之一&#xff0c;日新月异。它是一款录音机和编辑器&#xff0c;可让您不惜一切代价制作精美的音乐作品并保存精彩的活动画廊…




阅读更多...

















JavaEE——简单认识CSS








JavaEE——简单认识CSS




文章目录 一、简单了解什么是 CSS二、CSS 选择器1.标签选择器2.类选择器3.ID 选择器4.后代选择器5.子选择器6.伪类选择器 三、字体属性1.设置字体家族2.设置字体大小3.设置字体粗细4.文字倾斜 四、文本属性1.文本对齐2.文本装饰3.文本缩进4.背景设置 五、圆角矩形六、CSS 盒子模…




阅读更多...

















Kotlin学习——kt里的作用域函数scope function，let，run，with，apply，also








Kotlin学习——kt里的作用域函数scope function，let，run，with，apply，also




Kotlin 是一门现代但已成熟的编程语言&#xff0c;旨在让开发人员更幸福快乐。 它简洁、安全、可与 Java 及其他语言互操作&#xff0c;并提供了多种方式在多个平台间复用代码&#xff0c;以实现高效编程。 
https://play.kotlinlang.org/byExample/01_introduction/02_Functio…




阅读更多...

















剑指 Offer（第2版）面试题 11：旋转数组的最小数字








剑指 Offer（第2版）面试题 11：旋转数组的最小数字




剑指 Offer&#xff08;第2版&#xff09;面试题 11&#xff1a;旋转数组的最小数字 剑指 Offer&#xff08;第2版&#xff09;面试题 11&#xff1a;旋转数组的最小数字解法1&#xff1a;二分查找 剑指 Offer&#xff08;第2版&#xff09;面试题 11&#xff1a;旋转数组的最小…




阅读更多...

















LeetCode（45）最长连续序列【哈希表】【中等】








LeetCode（45）最长连续序列【哈希表】【中等】




目录 1.题目2.答案3.提交结果截图 链接&#xff1a; 最长连续序列 1.题目 
给定一个未排序的整数数组 nums &#xff0c;找出数字连续的最长序列&#xff08;不要求序列元素在原数组中连续&#xff09;的长度。 
请你设计并实现时间复杂度为 O(n) 的算法解决此问题。 
示例 1&a…




阅读更多...

















鸿蒙原生应用/元服务开发-开发者如何进行真机测试








鸿蒙原生应用/元服务开发-开发者如何进行真机测试




前提条件&#xff1a;已经完成鸿蒙原生应用/元服务开发&#xff0c;已经能相对熟练使用DevEco Studio,开发者自己有鸿蒙4.0及以上的真机设备。 真机测试具体流程如下 
1.手机打开开发者模式 2.在项目中&#xff0c;左上角 文件(F)->项目结构 进行账号连接   3.运行




阅读更多...

















基于AT89C51单片机的电子闹钟设计








基于AT89C51单片机的电子闹钟设计




1&#xff0e;设计任务 
利用AT89C51单片机为核心控制元件,设计一个电子闹钟&#xff0c;设计的系统实用性强、操作简单&#xff0c;实现了智能化、数字化。 
&#xff08;1&#xff09;按开始键自动进入时间显示&#xff0c;开始为0&#xff0c;按K1键进入更改时间&#xff0c…




阅读更多...

















C++核心编程——运算符重载








C++核心编程——运算符重载




C核心编程——运算符重载 运算符重载的方法运算符重载函数作成员函数与友元函数重载双目运算符重载单目运算符重载流插入运算符和"<<"和流提取运算符">>"重载流插入运算符和"<<"流提取运算符">>" 运算符重载的…




阅读更多...


















推荐文章












最新文章


















Copyright @ 2022~2023