如何在PHP框架中使用分布式锁机制避免高并发的资源竞争

原生实现 php 中的分布式锁机制创建锁表，存储锁名称、到期时间和进程 id。使用事务获取锁，插入锁信息并检查是否成功。在处理结束后释放锁，根据进程 id 删除锁信息。

在PHP框架中实现分布式锁机制

简介

在分布式系统中，高并发请求可能会导致资源竞争，从而影响系统的稳定性和性能。分布式锁可以帮助解决这个问题，允许多个进程之间对共享资源进行互斥访问。

立即学习“PHP免费学习笔记（深入）”；

实现

在PHP框架中，可以使用第三方库或原生方式来实现分布式锁。以下是如何使用原生方式实现分布式锁：

Skybox AI

一键将涂鸦转为360°无缝环境贴图的AI神器

下载

步骤 1：创建锁表

在数据库中创建一个表来存储锁信息，包括锁名称、到期时间和进程标识符。

CREATE TABLE locks (
  lock_name VARCHAR(255) NOT NULL PRIMARY KEY,
  expiry_timestamp TIMESTAMP NOT NULL,
  process_id INT NOT NULL
);

步骤 2：获取锁

public function acquireLock(string $lockName): bool
{
    $expiryTimestamp = date('Y-m-d H:i:s', time() + $this->lockTimeout);
    $processId = getmypid();

    try {
        $this->db->query('BEGIN TRANSACTION');
        $query = $this->db->prepare(
            'INSERT INTO locks (lock_name, expiry_timestamp, process_id) VALUES (?, ?, ?)'
        );
        $query->execute([$lockName, $expiryTimestamp, $processId]);

        if ($query->rowCount() > 0) {
            $this->db->commit();
            return true;
        } else {
            $this->db->rollBack();
            return false;
        }
    } catch (PDOException $e) {
        $this->db->rollBack();
        throw $e;
    }
}

步骤 3：释放锁

public function releaseLock(string $lockName): void
{
    $processId = getmypid();

    try {
        $this->db->query('BEGIN TRANSACTION');
        $query = $this->db->prepare('DELETE FROM locks WHERE lock_name = ? AND process_id = ?');
        $query->execute([$lockName, $processId]);
        $this->db->commit();
    } catch (PDOException $e) {
        $this->db->rollBack();
        throw $e;
    }
}

实战案例

考虑一个购物车场景，多个用户可以同时向购物车中添加物品。为了避免库存过量，可以使用分布式锁来确保一次只有一个用户可以修改购物车内容。

use my\LockManager;

$lockManager = new LockManager();

// 获取锁
if ($lockManager->acquireLock('cart')) {
    // 修改购物车内容
    ...

    // 释放锁
    $lockManager->releaseLock('cart');
} else {
    // 重试或显示错误消息
}