thinkphp并发阻塞模式与非阻塞模式

结构代码

public function index(){

        $fp = fopen("lock.txt", "w+");

        if(flock($fp,LOCK_EX))

        {

            // 处理商品数据

            flock($fp,LOCK_UN);

        }

        fclose($fp);

    }

概述：

1.首先，读写方式打开或者创建文件lock.txt文件

2.给lock.txt文件上 "独占锁"，上锁成功后就可以进行下一步"处理订单商品数据了"

3.处理完数据后，要"释放锁”，以及fclose关闭打开的文件

注意：给文件“独占锁”后，如果再没有里面的“释放锁”，就没有下一个"轮回"

fopen详细介绍：http://www.w3school.com.cn/php/func_filesystem_fopen.asp

flock详细介绍：http://www.w3school.com.cn/php/func_filesystem_flock.asp

fclose详细介绍：http://www.w3school.com.cn/php/func_filesystem_fclose.asp

详细代码

namespace app\index\controller;

use think\Controller;

use think\Cache;

class Index extends Controller

{

    /**

     * 首页

     * */

    public function index(){

        $fp = fopen("lock.txt", "w+");

        if(flock($fp,LOCK_EX))   //锁定当前指针，，，

        {

            //..处理订单

            $stock = $this->findStock();

            if($stock > ){

                $this->setDec();

            }else{

                return '抢购失败';

            }

            return $stock;

            flock($fp,LOCK_UN);

        }

        fclose($fp);

    }

    /**

     * 查询数据库库存

     * */

    public function findStock(){

        $res = db('info')->where('id',)->field('stock')->lock(true)->find();

        return $res['stock'];

    }

    /**

     * 减少库存操作

     * */

    public function setDec(){

        $res = db('info')->where('id',)->setDec('stock',);

        return $res;

    }

}

总结有点：

1.可以解决并发问题，库存为负数的情况。

2.并发是，大家都在等待。当所有并发结束后，才会获得跳转（这也是缺点，如果处理1000条并发,需要时间15s，那么所有参加的人都需要等待15s后才进入下一个页面）

非阻塞模式

结构代码，与阻塞模式不同的地方 LOCK_NB (如果不希望 flock() 在锁定时堵塞，则给 lock 加上 LOCK_NB)

代码：

 public function index(){

        $fp = fopen("lock.txt", "w+");

        if(flock($fp,LOCK_EX | LOCK_NB))

        {

            $stock = $this->findStock();

            if($stock > ){

                $this->setDec();

            }else{

                return '抢购失败';

            }

            $this->setDec();

            return $stock;

            flock($fp,LOCK_UN);

        }

        else

        {

            echo "抢购失败，要不再试试";

        }

        fclose($fp);

    }

总结：

1.相比阻塞模式的时间等待，非阻塞模式则更加人性化很多

2.如果有有很多人都进入抢购，人太多就会直接进入第二个动作（“抢购失败界面”）。部分人就会进入第一个动作（“抢购候选名单”），下一个步骤1.抢购成功或者2 抢购失败

巴特西

thinkphp并发阻塞模式与非阻塞模式

最新文章

热门文章

巴特西

thinkphp并发 阻塞模式与非阻塞模式

最新文章

热门文章

thinkphp并发阻塞模式与非阻塞模式