分布式锁的应用场景和三种实现方式的区别_负载均衡策略

分布式锁的应用场景和三种实现方式的区别_负载均衡策略多线程对同一资源的竞争,需要用到锁,例如Java自带的Synchronized、ReentrantLock。但只能用于单机系统中,如果涉及到分布式环境(多机器)的资源竞争,则需要分布式锁。分布式锁的主要作用:保证数据的正确性:比如:秒杀的时候防止商品超卖,表单重复提交,接口幂等性。避免重复处理数据:比如:调度任务在多台机器重复执行,缓存过期所有请求都去加载数据库。分布式锁的主要特性:互斥:同一时刻只能有一个线程获得锁。可重入:当一个线程获取锁后,还可以再次获取这个锁,避免死锁发生。高可用:当

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

应用场景

多线程对同一资源的竞争,需要用到锁,例如Java自带的Synchronized、ReentrantLock。
但只能用于单机系统中,如果涉及到分布式环境(多机器)的资源竞争,则需要分布式锁。

分布式锁的主要作用:

  1. 保证数据的正确性:
    比如:秒杀的时候防止商品超卖,表单重复提交,接口幂等性。
  2. 避免重复处理数据:
    比如:调度任务在多台机器重复执行,缓存过期所有请求都去加载数据库。

分布式锁的主要特性:

  1. 互斥:同一时刻只能有一个线程获得锁。
  2. 可重入:当一个线程获取锁后,还可以再次获取这个锁,避免死锁发生。
  3. 高可用:当小部分节点挂掉后,仍然能够对外提供服务。
  4. 高性能:要做到高并发、低延迟。
  5. 支持阻塞和非阻塞:Synchronized是阻塞的,ReentrantLock.tryLock()就是非阻塞的
  6. 支持公平锁和非公平锁:Synchronized是非公平锁,ReentrantLock(boolean fair)可以创建公平锁

分布式锁的知识图谱

在这里插入图片描述

分布式锁的实现方式

使用 MySQL 实现分布式锁

数据库表设计:

