一起唠唠分布式锁

(1)分布式锁和分布式事务的区别

1.分布式锁是在集群环境下,用来控制不同机器对全局共享资源的访问。
2.分布式事务是在集群环境下,用来保证全局事务的一致性,保证多个数据库的数据整体上能正确的从一个一致性状态转到另一个一致性状态。

(2)分布式锁应用场景

在我们的某个jvm应用程序中,如果需要对某个共享变量进行多线程同步访问,可以使用java多线程的同步工具,例如ReentrantLock、Synchronized等等。但是当我们的系统由单机部署演化成为分布式集群系统后,在不同机器上原来单机的并发控制锁策略就会失效了,这时就需要引入分布式锁。
举个简单的例子,比如某个外卖骑士每天需要购买一份保险,某天在购买保险时,这个骑士多次点击了买保险的按钮,前端没有做控制,导致同时向服务器发送了多个买保险请求,那这个时候就会导致骑士多次购买保险,为了解决这个问题,我们可以使用分布式锁,保证在某个时间段内,只能有一台机器执行买保险操作,这时就能保障骑士不会多次购买保险。分布式锁主要有三种实现方式:

  1. 基于数据库实现
  2. 基于redis实现
  3. 基于ZooKeeper实现

(3)分布式锁实现方式

1.基于数据库实现

我们可以通过数据库表来实现分布式锁,表结构如下:在这里插入图片描述
表中的每一条记录就代表一个锁,当我们需要获取锁时就去数据库中查询是否有该共享资源的记录。
(1)如果有则获取其中的node_info,与自己的机器信息进行比较,如果发现是自己已经获取过的锁,那直接使用共享资源,将count数加1,在使用完数据后将count数减1,当count数为0时将记录删除掉。否则就返回错误信息,提示已经有人获取了锁。
(2)如果获取不到就建立一条记录,那就自己建立一条记录,并记录下自己的机器信息,然后使用共享资源。
在这里插入图片描述
上面其实就是利用数据库实现锁的简单方式。这种方式存在比较严重的问题:1.数据库机器可能存在单点、2.没有超时时间,数据库宕掉后可能导致无法获取锁、3.数据库是磁盘文件,获取锁的时间和性能并不好。

2.基于redis实现

基于redis的分布式锁,主要依赖于redis的几个命令:

  1. setnx():set if not exists,其主要有两个参数 setnx(key, value)。该方法是原子的,如果 key 不存在,则设置当前 key 成功,返回 1;如果当前 key 已经存在,则设置当前 key 失败,返回 0。
  2. expire():expire 设置过期时间,要注意的是 setnx 命令不能设置 key 的超时时间,只能通过 expire() 来对 key 设置。

使用步骤:
1、setnx(lockkey, 1) 如果返回 0,则获取锁失败;如果返回 1,则说明获取锁成功。
2、expire() 命令对 lockkey 设置超时时间,为的是避免死锁。
3、执行完业务代码后,可以通过 delete 命令删除 key。

使用问题:
上面的使用方式是能满足我们大部分的业务需求的,但是在某些极端的情况下,还是会存在问题。

  1. 问题: 当节点A执行完setnx后,节点A就宕掉了,还没来得及执行expire,那么会导致其他节点一直无法获取锁。
    在这里插入图片描述
    解决方案: 使用set命令代替setnx和expire。
// NX表示:key不存在就返回true,存在就返回false
// PX表示:指定的过期时间
SET lockName value NX PX
  1. 问题: 节点A获取了锁,并设置了30秒的过期时间,但是由于某些原因业务代码执行了很久(超过了30秒),delete操作还没执行。这时因为节点A获取的锁过期了,节点B获取了锁,而节点A执行了delete操作,释放了节点B的锁。
    在这里插入图片描述
    解决方案: 在通过delete操作释放锁之前判断当前的锁是不是自己加的。

当然我们也可以使用RedLock,RedLock是redis实现的分布式锁算法(RedLock),可以有效防止单点故障 。另外还有基于Zookeeper的实现,对于Zookeeper我不咋懂,所以这里就不写了。
在这里插入图片描述

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

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

相关文章

luogu2577/bzoj1899 午餐 (贪心+dp)

首先,应该尽量让吃饭慢的排在前面,先按这个排个序 然后再来决定每个人到底去哪边 设f[i][j]是做到了第i个人,然后1号窗口目前的总排队时间是j,目前的最大总时间 有这个i和j的话,再预处理出前i个人的排队总时间sum[i]&a…

wpf中xps文档合并功能实现

原文:wpf中xps文档合并功能实现跟着上一篇的xps文档套打的文章,近期一直在研究xps打印技术,其中用户提到了一个需求,要求能够多页面进行打印,我的想法是,先生成xps文件,然后将文件读取出来以后,…

DCT(离散余弦变换(DiscreteCosineTransform))

离散余弦变换(Discrete Cosine Transform,简称DCT变换)是一种与傅立叶变换紧密相关的数学运算。在傅立叶级数展开式中,如果被展开的函数是实偶函数,那么其傅立叶级数中只包含余弦项,再将其离散化可导出余弦…

从源码看ConcurrentHashMap

简介 ConcurrentHashMap是线程安全的HashMap实现,这里主要研究JDK8后的ConcurrentHashMap,下面是ConcurrentHashMap的简单结构: ConcurrentHashMap基于HashMap的基本逻辑,通过CAS synchronized 来保证并发安全性。ConcurrentHas…

代码重构的方法

