php yii Redis實現並發鎖

需要寫一個抽獎活動,並發量很大,抽獎的同時需要操作多個數據表,決定采用redis鎖.

網上找了一下,找到大牛的博客

http://www.cnblogs.com/yjf512/archive/2017/03/22/6597814.html

需要用到lua

Q:很好奇解鎖的函數里為什么要用redis執行lua腳本,為什么不用php直接來操作呢?

A:群里問了下,大概明白了,redis是原子性,操作都是串行,但php是並發操作的,所以在高並發的時候可能存在臟讀的問題,所以使用eval函數在redis里串行的執行這段代碼,因為是串行的,不存在並發問題.

 

Q:如何實現阻塞鎖

A:我沒有在網上找到好的解決方案,都是自己寫循環執行

 

SET key value [EX seconds] [PX milliseconds] [NX|XX]

將字符串值 value 關聯到 key 。

如果 key 已經持有其他值， SET 就覆寫舊值，無視類型。

對於某個原本帶有生存時間（TTL）的鍵來說， 當 SET 命令成功在這個鍵上執行時， 這個鍵原有的 TTL 將被清除。

可選參數

從 Redis 2.6.12 版本開始， SET 命令的行為可以通過一系列參數來修改：

• EX second ：設置鍵的過期時間為 second 秒。 SET key value EX second 效果等同於 SETEX key second value 。
• PX millisecond ：設置鍵的過期時間為 millisecond 毫秒。 SET key value PX millisecond 效果等同於 PSETEX keymillisecond value 。
• NX ：只在鍵不存在時，才對鍵進行設置操作。 SET key value NX 效果等同於 SETNX key value 。
• XX ：只在鍵已經存在時，才對鍵進行設置操作。

因為 SET 命令可以通過參數來實現和 SETNX 、 SETEX 和 PSETEX 三個命令的效果，所以將來的 Redis 版本可能會廢棄並最終移除 SETNX 、 SETEX 和 PSETEX 這三個命令。

 

<?php
/**
 * Created by PhpStorm.
 * User: yiyz
 * Date: 2017/7/6
 * Time: 下午2:05
 */

namespace common\vendor;


use common\helper\TextHelper;

class RedisLock
{
    private $key;
    private $timeout;
    private $token;

    public function __construct($key, $timeout = 10)
    {
        $this->key = $key;
        $this->timeout = $timeout;
        $this->token = TextHelper::generateOrderNo();
    }

    /**
     * 阻塞加鎖
     * @return bool
     */
    public function lock()
    {
        $timeStart = microtime(true) * 1000;
        while (true) {
            $res = \Yii::$app->redis->set($this->key, $this->token, "nx", "ex", $this->timeout);
            if ($res) {
                break;
            }
            $timeEnd = microtime(true) * 1000;
            if ($timeEnd - $timeStart > 10000) {
                //add log error
                return false;43             }
        }
        return true;
    }

    /**
     * 解鎖
     * @return mixed
     */
    public function unlock()
    {
        $script = '
        if redis.call("get",KEYS[1]) == ARGV[1]
        then
            return redis.call("del",KEYS[1])
        else
            return 0
        end';
        return \Yii::$app->redis->eval($script, $this->key, $this->token);
    }
}

隨便寫的,沒經過測試,大牛不要笑我...