文档章节

Redis实现锁

秋风醉了
 秋风醉了
发布于 2016/04/14 16:17
字数 886
阅读 395
收藏 2

精选30+云产品,助力企业轻松上云!>>>

Redis实现锁

虽然很多的Redis用户都对锁(lock),加锁(locking)以及锁超时(lock timeouts)有所了解,但大部分使用Redis实现的锁只是基本上正确,它们发生故障的时间和方式通常都难以预料。下面列出了一些导致锁出现不正确行为的原因,以及锁在不正确运行时的症状:

  • 持有锁的进程因为操作时间过长而导致锁被自动释放,但进程本身并不知道,甚至还可能会错误的释放掉了其他进程持有的锁。

  • 一个持有锁并打算执行长时间操作的进程已经崩溃,但其他想要获取锁的进程不知道哪个进程持有着锁,只能白白浪费时间等待锁被释放

  • 在一个进程持有的锁过期之后,其他多个进程同时尝试去获取锁,并且都获得了锁。

  • 上面提到的第一个种情况和第三种情况同时出现,导致有多个进程获得了锁,而每个进程都以为自己是唯一一个获得锁的进程。

以上几种情况是redis锁使用过程中有可能出现的问题,在redis锁的使用过程中应该要注意。


Redis实现基本的加锁和锁的释放

为了对数据进行排他性访问,程序首先要做的就是获取锁。SETNX命令天生就适合用来实现锁的获取功能,这个命令只在键不存在的情况下为键设置值,而锁要做的就是将一个随机生成的128位UUID设置为键的值,并使用这个值来防止锁被其他进程取得。

如果程序在尝试获取锁的时候失败,那么它将不断的进行重试,知道成功的取得锁获取超时,代码如下,

/**
 * 获取锁
 *
 * @param conn
 * @param lockName
 * @param acquireTimeout 获取锁直到超时
 * @return
 */
public String acquireLock(Jedis conn, String lockName, long acquireTimeout) {
    String identifier = UUID.randomUUID().toString();

    long end = System.currentTimeMillis() + acquireTimeout;
    //获取锁的过程超时后,直接返回null
    while (System.currentTimeMillis() < end) {
        if (conn.setnx("lock:" + lockName, identifier) == 1) { //key-value设置成功
            return identifier; //返回锁的标识符
        }

        //如果没有设置成功,即获取锁失败,sleep一毫秒继续重试,直到获取锁的过程超时

        try {
            Thread.sleep(1);
        } catch (InterruptedException ie) {
            Thread.currentThread().interrupt();
        }
    }

    return null;
}

以上代码实现了加锁过程,那么如何释放锁,

/**
 * 释放锁
 *
 * @param conn
 * @param lockName
 * @param identifier
 * @return
 */
public boolean releaseLock(Jedis conn, String lockName, String identifier) {
    String lockKey = "lock:" + lockName;

    while (true) {
        conn.watch(lockKey);
        //判断锁的标识,如果相等,说明标识符对应的线程正在持有该锁,可以释放
        if (identifier.equals(conn.get(lockKey))) {
            Transaction trans = conn.multi();
            trans.del(lockKey);
            List<Object> results = trans.exec();
            if (results == null) {
                continue;
            }
            return true;
        }

        //不再监视lockKey
        conn.unwatch();
        break;
    }

    //释放锁失败
    return false;
}


带有超时限制的锁

如下代码所示,

/**
 * 获取锁,锁有超时特性
 *
 * @param conn
 * @param lockName
 * @param acquireTimeout
 * @param lockTimeout
 * @return
 */
