laravel如何使用Redis实现分布式锁_Laravel Redis分布式锁实现方法-Laravel-PHP中文网

laravel如何使用Redis实现分布式锁_Laravel Redis分布式锁实现方法

下次还敢

发布： 2025-10-02 14:24:02

原创

574人浏览过

Laravel通过Redis的SET命令结合NX和PX选项实现原子性加锁，使用唯一token标识进程，并借助Lua脚本安全释放锁，确保分布式环境下任务不重复执行。

laravel如何使用redis实现分布式锁_laravel redis分布式锁实现方法

Laravel 使用 Redis 实现分布式锁，核心是利用 Redis 的原子操作特性来保证同一时间只有一个进程能获取到锁。这在多服务器、队列任务或定时命令并发执行的场景中非常有用，避免重复处理造成数据异常。

1. 安装并配置 Redis 扩展

Laravel 默认支持 Redis，但需要确保已安装 predis/predis 或启用 PHP 的 Redis 扩展。

composer require predis/predis

然后在 config/database.php 中确认 Redis 配置正确：

'redis' => [
    'client' => 'predis',
    'default' => [
        'host' => env('REDIS_HOST', '127.0.0.1'),
        'password' => env('REDIS_PASSWORD', null),
        'port' => env('REDIS_PORT', 6379),
        'database' => 0,
    ],
],

登录后复制

2. 使用 Redis::set 实现原子加锁

Redis 的 SET 命令支持 NX（不存在时设置）和 PX（毫秒过期），可以原子性地实现加锁。

示例代码：

奇布塔

基于AI生成技术的一站式有声绘本创作平台

查看详情

$lockKey = 'lock:send_report';
$ttl = 10000; // 锁过期时间，单位毫秒
$token = uniqid(); // 唯一标识当前进程

$locked = Redis::set($lockKey, $token, 'NX', 'PX', $ttl);

if (! $locked) {
    // 获取锁失败，说明其他进程正在执行
    return response('任务已在执行中', 423);
}

// 成功获取锁，开始执行任务
try {
    // 你的业务逻辑，比如发送报表
    dispatch(new SendReportJob());
} finally {
    // 使用 Lua 脚本安全释放锁（防止删除别人的锁）
    $script = <<<'LUA'
if redis.call("get", KEYS[1]) == ARGV[1] then
    return redis.call("del", KEYS[1])
else
    return 0
end
LUA;
    Redis::eval($script, 1, $lockKey, $token);
}

登录后复制

3. 封装为可复用的锁服务

为了方便使用，可以封装一个简单的分布式锁类：

class DistributedLock
{
    protected $key;
    protected $token;
    protected $ttl;

    public function __construct($key, $ttl = 10000)
    {
        $this->key = "lock:{$key}";
        $this->ttl = $ttl;
        $this->token = uniqid();
    }

    public function acquire()
    {
        return Redis::set($this->key, $this->token, 'NX', 'PX', $this->ttl);
    }

    public function release()
    {
        $script = <<<'LUA'
if redis.call("get", KEYS[1]) == ARGV[1] then
    return redis.call("del", KEYS[1])
else
    return 0
end
LUA;
        Redis::eval($script, 1, $this->key, $this->token);
    }
}

登录后复制

使用方式：

$lock = new DistributedLock('import_data', 5000);
if (! $lock->acquire()) {
    return '资源被占用';
}

try {
    // 执行关键操作
} finally {
    $lock->release();
}

登录后复制