首页 技术 正文
技术 2022年11月16日
0 收藏 478 点赞 2,391 浏览 1831 个字

  在电商项目中,经常有秒杀这样的活动促销,在并发访问下,很容易出现上述问题。如果在库存操作上,加锁就可以避免库存卖超的问题。分布式锁使分布式系统之间同步访问共享资源的一种方式

基于redis实现分布式锁的原理:

  redis为单进程单线程模式,采用队列模式将并发访问变成串行访问,且多客户端对Redis的连接并不存在竞争关系。其次Redis提供一些命令SETNX,GETSET,这些命令是原子操作,利用这些特性,

可以很充分的实现分布式锁。SETNX,GETSET 命令如下:

  SETNX key value

    功能:当且仅当 key 不存在,将 key 的值设为 value ,并返回1;若给定的 key 已经存在,则 SETNX 不做任何动作,并返回0。

  GETSET key value

    功能:将给定 key 的值设为 value ,并返回 key 的旧值 (old value),当 key 存在但不是字符串类型时,返回一个错误,当key不存在时,返回null

 实现要点:

  1、避免死锁,必要的超时机制。设置时间戳,时间戳要精确到毫秒。如果获取锁失败,则说明锁被其他对象保持,检查其是否超时

  2、释放锁时,避免释放非自己获得的锁,释放锁时,可以做一个是否超时的检查,如果超时说明锁就无需释放了

  3、为了造成不必要的资源浪费,提高并发,最好在最小颗粒度上的块加锁

  4、为了降低redis 压力,获取锁尝试时,循环之间一定要做sleep操作

参考源代码如下

// redis client

private Redistemplate tradeRedisTemplate

private Boolean setNX(String key, String value){

   return redisConnection.setNX(key.bytes, value.bytes)   

}

private String getSet(String key, String value){

   byte[] result = redisConnection.getSet(key.bytes, value.bytes)

   return new String(result)

}

//释放锁  key 锁名称,time 超时时间

public Void delDistributedLock(String key, Long time){

        String lastTimeS = tradeRedisTemplate.opsForValue().get(key)

        if(System.currentTimeMillis() – Long.parseLong(lastTimeS) < time){//避免删除非自己获取得到的锁

            tradeRedisTemplate.delete(key)

        }

}

//加锁 key 锁名称,time 超时时间

public Boolean acquireDistributedLock(String key, Long time){

        if(setNX(key, Long.toString(System.currentTimeMillis()))){ //SETNX成功,则成功获取一个锁

            return true

        }else{

            //SETNX失败,说明锁仍然被其他对象保持,检查其是否已经超时

            String lastTimeS = tradeRedisTemplate.opsForValue().get(key)

Long lastTime = Long.parseLong(lastTimeS)

//超时

            if(System.currentTimeMillis() – lastTime > time){

                String lastTimeRedis = getSet(key, Long.toString(System.currentTimeMillis()))

                if(lastTimeRedis.equals(lastTimeS)){// 获取锁成功

                    return true

                }

                // 已被其他进程捷足先登了

            }

        }

        return false

}

参考资料:

http://redis.io/commands/setnx

http://www.blogjava.NET/caojianhua/archive/2013/01/28/394847.html

相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:878 阅读:9,085
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:807 阅读:5,560
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:569 阅读:6,409
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:733 阅读:6,182
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:7,819
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:4,902