使用php和redis怎么實現一個秒殺活動

這期內容當中小編將會給大家帶來有關使用php和redis怎么實現一個秒殺活動，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

1 說明

前段時間面試的時候，一直被問到如何設計一個秒殺活動，但是無奈沒有此方面的實際經驗，所以只好憑著自己的理解和一些資料去設計這么一個程序

主要利用到了redis的string和set,string主要是利用它的k-v結構去對庫存進行處理，也可以用list的數據結構來處理商品的庫存，set則用來確保用戶進行重復的提交

其中我們最主要解決的問題是

-防止并發產生超搶/超賣

2 流程設計

3 代碼

3.1 服務端代碼

class MiaoSha{

 const MSG_REPEAT_USER = '請勿重復參與';
 const MSG_EMPTY_STOCK = '庫存不足';
 const MSG_KEY_NOT_EXIST = 'key不存在';

 const IP_POOL = 'ip_pool';
 const USER_POOL = 'user_pool';

 /** @var Redis */
 public $redis;
 public $key;

 public function __construct($key = '')
 {
  $this->checkKey($key);
  $this->redis = new Redis(); //todo 連接池
  $this->redis->connect('127.0.0.1');
 }

 public function checkKey($key = '')
 {
  if(!$key) {
   throw new Exception(self::MSG_KEY_NOT_EXIST);
  } else {
   $this->key = $key;
  }
 }

 public function setStock($value = 0)
 {
  if($this->redis->exists($this->key) == 0) {
   $this->redis->set($this->key,$value);
  }
 }

 public function checkIp($ip = 0)
 {
  $sKey = $this->key . self::IP_POOL;
  if(!$ip || $this->redis->sIsMember($sKey,$ip)) {
   throw new Exception(self::MSG_REPEAT_USER);
  }
 }

 public function checkUser($user = 0)
 {
  $sKey = $this->key . self::USER_POOL;
  if(!$user || $this->redis->sIsMember($sKey,$user)) {
   throw new Exception(self::MSG_REPEAT_USER);
  }
 }

 public function checkStock($user = 0, $ip = 0)
 {
  $num = $this->redis->decr($this->key);
  if($num < 0 ) {
   throw new Exception(self::MSG_EMPTY_STOCK);
  } else {
   $this->redis->sAdd($this->key . self::USER_POOL, $user);
   $this->redis->sAdd($this->key . self::IP_POOL, $ip);
   //todo add to mysql
   echo 'success' . PHP_EOL;
   error_log('success' . $user . PHP_EOL,3,'/var/www/html/demo/log/debug.log');
  }
 }

 /**
  * @note:此種做法不能防止并發
  * @func checkStockFail
  * @param int $user
  * @param int $ip
  * @throws Exception
  */
 public function checkStockFail($user = 0,$ip = 0) {
  $num = $this->redis->get($this->key);
  if($num > 0 ){
   $this->redis->sAdd($this->key . self::USER_POOL, $user);
   $this->redis->sAdd($this->key . self::IP_POOL, $ip);
   //todo add to mysql
   echo 'success' . PHP_EOL;
   error_log('success' . $user . PHP_EOL,3,'/var/www/html/demo/log/debug.log');
   $num--;
   $this->redis->set($this->key,$num);
  } else {
   throw new Exception(self::MSG_EMPTY_STOCK);
  }
 }
}

3.2 客戶端測試代碼

function test()
{
 try{
  $key = 'cup_';
  $handler = new MiaoSha($key);
  $handler->setStock(10);
  $user = rand(1,10000);
  $ip = $user;
  $handler->checkIp($ip);
  $handler->checkUser($user);
  $handler->checkStock($user,$ip);
 } catch (\Exception $e) {
  echo $e->getMessage() . PHP_EOL;
  error_log('fail' . $e->getMessage() .PHP_EOL,3,'/var/www/html/demo/log/debug.log');
 }
}

function test2()
{
 try{
  $key = 'cup_';
  $handler = new MiaoSha($key);
  $handler->setStock(10);
  $user = rand(1,10000);
  $ip = $user;
  $handler->checkIp($ip);
  $handler->checkUser($user);
  $handler->checkStockFail($user,$ip); //不能防止并發的
 } catch (\Exception $e) {
  echo $e->getMessage() . PHP_EOL;
  error_log('fail' . $e->getMessage() .PHP_EOL,3,'/var/www/html/demo/log/debug.log');
 }
}

4 測試

測試環境說明

• ubantu16.04

• redis2.8.4

• php5.5

在服務端代碼里面我們有兩個函數分別是checkStock和checkStockFail,其中checkStockFail不能在高并發的情況下效果很差，不能在redis層面保證庫存為0的時候終止操作。

我們利用ab工具進行測試

其中 www.hello.com 是配置的虛擬主機名稱 flash-sale.php 是我們腳本的名稱

#第1種情況 500并發下 用客戶端的test2()去執行
 ab -n 500 -c 100 www.hello.com/flash-sale.php

log日志的記錄結果:

#第2種情況 5000并發下 用客戶端的test2()去執行
 ab -n 5000 -c 1000 www.hello.com/flash-sale.php

log日志的記錄結果:

#第3種情況 500并發下 用客戶端的test()去執行
 ab -n 500 -c 100 www.hello.com/flash-sale.php

log日志的記錄結果:

#第4種情況 5000并發下 用客戶端的test()去執行
 ab -n 5000 -c 1000 www.hello.com/flash-sale.php

log日志的記錄結果:

php的框架有哪些

php的框架：1、Laravel，Laravel是一款免費并且開源的PHP應用框架。2、Phalcon，Phalcon是運行速度最快的一個PHP框架。3、Symfony，Symfony是一款為Web項目準備的PHP框架。4、Yii，Yii是一款快速、安全和專業的PHP框架。5、CodeIgniter，CodeIgniter是一款非常敏捷的開源PHP框架。6、CakePHP，CakePHP是一款老牌的PHP框架。7.Kohana，Kohana是一款敏捷但是功能強大的PHP框架。

上述就是小編為大家分享的使用php和redis怎么實現一個秒殺活動了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。