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秒，模擬業(yè)務(wù)
        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 秒，用來(lái)模擬耗時(shí)業(yè)務(wù)邏輯的處理。正在處理的時(shí)候，客戶端 B 訪問(wèn)了 “test”，并增加了 id:5。

在客戶端 A 耗時(shí)業(yè)務(wù)邏輯處理完的時(shí)候，增加了 id:4，并且會(huì)覆蓋掉 id:5。

最終“test” 里的內(nèi)容最終如下：

CAS 來(lái)保證數(shù)據(jù)一致性

WATCH 命令可以為 Redis 事務(wù)提供 check-and-set（CAS）行為。被 WATCH 的鍵會(huì)被監(jiān)視，并會(huì)發(fā)覺這些鍵是否被改動(dòng)過(guò)了。如果有至少一個(gè)被監(jiān)視的建在 EXEC 執(zhí)行之前被修改了，那么整個(gè)事務(wù)都會(huì)被取消，EXEC 返回空（Null replay）來(lái)表示事務(wù)執(zhí)行失敗。我們只需要重復(fù)操作，希望在這個(gè)時(shí)間段內(nèi)不會(huì)有新的競(jìng)爭(zhēng)。這種形式的鎖被稱作樂(lè)觀鎖，它是一種非常強(qiáng)大的鎖機(jī)制。

那么 CAS 的方式如何實(shí)現(xiàn)呢？我們只需要把 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秒，模擬業(yè)務(wù)
        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” 的內(nèi)容如下：

可見我們通過(guò)使用 WATCH 和 TRANACTION 命令，采用 CAS 樂(lè)觀鎖的方式實(shí)現(xiàn)了數(shù)據(jù)的一致性。

到此這篇關(guān)于Redis如何使用樂(lè)觀鎖(CAS)保證數(shù)據(jù)一致性的文章就介紹到這了,更多相關(guān)Redis 樂(lè)觀鎖保證數(shù)據(jù)一致性內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: