redis和zk实现分布式锁有什么区别_redis分布式锁和zk分布式锁区别

redis和zk实现分布式锁有什么区别_redis分布式锁和zk分布式锁区别前言本文介绍下分布式锁的一个使用场景分享本文的缘由是因为今天在写代码时需要处理一个原子性问题,场景是:业务功能需要先查询数据,再根据数据判断是否要更新数据,在这个查询+更新的过程必然会存在高并发下的原子性问题那么如何解决这个问题呢,那么就要说到我们的主角:分布式锁了分布式锁介绍分布式锁:即在多集群多节点环境下确保只有一个线程可以拿到锁,防止并发出现的问题,类似于synchronized,只不过synchronized不能处理多节点的问题解决上述问题的一种解决方式就是使用分布式锁,虽然性能会比较低

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

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

前言

本文介绍下分布式锁的一个使用场景
分享本文的缘由是因为今天在写代码时需要处理一个原子性问题,场景是:业务功能需要先查询数据,再根据数据判断是否要更新数据,在这个查询+更新的过程必然会存在高并发下的原子性问题

那么如何解决这个问题呢,那么就要说到我们的主角:分布式锁了

分布式锁介绍

分布式锁:即在多集群多节点环境下确保只有一个线程可以拿到锁,防止并发出现的问题,类似于synchronized,只不过synchronized不能处理多节点的问题

解决上述问题的一种解决方式就是使用分布式锁,虽然性能会比较低,但是笔者的场景是一个统计功能,并且是异步的,所以并不影响性能
核心代码如下:

场景介绍

try { 
   
	// 这里可以根据业务场景做分段锁,可以适当提升性能
	String lock = "lock_key";
	long keyValue = System.currentTimeMillis();
	// 获取锁,超时时间60秒每隔0.5秒尝试获取一次,60秒后没获取到则放弃
	boolean getLock = redisUtils.getLockByInterval(lock,keyValue,60,0.5,0);
	if(getLock) { 
   
		xxx
	}
} catch (Exception e) { 
   
  log.error("异常:", e);
} finally { 
   
    if(getLock) { 
   
        redisUtils.unLock(lock,keyValue);
    }
}

RedisUtils类getLockByInterval

  /** * 获取锁,如果没获取到那么每隔interval秒重试一次,重试直到timeout秒 * @param key * @param value * @param timeout 超时时间(单位秒) * @param interval 超时时间(单位秒) * @param currentTime 当前时间,调用时传0,只用于递归时间 * @return */
    public boolean getLockByInterval(String key,Object value,int timeout,double interval,double currentTime) { 
   
        if(currentTime > timeout) { 
   
            return false;
        }
        // 相当于redis的setnx命令
        boolean getLock = redisTemplate.opsForValue().setIfAbsent(key,value,timeout, TimeUnit.SECONDS);
        if(!getLock) { 
   
            //没有拿到锁就间隔interval再次尝试获取锁,直到总时间大于timeout
            try { 
   
                Thread.sleep(Double.valueOf(interval*1000).longValue());
            } catch (InterruptedException e) { 
   
                log.error("RedisUtils getLockByInterval error:",e);
            }
            currentTime += interval;
            // 递归
            return getLockByInterval(key,value,timeout,interval,currentTime);
        }
        return true;
    }

上述代码其实还是不够完美,当并发量足够大时可能存在某线程在超时时间内还是没有抢占到锁,因为获取锁的机制是按照间隔时间来获取的,并且属于非公平锁,即不是先到的线程有权利优先获取锁,这里可以看到redis的分布式锁并不是很友好,这里再介绍下zookeeper的分布式锁

分布式锁对比

redis分布式锁:通过redis通过的sexNx命令实现,即当key不存在时调用setNx返回true,否则返回false,获取不到锁的线程只能轮询去尝试获取锁
优点:性能高,使用简单,在允许偶发锁失效的场景下推荐使用
缺点:通过轮询抢占锁的机制不是很可靠,当某线程占用锁时间较长时可能导致其他线程抢占锁失败

zookeeper分布式锁:zk的分布式锁机制是利用zk的临时有序节点,即多个线程同时抢占锁会创建多个节点如a1->a2->a3->a4->a5…,只有拿到第一个节点的线程获得锁,里面节点注册是的watch机制,即a1使用完后会释放当前节点,同时watch下一个节点a2,依次类推
优点:不依靠轮询抢占锁,依靠的是节点间的通信,比较可靠,当业务场景要求比较高是推荐使用
缺点:性能不如redis缓存锁高

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

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

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

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

(0)


相关推荐

  • C++map函数的用法_random函数用法

    C++map函数的用法_random函数用法https://blog.csdn.net/sevenjoin/article/details/81943864

    2022年10月26日
  • java switch条件_Java switch 条件语句用法详解[通俗易懂]

    java switch条件_Java switch 条件语句用法详解[通俗易懂]首页>基础教程>循环条件语句>条件语句switchJavaswitch条件语句用法详解switchcase语句在很多编程语言中的功能都是等于条件判断,java中为多路分支选择流程专门提供了switch语句,switch语句根据多个表达式的值,选择运行多个操作中的一个。当需要对选项进行等值判断时,使用switch语句更加简洁明了。switch的case语句可以处…

  • JavaScript 开发者年度调查报告

    JavaScript 开发者年度调查报告

  • vue常见错误:Invalid prop: type check failed for prop “data“. Expected Array, got Object

    vue常见错误:Invalid prop: type check failed for prop “data“. Expected Array, got Object错误截图错误分析这个错误的意思是说:无效的命名数据:“数据”类型检查失败。期望数组,得到对象,那么我们这个时候很明白了,是类型不对,但是是哪一行的呢?打开错误信息下面的详情,这个时候找到后缀是自己页面的.vue文件,看看是哪一行,就知道问题在哪了!下面的是我的:warn @ vue.esm.js?efeb:610assertProp @ vue.esm.js?efeb:1691vali…

  • 网页w3c标准_让行为成为标准

    网页w3c标准_让行为成为标准转自:http://一杯白开水w.iteye.com/blog/1122618什么是W3C标准    作为网站技术开发人员而言,往往是站在自己的开发角度来实施网站布署(读取数据及开发的方便性等等),而不是站在网站访问者与搜索引擎角度。因此大部分的网站在浏览方面不够直观或是方便,特别是现在w3c的规范,更是在大部分的网站开发人员脑里一片空白。何况百度、google、msn、yahoo

  • windows server2003 web服务器搭建

    windows server2003 web服务器搭建在控制面板中点击添加或删除程序,打开如下界面:勾选并打开应用程序服务器-Internet信息服务(IIS)-万维网服务依次点击确定后,开始下载服务,完成后打开IIS管理器然后进行如下设置在主目录下创建一个文本文档,输入内容,并保存为index.htm打开浏览器,输入IP地址,即可看到刚才输入的内容用物理机访问同理…

发表回复

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

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