Tim

一枚野生程序员~

  • 主页
  • 分类
  • 标签
  • 归档
  • 关于
所有文章 工具

Tim

一枚野生程序员~

  • 主页
  • 分类
  • 标签
  • 归档
  • 关于

基于Redis实现分布式锁

阅读数:次 2019-12-08
字数统计: 1.4k字   |   阅读时长≈ 4分

在并发编程中,我们通过锁,来避免由于竞争而造成的数据不一致问题。通常,我们以synchronized 、Lock来使用它。 但是Java中的锁,只能保证在同一个JVM进程内中执行。如果在分布式集群环境下呢? 分布式锁的实现有很多,比如基于数据库、memcached、Redis、系统文件、zookeeper等。它们的核心的理念跟上面的过程大致相同。 本篇文章,主要讲如何用Redis的形式实现分布式锁。

1、秒杀示例

首先,下面的例子是一个特价商品得秒杀案例,直接看代码

mark

服务层

mark

mark

单个电脑上直接拿鼠标点链接肯定不会有问题,因为是串行的操作,接下用使用Apache ab工具模拟并发的情况:

http://httpd.apache.org/docs/2.0/programs/ab.html 这个是它的官网,使用说明里面也有,下面直接使用它进行模拟测压:

mark

经过测试之后发现:卖超了,意料之中的事情

mark

为什么会出现这种情况呢? 没有做同步呗,很正常,首先要解决的是数据同步问题

使用synchronized对方法加锁:

mark

加了synchronized之后肯定是数据同步了:

mark

但是速度却太慢了,无法实现细粒度控制,而且系统根本无法实现水平拓展,问题很多,下面用分布式锁来解决这些问题。

2、Redis的几个命令

http://www.redis.cn/commands/setnx.html 可以先看看这个文档:

第一个命令:SETNX

Design pattern: Locking with !SETNX
设计模式:使用!SETNX加锁
Please note that:
请注意:
不鼓励以下模式来实现the Redlock algorithm ,该算法实现起来有一些复杂,但是提供了更好的保证并且具有容错性。
无论如何,我们保留旧的模式,因为肯定存在一些已实现的方法链接到该页面作为引用。而且,这是一个有趣的例子说明Redis命令能够被用来作为编程原语的。
无论如何,即使假设一个单例的加锁原语,但是从 2.6.12 开始,可以创建一个更加简单的加锁原语,相当于使用SET命令来获取锁,并且用一个简单的 Lua 脚本来释放锁。该模式被记录在SET命令的页面中。
也就是说,SETNX能够被使用并且以前也在被使用去作为一个加锁原语。例如,获取键为foo的锁,客户端可以尝试一下操作:
SETNX lock.foo <current Unix time + lock timeout + 1>
如果客户端获得锁,SETNX返回1,那么将lock.foo键的Unix时间设置为不在被认为有效的时间。客户端随后会使用DEL lock.foo去释放该锁。
如果SETNX返回0,那么该键已经被其他的客户端锁定。如果这是一个非阻塞的锁,才能立刻返回给调用者,或者尝试重新获取该锁,直到成功或者过期超时。

第二个命令:GETSET

自动将key对应到value并且返回原来key对应的value。如果key存在但是对应的value不是字符串,就返回错误。

设计模式

GETSET可以和INCR一起使用实现支持重置的计数功能。举个例子:每当有事件发生的时候,一段程序都会调用INCR给key mycounter加1,但是有时我们需要获取计数器的值,并且自动将其重置为0。这可以通过GETSET mycounter “0”来实现:

其实就是先GET、再SET,所以返回SET之前的值

3、使用Redis实现分布式锁

首先搞清楚锁的是什么,即搞清楚什么是进行同步和互斥的数据,对于上面的秒杀系统示例程序来说,当然是商品,而且是同样的商品需要同步与互斥,假设现在是华为Mate30 Pro的秒杀活动,大家肯定买的都是这一款产品,所以其实需要关心的就是成交订单量和库存的关系,如果不进行同步与互斥,那么肯定会出现买超的情况,限量秒杀1000台,可能实际成交订单变成了1200或更多,所以需要进行数据的同步与互斥

