[php]如何作到高併發優化

在實際的開發過程當中咱們遇到過各類各樣的活動,但像用戶流量較大的平臺就須要考慮高併發的問題,可是如何去解決呢?我總結了幾種解決方案,歡迎你們指正!

1、什麼是PV/UV/QPS?php

PV:頁面訪問量,即PageView,用戶每次對網站的訪問均被記錄,用戶對同一頁面的屢次訪問,訪問量累計。(說白了就是用戶的點擊次數)
UV:獨立訪問用戶數:即UniqueVisitor,訪問網站的一臺電腦客戶端爲一個訪客。00:00-24:00內相同的客戶端只被計算一次。(說白了就是天天訪問的用戶數)
QPS: (每秒查詢率) : 每秒鐘請求或者查詢的數量,在互聯網領域,指每秒響應請求數(指HTTP請求)

2、php層面如何優化高併發?
1.redis層面:
(1)利用redis加鎖機制處理setnx key value:將 key 的值設爲 value,當且僅當 key 不存在。 若給定的 key 已經存在,則 SETNX 不作任何動做。SETNX 是SET if Not eXists的簡寫。mysql


<?php

class Lock
{
    private static $_instance ;
    private   $_redis;
    private function __construct()
    {
        $this->_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&&$val<time())
            {
                $this->del($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

/**
*優惠券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.數據庫層面(暫時沒有總結好)sql

相關文章
相關標籤/搜索