脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 数据库 → Redis → Redis 乐观锁保证数据一致性

Redis如何使用乐观锁(CAS)保证数据一致性

 更新时间：2022年03月25日 11:41:04   作者：翘翘脚_蹦高高  
本文主要介绍了Redis如何使用乐观锁(CAS)保证数据一致性，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

场景

在 Redis 中经常会存在这么一种情况，读取某一个 key 的值，做一些业务逻辑处理，然后根据读取到的值来计算出一个新的值，重新 set 进去。

如果客户端 A 刚读取到 key 值，紧接着客户端 B 就修改这个 key 的值，那么就会存在并发安全的问题。

问题模拟

假设 Redis Server 有个键名为 test 的key，里面存放的是一个 json 数组 [1, 2, 3]。

下面让我们模拟一下，客户端 A 与 客户端 B 同时访问修改的情况，代码如下：

客户端 A：

class RedisClientA(username: String, password: String, host: String, port: Int) {
    val jedis: Jedis

    init {
        val pool = JedisPool(JedisPoolConfig(), host, port)
        jedis = pool.resource
        jedis.auth(username, password)
    }

    fun update(key: String) {
        val idStr = jedis.get(key)
        val idList = Json.decodeFromString<MutableList<Int>>(idStr)

        // 等待2秒，模拟业务
        TimeUnit.SECONDS.sleep(2L)

        idList.add(4)
        println("new id list: $idList")

        jedis.set(key, Json.encodeToString(idList))
    }

    fun getVal(key: String): String? {
        return jedis.get(key)
    }
}

fun main() {
    val key = "test"
    val redisClientA = RedisClientA("default", "123456", "127.0.0.1", 6379)
    redisClientA.update(key)
    val res = redisClientA.getVal(key)
    println("res: $res")
}

客户端 B:

class RedisClientB(username: String, password: String, host: String, port: Int) {
    val jedis: Jedis

    init {
        val pool = JedisPool(JedisPoolConfig(), host, port)
        jedis = pool.resource
        jedis.auth(username, password)
    }

    fun update(key: String) {
        val idStr = jedis.get(key)
        val idList = Json.decodeFromString<MutableList<Int>>(idStr)

        idList.add(5)
        println("new id list: $idList")

        jedis.set(key, Json.encodeToString(idList))
    }

    fun getVal(key: String): String? {
        return jedis.get(key)
    }
}

fun main() {
    val key = "test"
    val redisClientB = RedisClientB("default", "123456", "127.0.0.1", 6379)
    redisClientB.update(key)
    val res = redisClientB.getVal(key)
    println("res: $res")
}

客户端 A 阻塞了 2 秒，用来模拟耗时业务逻辑的处理。正在处理的时候，客户端 B 访问了 “test”，并增加了 id:5。

在客户端 A 耗时业务逻辑处理完的时候，增加了 id:4，并且会覆盖掉 id:5。

最终“test” 里的内容最终如下：

CAS 来保证数据一致性

WATCH 命令可以为 Redis 事务提供 check-and-set（CAS）行为。被 WATCH 的键会被监视，并会发觉这些键是否被改动过了。如果有至少一个被监视的建在 EXEC 执行之前被修改了，那么整个事务都会被取消，EXEC 返回空（Null replay）来表示事务执行失败。我们只需要重复操作，希望在这个时间段内不会有新的竞争。这种形式的锁被称作乐观锁，它是一种非常强大的锁机制。

那么 CAS 的方式如何实现呢？我们只需要把 RedisClientA 的 update() 方法中的代码修改如下：

fun update(key: String) {
    var flag = true

    while (flag) {
        jedis.watch(key)

        val idStr = jedis.get(key)
        val idList = Json.decodeFromString<MutableList<Int>>(idStr)

        // 等待2秒，模拟业务
        TimeUnit.SECONDS.sleep(2L)

        val transaction = jedis.multi()
        idList.add(4)
        println("new id list: $idList")

        transaction.set(key, Json.encodeToString(idList))

        transaction.exec()?.let {
            flag = false
        }
    }

}

最终 “test” 的内容如下：

可见我们通过使用 WATCH 和 TRANACTION 命令，采用 CAS 乐观锁的方式实现了数据的一致性。

到此这篇关于Redis如何使用乐观锁(CAS)保证数据一致性的文章就介绍到这了,更多相关Redis 乐观锁保证数据一致性内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • redis通过位图法记录在线用户的状态详解

    redis通过位图法记录在线用户的状态详解

    这篇文章主要给大家介绍了关于redis如何通过位图法记录在线用户的状态的相关资料，文中先对位图进行了一个简单的介绍，而后通过示例代码将实现的方法介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2018-11-11
  • Redis不同数据类型使用场景代码实例

    Redis不同数据类型使用场景代码实例

    这篇文章主要介绍了Redis不同数据类型使用场景代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-12-12
  • 配置redis的序列化,注入RedisTemplate方式

    配置redis的序列化,注入RedisTemplate方式

    这篇文章主要介绍了配置redis的序列化,注入RedisTemplate方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-12-12
  • 一篇吃透Redis缓存穿透、雪崩、击穿问题

    一篇吃透Redis缓存穿透、雪崩、击穿问题

    这篇文主要介绍了Redis缓存穿透，缓存雪崩，缓存击穿的问题解决方法，文中有详细的图文介绍，对大家了解Redis有一定的帮助,需要的朋友可以参考下
    2023-05-05
  • redis持久化的介绍

    redis持久化的介绍

    今天小编就为大家分享一篇关于redis持久化的介绍，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
    2019-01-01
  • Redis数据一致性详解

    Redis数据一致性详解

    文章主要讨论了分布式系统中的数据一致性模型、缓存使用场景以及数据同步策略,一致性模型包括强一致性、弱一致性和最终一致性,缓存使用场景主要在高并发读取数据时提升性能,数据同步策略分为先删除缓存再更新数据库和先更新数据库再删除缓存两种
    2024-11-11
  • 浅谈Redis如何应对并发访问

    浅谈Redis如何应对并发访问

    本文主要介绍了Redis如何应对并发访问，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • 基于redis实现定时任务的方法详解

    基于redis实现定时任务的方法详解

    这篇文章主要给大家介绍了基于redis实现定时任务的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用redis具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2019-08-08
  • Redis数据库的应用场景介绍

    Redis数据库的应用场景介绍

    这篇文章主要介绍了Redis数据库的应用场景介绍,本文讲解了MySql+Memcached架构的问题、Redis常用数据类型、Redis数据类型应用和实现方式、Redis实际应用场景等内容,需要的朋友可以参考下
    2015-06-06
  • Redis在项目中常见的12种使用场景示例和说明

    Redis在项目中常见的12种使用场景示例和说明

    Redis是一个开源的高性能键值对数据库,它以其内存中数据存储、键过期策略、持久化、事务、丰富的数据类型支持以及原子操作等特性,在许多项目中扮演着关键角色,以下是整理的12个Redis在项目中常见的使用场景举例说明和解释
    2024-06-06

最新评论