CREATE TABLE `distributed_lock` (
  `id` bigint unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',
  `resource_name` varchar(200) NOT NULL DEFAULT '' COMMENT '资源名称(唯一索引)',
  `owner` varchar(200) NOT NULL DEFAULT '' COMMENT '锁持有者(机器码+线程名称)',
  `lock_count` int NOT NULL DEFAULT '0' COMMENT '加锁次数',
  `expire_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '锁过期时间',
  PRIMARY KEY (`id`),
  UNIQUE KEY `uk_resource_name` (`resource_name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='分布式锁';
  1. 锁的实现原理:
    将用来竞争的资源名称设置为表的唯一索引。
    获取锁的时候,就插入一条记录。插入成功就代表获取到锁,插入失败就代表获取锁失败。
    释放锁的时候,就删除这条记录。
  2. 支持阻塞和非阻塞:
    可以用while循环直到插入成功,不过自旋也会占用CPU。
  3. 支持可重入:
    使用锁持有者owner和加锁次数字段lock_count实现可重入:
    获取锁,次数加一,释放锁,次数减一,次数为零就删除这把锁。
  4. 支持过期时间
    使用过期时间expire_time字段,通过异步任务检测避免因程序异常或机器宕机导致锁无法释放。
  5. 支持锁续期
    获取锁的同时,启动一个异步任务,每当业务执行到三分之一时间,也就是6秒中的第2秒的时候,就自动延长锁过期时间,继续延长到6秒,这样就能保证业务逻辑处理完成之前锁不会过期。

使用 Redis 实现分布式锁

由于MySQL并发性能跟不上,所以还可以使用Redis实现分布式锁。
获取锁,并设置过期时间:

// 1. 获取锁
redis.setnx('resource_name1', 'owner1')
// 2. 增加锁过期时间
redis.exprire('resource_name1', 6, TimeUnit.SECONDS)

但是setnxexprire两条命令不是原子的,可能获取锁之后还没来得及设置过期时间就宕机了。
所以可以使用Redis 2.6.12之后提供的一条复合命令:

redis.set('resource_name1', 'owner1',"NX" "EX", 6)

释放锁:

// 释放锁
if ('owner1'.equals(redis.get('resource_name1'))){ 
   
  redis.del('resource_name1')
}

释放锁时判断锁的持有者,可以避免把其他线程持有的锁给释放掉了。
但是getdel两条命令不是原子操作,需要引入Lua脚本把两条命令打包成一条发给Redis执行:

String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
redis.eval(script, Collections.singletonList('resource_name1'), Collections.singletonList('owner1'))

此外,实现锁续期的功能,可以使用Redis客户端的Redisson的WatchDog功能,在我们调用lock自动唤醒WatchDog

使用 Zookeeper 实现分布式锁

zookeeper采用树形节点,类似Linux目录文件结构,同一目录下的节点名称不能重复。
在这里插入图片描述
节点有分为四种类型:

**持久节点:**一旦创建,永久存储在服务器上,除非手动删除。
临时节点:生命周期与客户端绑定,客户端断开连接,节点就被自动删除。
**持久顺序节点:**特性同持久节点,只是在节点名称后面追加自增有序数字。
**临时顺序节点:**特性同临时节点,只是在节点名称后面追加自增有序数字。

zookeeper还有个监听-通知机制,客户端可以在资源节点上创建watch事件。当节点发生变化,会通知客户端,客户端可以根据变化做相应的业务处理。

我们可以利用临时顺序节点的特性创建分布式锁,分以下三步:

  1. 在资源/resource1目录下创建临时顺序节点node
  2. 获取/resource1目录下的所有节点,如果当前节点序号最小,代表加锁成功
  3. 如果不是,就是watch监听序号最小的节点

实现逻辑很简单,我们来分析一下zookeeper实现分布式锁的优点:

  1. 由于创建的临时节点,断开连接后自动删除,所以无需设置锁超时时间,也就不用考虑不释放和锁续期
  2. 由于节点上存储的创建人信息,锁也就支持可重入
  3. 由于可以监听节点,也就实现了可阻塞
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/196014.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • 二进制——减法「建议收藏」

    二进制——减法「建议收藏」二进制的减法分为两种:1.使用硬件减法器运算;2.将减法转换成加法运算。 本文讲述第二种方法。 大家都知道计算机有两种数值类型:1.有符号类型;2.无符号类型。 有符号类型是利用其二进制的最高位来存储正负标志的,所以有符号类型的最大值的绝对值要小于无符号类型,就是因为有符号类型比无符号类型少了一位数据位,大小当然就少一半了,但是两种类型所表示的数值的个数是一

  • python将py文件编译成exe文件_怎么把python程序打包成可执行文件

    python将py文件编译成exe文件_怎么把python程序打包成可执行文件1.安装PyInstaller2.指定要打包文件的路径,使用pyinsatll-F“路径”,如果不需要弹出框后缀–noconsole3.在下面这个目录中查找打包好的文件

  • Java static关键字详解

    Java static关键字详解static关键字在类中,用static声明的成员变量为静态成员变量,也成为类变量。类变量的生命周期和类相同,在整个应用程序执行期间都有效。这里要强调一下:static修饰的成员变量和方法,从属于类普通变量和方法从属于对象静态方法不能调用非静态成员,编译会报错static关键字的用途一句话描述就是:方便在没有创建对象的情况下进行调用(方法/变量)。显然,被sta…

  • cxf框架调用webservice_webservice json

    cxf框架调用webservice_webservice json本文主要包括以下内容ant工具的使用利用cxf实现webservicecxf与spring整合ajax访问webserviceant工具1、为什么要用到ant这个工具呢?Ant做为一种工具已经广泛被使用,并且历史悠久。使用ant的内置命令,可以编译java源文件(javac),运行java文件(java),给class文件打包(jar、war、ear),也可以创建(mkdir)、删除…

  • phpstrom 2021.12激活码[最新免费获取]

    (phpstrom 2021.12激活码)这是一篇idea技术相关文章,由全栈君为大家提供,主要知识点是关于2021JetBrains全家桶永久激活码的内容IntelliJ2021最新激活注册码,破解教程可免费永久激活,亲测有效,下面是详细链接哦~https://javaforall.cn/100143.html1435QFILVV-eyJsaWN…

  • Pytest(1)安装与入门[通俗易懂]

    Pytest(1)安装与入门[通俗易懂]pytest介绍pytest是python的一种单元测试框架,与python自带的unittest测试框架类似,但是比unittest框架使用起来更简洁,效率更高。根据pytest的官方网站介绍,它

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号