thinkphp如何利用redis控制并发

amp redis 39 clock 673 来源： 2024-10-27

下面由thinkphp框架教程栏目给大家介绍thinkphp 利用redis 控制并发的方法，希望对需要的朋友有所帮助！

author:he qq:760863706 tp:3.2.3 date:2018-10-19

tp框架开发的项目，需求是想控制某项业务同一时刻的访问量，用redis锁机制来实现目的，在tp公共方法中创建公共函数 concurrence

/**
*redis控制并发
**/
function concurrence(){

    //实例化redis
    $redis = new \Redis();
    $redis->connect(C(&#39;REDIS_HOST&#39;),C(&#39;REDIS_PORT&#39;));
    $redis->auth(C(&#39;REDIS_AUTH&#39;));

    //进入队列及出列，queue在加减的时候，要保证操作的唯一性，此时加锁，完成后在解锁
    $random = mt_rand();//生成随机数
    $start = $redis->set(&#39;clock&#39;, $random, array(&#39;nx&#39;, &#39;ex&#39; => 10));//redis加锁，锁有效期10秒
    while (!$start) 
    {
        usleep(100000);//沉睡100毫秒
        $start = $redis->set(&#39;clock&#39;, $random, array(&#39;nx&#39;, &#39;ex&#39; => 10));//redis加锁，锁有效期10秒
    }
    $queue = $redis->get(&#39;queue&#39;);
    if ($queue <= 10)
    {
        $redis->incr(&#39;queue&#39;);//自增
        if ($redis->get(&#39;clock&#39;) == $random) {//当clock值满足条件
            $redis->del(&#39;clock&#39;);//删除$random随机数
        }
        $process = &#39;处理具体的业务逻辑中,耗时不定,当前时间戳：&#39;.time();

        $endRandom = mt_rand();//随机数
        $end = $redis->set(&#39;clock&#39;, $endRandom, array(&#39;nx&#39;, &#39;ex&#39; => 10));//redis加锁，锁有效期10秒
        while (!$end) 
        {
            usleep(100000);//沉睡100毫秒
            $end = $redis->set(&#39;clock&#39;, $endRandom, array(&#39;nx&#39;, &#39;ex&#39; => 10));//redis加锁，锁有效期10秒
        }
        $redis->decr(&#39;queue&#39;);//自减
        if ($redis->get(&#39;clock&#39;) == $endRandom) {//当clock值满足条件
            $redis->del(&#39;clock&#39;);//删除$endRandom随机数
        }
        return $process;
    }else{
        if ($redis->get(&#39;clock&#39;) == $random) {
            $redis->del(&#39;clock&#39;);
        }
        usleep(200000);//沉睡200毫秒
        concurrence();//递归再次调用
    }

}

在控制器中，调用公共函数，处理相关业务

更多编程相关知识，请访问：编程教学！！

上一篇：解决ThinkPHP6提示控制器不存在问题

下一篇：ThinkPHP如何同时自增自减多个字段

thinkphp如何利用redis控制并发

推荐文章

热门文章