如何在PHP应用中优雅地解决并发问题？使用eonx-com/easy-lock实现分布式锁

eonx-com/easy-lock

eonx-com/easy-lock

eonx-com/easy-lock

<pre class="brush:php;toolbar:false;">composer require eonx-com/easy-lock

eonx-com/easy-lock

eonx-com/easy-lock

easy_lock.connection

<pre class="brush:php;toolbar:false;"><?php

use Symfony\Component\Lock\Store\RedisStore;
use Redis; // 假设你已经安装了 PHP Redis 扩展

// ... 在你的服务容器配置中 ...

// 实例化 Redis 客户端
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 创建 RedisStore 实例作为锁连接
$container->set('easy_lock.connection', new RedisStore($redis));

// 之后，你就可以通过 easy_lock.factory 服务来获取锁了
// 例如：$lockFactory = $container->get('easy_lock.factory');

easy_lock.store

Symfony\Component\Lock\Store\StoreInterface

eonx-com/easy-lock

<pre class="brush:php;toolbar:false;"><?php

// 假设你已经通过依赖注入获取了 LockFactory
// $lockFactory = $container->get('easy_lock.factory');

// 创建一个名为 'update-product-stock-123' 的锁
// 这里的名称应该是全局唯一的，代表你想要保护的资源
$lock = $lockFactory->createLock('update-product-stock-123', 30); // 锁的过期时间为30秒

if ($lock->acquire()) {
    // 成功获取到锁：进入临界区，执行需要保护的业务逻辑
    try {
        echo "成功获取到锁，正在更新商品库存...\n";
        // 模拟耗时操作，例如更新数据库、调用外部API
        sleep(5);
        echo "商品库存更新完成。\n";
    } finally {
        // 确保在任何情况下都释放锁，避免死锁
        $lock->release();
        echo "锁已释放。\n";
    }
} else {
    // 未能获取到锁：说明其他进程正在处理该资源
    echo "未能获取到锁，其他进程正在处理中，请稍后再试。\n";
}

eonx-com/easy-lock

eonx-com/easy-lock