phpredis使用场景(php和redis实现秒杀活动的流程)
phpredis使用场景
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工具进行测试
其中 是配置的虚拟主机名称 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日志的记录结果:
5 总结
我们从日志中可以很明显的看出第3、4中情况下,可以保证商品的数量总是我们设置的库存值10,但是在情况1、2下,则产生了超卖的现象
redis来控制并发主要是利用了其api都是原子性操作的优势,从checkstock和checkstockfail中可以看出,一个是直接decr对库存进行减一操作,所以不存在并发的情况,但是另一个方法是将库存值先取出做减一操作然后再重新赋值,这样的话,在并发下,多个进程会读取到多个库存为1的值,因此会产生超卖的情况
以上所述是小编给大家介绍的php和redis实现秒杀活动的流程,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对开心学习网网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!原文链接:https://segmentfault.com/a/1190000019778733
- php redis应用场景(PHP商品秒杀问题解决方案实例详解mysql与redis)
- docker实现redis集群(详解使用Docker进行Redis主从复制实践)
- redis新手入门教学(scrapy-redis的安装部署步骤讲解)
- django常用模块(django celery redis使用具体实践)
- docker快速配置redis集群(基于docker搭建redis集群的方法)
- phpredis高级用法(PHP Redis扩展无法加载的问题解决方法)
- django测试服务器静态资源放哪里(Django使用redis缓存服务器的实现代码示例)
- phpredis怎么实现任务(PHP swoole和redis异步任务实现方法分析)
- redis数据超过可用内存
- phpredis怎么设置队列(php使用lua+redis实现限流,计数器模式,令牌桶模式)
- docker怎么设置redis(docker安装redis并以配置文件方式启动详解)
- mysql缓存和redis查询效率(浅谈MySQL与redis缓存的同步方案)
- phpredis常用方法(PHP针对redis常用操作实例详解)
- docker部署redis集群查看版本(docker下的 redis 之持久化存储详解)
- redis的scan命令的使用(scrapy-redis源码分析之发送POST请求详解)
- php运用redis实现抢购实例(PHP+redis实现微博的拉模型案例详解)
- 五代十国南唐历代国君(五代十国南唐历代国君)
- 飞机引进工程师杨隆 匠人匠心,只争朝夕(飞机引进工程师杨隆)
- 三人行,她们是育人路上的 铁三角 团队(她们是育人路上的)
- 阴阳师 孟婆山兔CP不倒 新皮肤草稿 孟婆兔 让痒痒鼠点赞(阴阳师孟婆山兔CP不倒)
- 阴阳师孟婆御魂推荐 孟婆御魂搭配毕业套(阴阳师孟婆御魂推荐)
- 袁冰妍终于接到新剧,饰演反追男主,看到合作演员 眼光果然毒辣(袁冰妍终于接到新剧)
热门推荐
- python爬微信好友(python抓取需要扫微信登陆页面)
- androidjpg图像处理(详解如何使用image-set适配移动端高清屏图片)
- python模块学习之random模块(详解Python基础random模块随机数的生成)
- MVC中使用jQuery加载分部视图(PartialView)
- C#如何获取真实IP地址
- php数组写法(php文件操作之文件写入字符串、数组的方法分析)
- python 写入d盘文件(python文件写入write的操作)
- 怎么查询linux的selinux状态(如何理解Linux下的SELinux)
- mysqldecimal类型转换(mysql中decimal数据类型小数位填充问题详解)
- webview上传功能教程(关于webview适配H5上传照片或者视频文件的方法)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9