Client ──► SETNX lock:sku:123 <uuid>  // 成功=1 → 执行业务 → DEL

┌─────────────┐
│  业务 Pod   │  (Hyperf + Coroutine)
└─────┬───────┘
      │  Lua 原子脚本
┌─────┴──────────────┐
│  5 台独立 Redis    │  (非 Cluster，主从异步关闭)
│  10.0.1.11 ~ .15   │
└────────────────────┘

composer require pudongping/hyperf-wise-locksmith:^1.2 -vvv
php bin/hyperf.php vendor:publish --provider="Pudongping\HyperfWiseLocksmith\LockerProvider"

return [
    'default' => [...], // 业务缓存
    'redLockNode1' => ['host'=>'10.0.1.11','port'=>6379,'auth'=>null,'db'=>0],
    'redLockNode2' => ['host'=>'10.0.1.12','port'=>6379,'auth'=>null,'db'=>0],
    'redLockNode3' => ['host'=>'10.0.1.13','port'=>6379,'auth'=>null,'db'=>0],
    'redLockNode4' => ['host'=>'10.0.1.14','port'=>6379,'auth'=>null,'db'=>0],
    'redLockNode5' => ['host'=>'10.0.1.15','port'=>6379,'auth'=>null,'db'=>0],
];

<?php
declare(strict_types=1);

namespace App\Service;

use Hyperf\Contract\StdoutLoggerInterface;
use Hyperf\Redis\RedisFactory;
use Pudongping\HyperfWiseLocksmith\Locker;
use Throwable;

abstract class AbstractRedLockService
{
    protected Locker $locker;

    public function __construct(
        RedisFactory $redisFactory,
        StdoutLoggerInterface $logger
    ) {
        $nodes = array_map(
            fn($pool) => $redisFactory->get($pool),
            ['redLockNode1','redLockNode2','redLockNode3','redLockNode4','redLockNode5']
        );
        $this->locker = new Locker($nodes);
        $this->locker->setLogger($logger);
    }

    /**
     * 执行业务并自动加/解锁
     * @param string   $resource 锁资源名
     * @param callable $callback 业务闭包
     * @param int      $ttl      锁有效期(ms)
     * @param int      $retry    重试次数
     * @return mixed
     * @throws Throwable
     */
    public function withRedLock(string $resource, callable $callback, int $ttl = 10000, int $retry = 3)
    {
        return $this->locker->redLock(
            $resource,
            $callback,
            $ttl,
            $retry
        );
    }
}

// 在 withRedLock 内部
$renew = function () use ($resource, $uuid) {
    $script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('pexpire', KEYS[1], ARGV[2]) else return 0 end";
    foreach ($this->nodes as $node) {
        $node->eval($script, 1, $resource, $uuid, $ttl);
    }
};
$timer = new Timer();
$timer->tick(intval($ttl/3), $renew);
try {
    return $callback();
} finally {
    $timer->clear();
}

# 挂掉节点 10.0.1.14
docker stop redis-14
wrk -t4 -c100 -d30s http://127.0.0.1:9501/lock/test

时间点   事件
t0       正常
t1       kill 节点 14
t1+200ms Prometheus 报警
t1+500ms 业务锁成功率恢复 100%