baagee/redis-tools

Redis distributed lock and current limiter

v0.0.2 2020-07-01 01:55 UTC

Requires

• php: >=7.1

MIT

• BaAGee

• redis
• limiter
• distributed lock

README

Redis distributed lock and current limiter

结合redis实现的分布式锁和限流器,令牌桶

Redis分布式抢占锁用法

include __DIR__ . '/../vendor/autoload.php';

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$lock = \BaAGee\RedisTools\PreemptiveLock::getInstance($redis);
//方式1
$getLock = $lock->lock("test", 3, 10, 10000);
if ($getLock) {
    echo "get lock" . PHP_EOL;
    $lock->unlock('test');
} else {
    echo 'not get lock' . PHP_EOL;
}

// 方式2
$execute = $lock->run(function () {
    echo "我获得锁啦，哈哈哈" . PHP_EOL;
}, "test2", 5, 20, 20000);
if ($execute) {
    echo "获得锁并且已经执行了" . PHP_EOL;
} else {
    echo "没获得锁也没执行" . PHP_EOL;
}

限速器用法

include __DIR__ . '/../vendor/autoload.php';

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$sl = \BaAGee\RedisTools\SpeedLimit::getInstance($redis);
for ($i = 0; $i < 100; $i++) {
    echo str_repeat('#', 70) . PHP_EOL;
    // 十秒内最多允许7次操作
    //用法1
    $res = $sl->isAllow("user_id", 'replay', 10, 7);
    echo ($res ? 'replay允许' : 'replay不允许') . $i . PHP_EOL;

    // 十秒内最多允许7次操作
    //用法1
    $res = $sl->run(function () {
        echo '买了' . PHP_EOL;
    }, "user_id2", 'buy', 10, 7);

    echo ($res ? '已经买完了' : '不能买') . $i . PHP_EOL;
    usleep(1000000);
}

令牌桶

include __DIR__ . '/../vendor/autoload.php';

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$bucket = \BaAGee\RedisTools\TokenBucket::getInstance($redis);
//方式1
$action = 'eat';
//设置桶容量 设置添加令牌的速度（每毫秒添加几个）
$bucket->setCapacity(100)->setLeakingRate(1);
for ($i = 0; $i < 1000; $i++) {
    $res = $bucket->getToken($action);
    echo ($res ? '可以' : '不可以') . $action . PHP_EOL;
}
// 方式2

for ($i = 0; $i < 1000; $i++) {
    $res = $bucket->run(function () use ($action) {
        echo '小明' . $action . PHP_EOL;
    }, $action);
    echo ($res ? 'success' : 'failed') . PHP_EOL;
}