Redis 分布式锁解决方案

在论坛上找到各种版本，应用到项目出运行不了，各种报错。今天自己重新编写调试测试，运行成功。

• PHP redis使用phpredis
• 参考redis官方资料

• 具体代码

  <?php
  namespace app\common\service;
  
  /**
   *
   * redis 加锁 --单Redis实例实现分布式锁
   *
   * -- 分布式请使用：Redlock:https://github.com/ronnylt/redlock-php
   * -- 详情参考： http://www.redis.cn/topics/distlock.html
   *
   * @package app\common\service
   */
  class RedisLock
  {
      const LOCK_SUCCESS = 'OK';
      const IF_NOT_EXISTS = 'NX';
      const MILLISECOND_EXPIRE_TIME = 'PX';
      const EXPIRE_TIME = 60000; // millisecond => 60s
      const LOCK_VALUE = 1;
  
          /**
           * 加锁
           * @param $redis object
           * @param $key
           * @param string $expire_time 60000
           */
          public static function lock($redis, $key, $expire_time='')
          {
              if (empty($expire_time)) {
                      $expire_time = self::EXPIRE_TIME;
              }
  
              $result = $redis->set($key, self::LOCK_VALUE, [self::IF_NOT_EXISTS, self::MILLISECOND_EXPIRE_TIME => $expire_time]);
  
              return self::LOCK_SUCCESS === (string)$result;
          }
  
          /**
           * 解锁
           *
           * 参考： https://github.com/phpredis/phpredis/blob/develop/tests/RedisTest.php
           * @param $redis
           * @param $key
           */
          public static function unlock($redis, $key)
          {
              $lua =<<<EOT
  if redis.call("get",KEYS[1]) == ARGV[1] then
      return redis.call("del",KEYS[1])
  else
      return 0
  end
  EOT;
              $result = $redis->eval($lua, array($key, self::LOCK_VALUE), 1);
              return $result;
      }
  }

本作品采用《CC 协议》，转载必须注明作者和本文链接