redis 加锁逻辑

小白 2022-09-15 14:28:01  65113

分类专栏：资讯

/**
 * 功能锁 锁住一个代码片段
 * @param string $lockKey
 * @param callable $call
 * @param int $expire
 * @return void
 * Created by PhpStorm
 * User:jill
 * Date:2022/5/13
 * Time:3:57 PM
 * @throws ErrorException
 */
public static function redisFunctionLock(string $lockKey, callable $call, int $expire = 10): ?array
{

    $redis = \EasySwoole\RedisPool\Redis::defer(EnvConst::REDIS_KEY);
    $lockValue = $redis->get($lockKey);
    //验证锁状态
    if (superEmpty($lockValue)) {
        try {
            //过期时间为 0 则是上业务锁 防止同时操作一个业务 不为0 则为防止重复提交锁
            if ($expire <= 0) {
                $redis->set($lockKey, time(), 3600);
            } else {
                $redis->set($lockKey, time(), $expire);
            }


            $result = $call();

            if ($expire <= 0) {
                /** 解锁 */
                $redis->del($lockKey);
            }

        } catch (RedisException $e) {
            /** 解锁 */
            $redis->del($lockKey);
            throw new ErrorException(1000, 'redis锁调用失败');
        }
    }
    return $result ?? [];
}

网站声明：如果转载，请联系本站管理员。否则一切后果自行承担。

本文链接：https://www.xckfsq.com/news/show.html?id=66

赞同 0

评论 0 条

redis 加锁逻辑

相关文章

关注我们