我直接使用Docker跑了一个Redis实例

mark

测试通过可以使用!

pom文件引入redis-starter

mark

写入最基础的连接配置

mark

RedisLock实现:

mark

在秒杀系统中使用:

mark

在设计的时候把商品的Id设置为Key,当前时间+超时时间为Value

通过代码注释可以看清楚实现流程:

mark

如果锁未超时也是返回False,这说明别的线程已经持有锁!

4、Redis分布式锁的好处

保证了数据的同步与互斥,通过模拟10个线程模拟500次请求的结果,对了我还统计了一下未能成功获得锁的请求次数,本次实验是469次请求未能成功获得锁,所以订单成交了31个,仓库剩余99969份!

mark

另外分布式锁可以很好的支持分布式部署,本例中因为为了方便直接在一个服务中写死了,所以就不演示集群似的测试了。

效率上也是很大的进步:

使用Redis分布式锁:

使用synchronized:

赏

谢谢你请我喝咖啡

支付宝
微信
  • 本文作者: Tim
  • 本文链接: https://zouchanglin.cn/238802463.html
  • 版权声明: 本博客所有文章除特别声明外,均采用 CC BY-SA 4.0 许可协议。转载请注明出处!
  • JavaSE
  • JVM
  • 分布式
  • 分布式理论

扫一扫,分享到微信

重新认识volatile
TCP协议基本特性
  1. 1. 1、秒杀示例
  2. 2. 2、Redis的几个命令
  3. 3. 3、使用Redis实现分布式锁
  4. 4. 4、Redis分布式锁的好处
© 2017-2021 Tim
本站总访问量次 | 本站访客数人
  • 所有文章
  • 工具

tag:

  • 生活
  • Android
  • 索引
  • MySQL
  • 组件通信
  • Nginx
  • JavaSE
  • JUC
  • JavaWeb
  • 模板引擎
  • 前端
  • Linux
  • 计算机网络
  • Docker
  • C/C++
  • JVM
  • 上传下载
  • JavaEE
  • SpringCloud
  • Golang
  • Gradle
  • 网络安全
  • 非对称加密
  • IDEA
  • SpringBoot
  • Jenkins
  • 字符串
  • vim
  • 存储
  • 文件下载
  • Mac
  • Windows
  • NIO
  • RPC
  • 集群
  • 微服务
  • SSH
  • 配置中心
  • XML
  • Chrome
  • 压力测试
  • Git
  • 博客
  • 概率论
  • 排序算法
  • 分布式
  • 异常处理
  • 文件系统
  • 哈希
  • openCV
  • 栈
  • 回溯
  • SpringCore
  • 流媒体
  • rtmp
  • 面向对象
  • Vue
  • ElementUI
  • 软件工程
  • 异步
  • 自定义UI
  • ORM框架
  • 模块化
  • 交互式
  • Jsoup
  • Http Client
  • LRUCache
  • RabbitMQ
  • 消息通信
  • 服务解耦
  • 负载均衡
  • 权限
  • 多线程
  • 单例模式
  • Protobuf
  • 序列化
  • Python
  • m3u8
  • 堆
  • 二叉树
  • 自定义View
  • 观察者模式
  • 设计模式
  • 线程池
  • 动态扩容
  • 高可用
  • GC
  • ffmpeg
  • SpringMVC
  • REST
  • Redis
  • 缓存中间件
  • UML
  • Maven
  • Netty
  • 高性能网络
  • IPC通信
  • IO
  • Stream
  • 发布订阅
  • SQLite
  • Hash
  • 集合框架
  • 链表
  • Lambda
  • 汇编语言
  • 组件化
  • Router
  • 开发工具

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录(注意不是yilia-plus根目录)执行以下命令:
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置:

      jsonContent:
        meta: false
        pages: false
        posts:
          title: true
          date: true
          path: true
          text: false
          raw: false
          content: false
          slug: false
          updated: false
          comments: false
          link: false
          permalink: false
          excerpt: false
          categories: false
          tags: true
    

  • 思维导图
  • PDF工具
  • 无损放大
  • 代码转图
  • HTTPS证书