回答

1、incr单位时间内可以执行多少次

<?php
function checkrequest($_actkey) {
    $_limitsecond = 60;//单位时间 秒
    $concurrencyKey = "testincr".$_actkey;
    $_limitcount = 5;//可执行次数
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $_count = $redis->incr($concurrencyKey);
    if ($_count > $_limitcount) {
        return false;
    } else {
        if ($_count == 1) {
            $redis->expire($concurrencyKey, $_limitsecond);//设置过期时间
        }
        return true;
    }
}

echo time();
var_dump(checkrequest("test"));
var_dump(checkrequest("test"));
var_dump(checkrequest("test"));
var_dump(checkrequest("test"));
echo time();

var_dump(checkrequest("test"));
echo time();
var_dump(checkrequest("test"));
echo time();
var_dump(checkrequest("test"));

2、令牌桶限流

一个线程定时网队列中插入指定数量的令牌，其他的线程消费这个队列达到限流的目的

<?php
//每6秒钟插入指定令牌到队列中
$timer1 = Swoole\Timer::tick(6000, function () {
    try {
        $_limit_count = 3;//插入令牌数量
        $_actkey = "test";
        $redis = new Redis();
        $redis->connect('127.0.0.1');
        $key = 'limit_list'.$_actkey; //redis数据库key [注:默认redis数据库选择第0号数据库]
        for ($i = 0; $i < $_limit_count; $i++) {
            $redis->lPush($key, 1);
        }


        echo "插入令牌完成\n";
    } catch (Exception $e) {
        echo "出错了s\n";
    }

});
//定时消息发送
$timer1 = Swoole\Timer::tick(3000, function () {
    var_dump(checkrequest("test"));
    var_dump(checkrequest("test"));
    var_dump(checkrequest("test"));
    var_dump(checkrequest("test"));
    var_dump(checkrequest("test"));
    var_dump(checkrequest("test"));
    var_dump(checkrequest("test"));
});

function checkrequest($_actkey) {
    $redis = new Redis();
    $redis->connect('127.0.0.1');
    $key = 'limit_list'.$_actkey; //redis数据库key [注:默认redis数据库选择第0号数据库]
    //从队列最前头取出一个值
    $_data = $redis->lPop($key);
    if (!$_data || $_data == 'nil') {
       
        return false;
    } else {
       
        return true;
    }
}