1 说明
前段时间面试的时候，一直被问到如何设计一个秒杀活动，但是无奈没有此方面的实际经验，所以只好凭着自己的理解和一些资料去设计这么一个程序
主要利用到了redis的string和set,string主要是利用它的k-v结构去对库存进行处理，也可以用list的数据结构来处理商品的库存，set则用来确保用户进行重复的提交
其中我们最主要解决的问题是
-防止并发产生超抢/超卖
2 流程设计
3 代码
3.1 服务端代码
?
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
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 客户端测试代码
?
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
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
2
|
#第1种情况 500并发下 用客户端的test2()去执行
ab -n 500 -c 100 www.hello.com/flash-sale.php
|
log日志的记录结果:
?
|
1
2
|
#第2种情况 5000并发下 用客户端的test2()去执行
ab -n 5000 -c 1000 www.hello.com/flash-sale.php
|
log日志的记录结果:
?
|
1
2
|
#第3种情况 500并发下 用客户端的test()去执行
ab -n 500 -c 100 www.hello.com/flash-sale.php
|
log日志的记录结果:
?
|
1
2
|
#第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实现秒杀活动的流程,希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对快网idc网站的支持！
如果你觉得本文对你有帮助，欢迎转载，烦请注明出处，谢谢！
原文链接：https://segmentfault.com/a/1190000019778733
相关文章
猜你喜欢
- ASP.NET自助建站系统中如何实现多语言支持？ 2025-06-10
- 64M VPS建站：如何选择最适合的网站建设平台？ 2025-06-10
- ASP.NET本地开发时常见的配置错误及解决方法？ 2025-06-10
- ASP.NET自助建站系统的数据库备份与恢复操作指南 2025-06-10
- 个人网站服务器域名解析设置指南：从购买到绑定全流程 2025-06-10
