资讯专栏INFORMATION COLUMN

[php]如何做到高并发优化

Sunxb / 1340人阅读

摘要:说白了就是每天访问的用户数每秒查询率每秒钟请求或者查询的数量,在互联网领域,指每秒响应请求数指请求二层面如何优化高并发层面利用加锁机制处理将的值设为,当且仅当不存在。若给定的已经存在,则不做任何动作。

在实际的开发过程中我们遇到过各种各样的活动,但像用户流量较大的平台就需要考虑高并发的问题,但是如何去解决呢?我总结了几种解决方案,欢迎大家指正!

一、什么是PV/UV/QPS?

PV:页面访问量,即PageView,用户每次对网站的访问均被记录,用户对同一页面的多次访问,访问量累计。(说白了就是用户的点击次数)  
UV:独立访问用户数:即UniqueVisitor,访问网站的一台电脑客户端为一个访客。00:00-24:00内相同的客户端只被计算一次。(说白了就是每天访问的用户数)
QPS: (每秒查询率) : 每秒钟请求或者查询的数量,在互联网领域,指每秒响应请求数(指HTTP请求)

二、php层面如何优化高并发?
1.redis层面:
(1)利用redis加锁机制处理setnx key value:将 key 的值设为 value,当且仅当 key 不存在。 若给定的 key 已经存在,则 SETNX 不做任何动作。SETNX 是SET if Not eXists的简写。


_redis =  new Redis();
        $this->_redis ->connect("127.0.0.1");
    }
    public static function getInstance()
    {
        if(self::$_instance instanceof self)
        {
            return self::$_instance;
        }
        return self::$_instance = new  self();
    }
    /**
     * @function 加锁
     * @param $key 锁名称
     * @param $expTime 过期时间
      */
    public function set($key,$expTime)
    {
        //初步加锁
        $isLock = $this->_redis->setnx($key,time()+$expTime);
        if($isLock)
        {
            return true;
        }
        else
        {
            //加锁失败的情况下。判断锁是否已经存在,如果锁存在且已经过期,那么删除锁。进行重新加锁
            $val = $this->_redis->get($key);
            if($val&&$valdel($key);
            }
            return  $this->_redis->setnx($key,time()+$expTime);
        }
    }
    /**
     * @param $key 解锁
     */
    public function del($key)
    {
        $this->_redis->del($key);
    }
}

$pdo = new PDO("mysql:host=127.0.0.1;dbname=test", "root", "root");
$lockObj = Lock::getInstance();  //单例模式
//判断是能加锁成功
if($lock = $lockObj->set("storage",10))
{
    $sql="select `number` from  storage where id=1 limit 1";
    $res = $pdo->query($sql)->fetch();
    $number = $res["number"];
    if($number>0)
    {
        $sql ="insert into `order`  VALUES (null,$number)";

        $order_id = $pdo->query($sql);
        if($order_id)
        {

            $sql="update storage set `number`=`number`-1 WHERE id=1";
            $pdo->query($sql);
        }
    }
    //解锁
    $lockObj->del("storage");

}
else
{
    //加锁不成功执行其他操作。
}
?>  



(2)利用reids消息队列处理高并发:队列是按先进先出的顺序来执行,需要用到 lpop、rpush、llen等方法

/**
*优惠券redis入库
**/
public function reload_quan(){
        $yhq_dom = Yhq_user_relation::i();
        $redis = Redis::i("redis");
        $redis->setOption( Redis::OPT_SERIALIZER, Redis::SERIALIZER_NONE );
        for ($i=0;$i<100;$i++){
            $date_time = date("Y-m-d H:i:s",time());
            $res = $yhq_dom->add([
                "hd_id" => 3,
                "yhq_id"=> 19,
                "name"  => "满58减20",
                "create_time" => $date_time,
                "price" => 58,
                "yuanbao" => 20
            ]);
            if (!$res){
                $this->_error("添加第".$i."张优惠券时失败");
            }
            //在redis中存入数据
            $redis->rPush("yhq_relation","{$i}");
        }
        $redis->expire("yhq_relation",1860);
        $this->_success("","库内添加优惠券成功");
    }
/**
*领取优惠券
**/
public function get_quan(){
    $redis = Redis::i("redis");
    $redis->setOption( Redis::OPT_SERIALIZER, Redis::SERIALIZER_NONE );
    $start_time = date("Y-m-d 00:00:00",time());
    $stop_time = date("Y-m-d 23:59:59",time());
    //判断是否在抢购时间内
    //$start_string = mktime(12,0,0,date("m"),date("d")-date("w")+5,date("Y"));
    //$stop_string = mktime(23,59,59,date("m"),date("d")-date("w")+5,date("Y"));
    //$now_time = time();
    //if ($now_time<$start_string || $now_time>$stop_string){
    //    $this->_error("抢券时间未到,请稍后再来~");
    //}
    $len = $redis->lLen("yhq_relation");
    if ($len<1){
        $this->_error("优惠券已经抢光啦~");
    }else{
        //领取优惠券时判断用户是否真正领取
        $user_id = $this->_user_info()["accid"];
        $yhq_dom = Yhq_user_relation::i();
        $where = [
            "accid" => $user_id,
            "hd_id"  => 3,
            "yhq_id"=>19,
            "create_time" => [
                "between" => [$start_time,$stop_time]
            ]
        ];
        $result = $yhq_dom->where($where)->find();
        if($result){
            $this->_error("对不起,您已经领取过了哦~");
        }else{
            //用户领取优惠券
            $expire_time = date("Y-m-d H:i:s",(time()+259200));
            $sql = "select id from yhq_user_relation where hd_id = 3 and yhq_id=19 and create_time between "$start_time" and "$stop_time" and accid is NULL ORDER by create_time ASC ";
            $update_id = $yhq_dom->query($sql)[0]["id"];
            //双重判断是否已经领取完毕
            if (!$update_id){
                $this->_error("优惠券已经抢光了哦~");
            }
            $redis->lPop("yhq_relation");
            $res = $yhq_dom->update("id={$update_id}",["accid"=>$user_id,"expire_time"=>$expire_time]);
            if ($res){
                $this->_success("","领取成功");
            }else{
                $this->_error("领取失败,请查看网络连接");
            }
        }
    }
}



2.数据库层面(暂时没有总结好)

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/29459.html

相关文章

  • 前端也该了解的一些后端知识

    摘要:而后端的知识是与前端工作最密切相关的一部分内容,多了解些后端的知识也是大有裨益的。本文简单叙述了三种构建大型架构的必备知识。而作为一个前端儿,许多技术可能无法在工程项目中亲自去实践,也只能从书,讲座,博文中学习了。 前言 作为一个有追求的前端,在学有余力的同时,不应该把自己仅仅局限于前端的世界中的。而后端的知识是与前端工作最密切相关的一部分内容,多了解些后端的知识也是大有裨益的。 本文...

    OnlyMyRailgun 评论0 收藏0
  • 前端也该了解的一些后端知识

    摘要:而后端的知识是与前端工作最密切相关的一部分内容,多了解些后端的知识也是大有裨益的。本文简单叙述了三种构建大型架构的必备知识。而作为一个前端儿,许多技术可能无法在工程项目中亲自去实践,也只能从书,讲座,博文中学习了。 前言 作为一个有追求的前端,在学有余力的同时,不应该把自己仅仅局限于前端的世界中的。而后端的知识是与前端工作最密切相关的一部分内容,多了解些后端的知识也是大有裨益的。 本文...

    leanote 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<