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