这期内容当中小编将会给大家带来有关使用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的框架: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怎么实现一个秒杀活动了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。