1 說(shuō)明
前段時(shí)間面試的時(shí)候，一直被問(wèn)到如何設(shè)計(jì)一個(gè)秒殺活動(dòng)，但是無(wú)奈沒(méi)有此方面的實(shí)際經(jīng)驗(yàn)，所以只好憑著自己的理解和一些資料去設(shè)計(jì)這么一個(gè)程序
主要利用到了redis的string和set,string主要是利用它的k-v結(jié)構(gòu)去對(duì)庫(kù)存進(jìn)行處理，也可以用list的數(shù)據(jù)結(jié)構(gòu)來(lái)處理商品的庫(kù)存，set則用來(lái)確保用戶進(jìn)行重復(fù)的提交
其中我們最主要解決的問(wèn)題是
-防止并發(fā)產(chǎn)生超搶/超賣
2 流程設(shè)計(jì)
3 代碼
3.1 服務(wù)端代碼
class MiaoSha{
const MSG_REPEAT_USER = '請(qǐng)勿重復(fù)參與';
const MSG_EMPTY_STOCK = '庫(kù)存不足';
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:此種做法不能防止并發(fā)
* @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 客戶端測(cè)試代碼
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); //不能防止并發(fā)的
} catch (\Exception $e) {
echo $e->getMessage() . PHP_EOL;
error_log('fail' . $e->getMessage() .PHP_EOL,3,'/var/www/html/demo/log/debug.log');
}
}
4 測(cè)試
測(cè)試環(huán)境說(shuō)明
- ubantu16.04
- redis2.8.4
- php5.5
在服務(wù)端代碼里面我們有兩個(gè)函數(shù)分別是checkStock和checkStockFail,其中checkStockFail不能在高并發(fā)的情況下效果很差，不能在redis層面保證庫(kù)存為0的時(shí)候終止操作。
我們利用ab工具進(jìn)行測(cè)試
其中 www.hello.com 是配置的虛擬主機(jī)名稱 flash-sale.php 是我們腳本的名稱
#第1種情況 500并發(fā)下 用客戶端的test2()去執(zhí)行
ab -n 500 -c 100 www.hello.com/flash-sale.php
log日志的記錄結(jié)果:
#第2種情況 5000并發(fā)下 用客戶端的test2()去執(zhí)行
ab -n 5000 -c 1000 www.hello.com/flash-sale.php
log日志的記錄結(jié)果:
#第3種情況 500并發(fā)下 用客戶端的test()去執(zhí)行
ab -n 500 -c 100 www.hello.com/flash-sale.php
log日志的記錄結(jié)果:
#第4種情況 5000并發(fā)下 用客戶端的test()去執(zhí)行
ab -n 5000 -c 1000 www.hello.com/flash-sale.php
log日志的記錄結(jié)果:
5 總結(jié)
我們從日志中可以很明顯的看出第3、4中情況下，可以保證商品的數(shù)量總是我們?cè)O(shè)置的庫(kù)存值10，但是在情況1、2下，則產(chǎn)生了超賣的現(xiàn)象
redis來(lái)控制并發(fā)主要是利用了其api都是原子性操作的優(yōu)勢(shì)，從checkStock和checkStockFail中可以看出，一個(gè)是直接decr對(duì)庫(kù)存進(jìn)行減一操作，所以不存在并發(fā)的情況，但是另一個(gè)方法是將庫(kù)存值先取出做減一操作然后再重新賦值，這樣的話，在并發(fā)下，多個(gè)進(jìn)程會(huì)讀取到多個(gè)庫(kù)存為1的值，因此會(huì)產(chǎn)生超賣的情況
以上所述是小編給大家介紹的php和redis實(shí)現(xiàn)秒殺活動(dòng)的流程,希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！
如果你覺(jué)得本文對(duì)你有幫助，歡迎轉(zhuǎn)載，煩請(qǐng)注明出處，謝謝！
您可能感興趣的文章:- php結(jié)合redis實(shí)現(xiàn)高并發(fā)下的搶購(gòu)、秒殺功能的實(shí)例
- Redis瞬時(shí)高并發(fā)秒殺方案總結(jié)
- php+redis實(shí)現(xiàn)商城秒殺功能
- redis使用watch秒殺搶購(gòu)實(shí)現(xiàn)思路
- 基于redis分布式鎖實(shí)現(xiàn)秒殺功能
- Redis使用watch完成秒殺搶購(gòu)功能的代碼
- Java使用Redis實(shí)現(xiàn)秒殺功能
- 使用Redis實(shí)現(xiàn)秒殺功能的簡(jiǎn)單方法