public String acquireLockWithTimeout(
        Jedis conn, String lockName, long acquireTimeout, long lockTimeout) {
    String identifier = UUID.randomUUID().toString();
    String lockKey = "lock:" + lockName;
    int lockExpire = (int) (lockTimeout / 1000);

    long end = System.currentTimeMillis() + acquireTimeout;

    //循环获取锁,直到获取成功或超时
    while (System.currentTimeMillis() < end) {
        if (conn.setnx(lockKey, identifier) == 1) { //设置成功
            //设置成功后设置锁的过期时间
            conn.expire(lockKey, lockExpire);
            return identifier;
        }

        //当获取锁失败后,检查过期时间
        //如果返回-1 表示该锁没有设置过期
        if (conn.ttl(lockKey) == -1) {
            //设置一个过期时间
            conn.expire(lockKey, lockExpire);
        }

        try {
            Thread.sleep(1);
        } catch (InterruptedException ie) {
            Thread.currentThread().interrupt();
        }
    }

    // null indicates that the lock was not acquired
    return null;
}

======END======

上一篇: MongoDB入坑
下一篇: Redis事务
秋风醉了
粉丝 253
博文 530
码字总数 404430
作品 0
朝阳
程序员
私信 提问
加载中
请先登录后再评论。
简洁实用的Redis分布式锁用法

在微服务中很多情况下需要使用到分布式锁功能,而目前比较常见的方案是通过Redis来实现分布式锁,网上关于分布式锁的实现方式有很多,早期主要是基于Redisson等客户端,但在Spring Boot2.x以...

JAVA葵花宝典
07/04
0
0
慢谈 Redis 实现分布式锁 以及 Redisson 源码解析

# 产生背景 Distributed locks are a very useful primitive in many environments where different processes must operate with shared resources in a mutually exclusive way. 在某些场景......

2019/01/30
0
0
Redis分布式锁的try-with-resources实现

Redis分布式锁的try-with-resources实现 一、简介 在当今这个时代,单体应用(standalone)已经很少了,java提供的synchronized已经不能满足需求,大家自然 而然的想到了分布式锁。谈到分布式...

ronaldoliubo
2018/06/21
0
0
分布式锁(2) ----- 基于redis的分布式锁

分布式锁系列文章 分布式锁(1) ----- 介绍和基于数据库的分布式锁分布式锁(2) ----- 基于redis的分布式锁分布式锁(3) ----- 基于zookeeper的分布式锁代码:https://github.com/shuo123/di...

osc_my2aqmiz
2019/03/28
30
0
AP模式(Redis)的分布式锁分析以及实现

分布式CAP理论 在介绍分布式锁之前,先说一下CAP理论。因为现在提到分布式系统一定离不开CAP理论。C(Consistency)一致性、A(Availability)可用性、P(Partition tolerance)分区容错性。...

无敌老娘们儿
06/16
0
0

没有更多内容

加载失败,请刷新页面

加载更多

使当前提交成为Git存储库中唯一的(初始)提交? - Make the current commit the only (initial) commit in a Git repository?

问题: I currently have a local Git repository, which I push to a Github repository. 我目前有一个本地Git存储库,我将其推送到Github存储库。 The local repository has ~10 commits, ......

javail
51分钟前
14
0
IntelliJ IDEA 默认快捷键大全

Remember these Shortcuts 常用 功能 快捷键 备注 ● Smart code completion Ctrl + Shift + Space - ● Search everywhere Double Shift - ● Show intention actions and quick-fixes Alt......

巨輪
今天
24
0
Hacker News 简讯 2020-07-14

更新时间: 2020-07-14 02:01 Chipmaker Analog Devices to Acquire Maxim Integrated for $21B - (reuters.com) 芯片制造商模拟设备公司将以210亿美元收购Maxim Integrated 得分:92 | 评论:......

FalconChen
今天
129
0
绕过移动端系统限制的 dlopen 库 byOpen

byOpen是一个绕过移动端系统限制的增强版dlfunctions库。 支持特性 Android 支持App中加载和使用Android系统库接口(即使maps中还没有被加载也支持)。 Android 7以上dlopen, System.load都是...

shzwork
昨天
31
0
Golang学习系列第二天:变量、常量、数据类型和流程语句

继golang第一天后,今天学习下golang的变量、常量、数据类型和控制流语句。 做过其他编程语言(比如JavaScript,java,python)项目的话,其实很好理解变量、常量、数据类型和控制流。 变量也...

董广明
昨天
48
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部