见:http://blog.csdn.net/u011889786/article/details/51865344 见:http://blog.csdn.net/weiky626/article/details/1602691 一.提取子函数 说白了就是一个大函数里,可以根据不同功能分成几个小函数,因为说不定,其他…

android 去掉标题栏、状态栏、横屏

// 去掉标题栏supportRequestWindowFeature(Window.FEATURE_NO_TITLE);// 全屏、隐藏状态栏getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN, WindowManager.LayoutParams.FLAG_FULLSCREEN);// 横屏setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION…

Spring Boot 整合Mybatis (一)

2019独角兽企业重金招聘Python工程师标准>>> 新建spring-boot项目&#xff0c;相关依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><de…

x264 的 cache详解

在这里和下一级别的分析中有必要先讲一下这个h->mb.cache&#xff08;没法讲&#xff0c;就是cache!&#xff09;。 x264_macroblock_cache_load将参考帧中某位置的&#xff08;重建后&#xff09;数据保存进cache&#xff0c;供参考和反复使用。 x264_macroblock_cache_s…

同步/异步阻塞/非阻塞

平时开发中经常会听大家说到什么同步阻塞、异步非阻塞等等名词&#xff0c;这里我谈下自己对这两个名词的理解&#xff0c;仅仅是个人观点&#xff0c;并不一定正确。 1.阻塞/非阻塞 我认为判定阻塞还是非阻塞&#xff0c;取决于线程所做的操作是否需要将线程挂起等待。 举个…

Repeater的使用

1.页面代码 如果要分页&#xff0c;那么页面开头必须写&#xff08;<% Register Src"~/Controls/Page.ascx" TagName"Page" TagPrefix"uc1" %>&#xff09; 并且分页&#xff0c;页脚<uc1:Page ID"Page2" runat"server&…

springboot 整合 mongodb实现 批量更新数据

现需求&#xff1a;需要批量将1000个数据先查询在更新到mongodb&#xff08;如果查询不到数据&#xff0c;则添加数据&#xff09; 1&#xff1a;工具类BathUpdateOptions 1 import org.springframework.data.mongodb.core.query.Query;2 import org.springframework.data.mong…

【开题报告】基于微信小程序的校园资讯平台的设计与实现

1.选题背景与意义 随着移动互联网的快速发展&#xff0c;微信成为了人们日常生活中不可或缺的工具之一。在校园生活中&#xff0c;学生们对于校园资讯的获取和交流需求也越来越高。然而&#xff0c;传统的校园资讯发布方式存在信息不及时、传播范围有限等问题&#xff0c;无法…

三种Cache写入方式原理简介

三种Cache写入方式原理简介 在386以上档次的微机中&#xff0c;为了提高系统效率&#xff0c;普遍采用Cache&#xff08;高速缓冲存储器&#xff09;&#xff0c;现在的系统甚至可以拥有多级Cache。Cache实际上是位于CPU与DRAM主存储器之间少量超高速的静态存储器&#xff08;S…

Minor GC和Full GC

我们在日常开发中可能经常会听大家谈论GC&#xff0c;但是其实很多人对GC的种类其实并不是很了解&#xff0c;接下来我们简单介绍下Minor GC和Full GC及他们的区别。 MinorGC&#xff1a; 也可以叫作新生代GC&#xff0c;指的是发生在新生代的垃圾收集动作。因为新生代中对象大…

linux安装软件的几种方法

见&#xff1a;http://blog.csdn.net/u010509774/article/details/50593231 一、rpm包安装方式步骤&#xff1a; 1、找到相应的软件包&#xff0c;比如soft.version.rpm&#xff0c;下载到本机某个目录&#xff1b; 2、打开一个终端&#xff0c;su -成root用户&#xff1b; …

Android NDK MediaCodec在ijkplayer中的实践

https://www.jianshu.com/p/41d3147a5e07 从API 21&#xff08;Android 5.0&#xff09;开始Android提供C层的NDK MediaCodec的接口。 Java MediaCodec是对NDK MediaCodec的封装&#xff0c;ijkplayer硬解通路一直使用的是Java MediaCodec接Surface的方式。 本文的主要内容是&a…

leetcode-49-字母异位词分组(神奇的哈希)

题目描述&#xff1a; 给定一个字符串数组&#xff0c;将字母异位词组合在一起。字母异位词指字母相同&#xff0c;但排列不同的字符串。 示例: 输入: ["eat", "tea", "tan", "ate", "nat", "bat"], 输出: [[&quo…

【精心总结】java内存模型和多线程必会知识

内存模型 &#xff08;1&#xff09;java内存模型到底是个啥子东西&#xff1f; java内存模型是java虚拟机规范定义的一种特定模型&#xff0c;用以屏蔽不同硬件和操作系统的内存访问差异&#xff0c;让java在不同平台中能达到一致的内存访问效果&#xff0c;是在特定的协议下…

工作流 activity 视频教程 + redis 视频教程 百度网盘分享地址

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到教程。 云盘下载都没有密码&#xff0c;直接下载&#xff0c;解压有密码&#xff1a;chongxiangmengxiangjiaoyu&#xff0c; 解压完成后就可以…

快速解决 GRADLE 项目下载 gradle-*-all.zip 慢的问题

1、首先根据项目中 gradle\wrapper\gradle-wrapper.properties 文件的 distributionUrl 属性的值 #Tue Feb 06 12:27:20 CET 2018 distributionBaseGRADLE_USER_HOME distributionPathwrapper/dists zipStoreBaseGRADLE_USER_HOME zipStorePathwrapper/dists distributionUrlht…