一、简单的字符串缓存
比如针对一些sql查询较慢，更新不频繁的数据进行缓存。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
<?php
$redis
=
new
Redis();
$redis
->connect(
'127.0.0.1'
, 6379, 60);
$sql
=
'select * from tb_order order by id desc limit 10'
;
//伪代码，从数据库中获取数据
$data
=
$db
->query(
$sql
);
$data
= json_encode(
$data
, JSON_UNESCAPED_UNICODE);
$key
= md5(
$sql
);
//缓存数据
$redis
->set(
$key
,
$value
, 60);
//获取数据
$data
=
$redis
->get(
$key
);
print_r(json_decode(
$data
, true));
|
二、通过列表模拟简单队列
比如我们需要批量的发送邮件，可以把发送邮件的任务存入队列中，然后启多个php脚本从队列中读取任务去发送邮件。
也可以用来处理商品秒杀，用户点击抢购时，把一个个的用户抢购任务放入队列中，串行化处理，判断队列数量，防止超卖的发生。
|
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
|
<?php
$redis
=
new
Redis();
$redis
->connect(
'127.0.0.1'
, 6379, 60);
//循环的把发送1000条邮件任务插入队列
for
(
$ix
= 0;
$ix
< 1000;
$ix
++) {
$redis
->lPush(
'send_email_queue'
, json_encode([
'id'
=>
$ix
,
'send'
=>
'xxx@qq.com'
,
'receive'
=>
'yyy@qq.com'
,
'title'
=>
'xxx'
,
'body'
=>
'xxx'
,
]));
}
sleep(3);
//从队列中取任务，执行任务
while
(
$count
=
$redis
->lLen(
'send_email_queue'
)) {
echo
"当前任务队列数 {$count} <br>"
;
$task
=
$redis
->rpop(
'send_email_queue'
);
$task
= json_decode(
$task
, true);
//伪代码，发送邮件
$mailer
->send(
$task
[
'send'
],
$task
[
'receive'
],
$task
[
'title'
],
$task
[
'body'
]);
echo
"任务 {$task['id']} 邮件发送成功<br>"
;
}
|
三、通过watch + multi 来实现乐观锁
乐观锁，顾名思义，乐观的认为数据不会被修改，只有当更新时才去判断数据是否被修改过，通常用版本号或时间戳来实现。
redis中通过watch和multi来实现，watch会监视给定的key是否发生更改，当exec的时候如果监视的key发生过改变，则整个事务会失败。
当然我们可以调用多次watch监视多个key。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
<?php
$redis
=
new
Redis();
$redis
->connect(
'127.0.0.1'
, 6379, 60);
//设置商品的库存数为100
$redis
->set(
'goods_stock_nums'
, 100);
//监视该key
$redis
->watch(
'goods_stock_nums'
);
//开启事务
$redis
->multi();
//修改库存数
$redis
->decr(
'goods_stock_nums'
);
//提交事务，如果在此期间有其他请求修改了该key，那么事务会失败
if
(
$redis
->
exec
()) {
echo
'抢购成功'
;
}
else
{
echo
'数据错误，请重新再试'
;
}
|
四、使用 set 来实现悲观锁
悲观锁，顾名思义，悲观的认为数据总是会被修改，所以在操作前都会先加上锁，操作完后，再释放锁。
|
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
|
<?php
function
getRedis()
{
$redis
=
new
Redis();
$redis
->connect(
'127.0.0.1'
, 6379, 60);
return
$redis
;
}
function
lock(
$key
,
$random
)
{
$redis
= getRedis();
return
$redis
->set(
$key
,
$random
, [
'nx'
,
'ex'
=> 3]);
}
function
unlock(
$key
,
$random
)
{
$redis
= getRedis();
//使用lua脚本保证原子性
$script
=
'if redis.call("get",KEYS[1]) == ARGV[1] then return redis.call("del",KEYS[1]) else return 0 end'
;
return
$redis
->
eval
(
$script
, [
$key
,
$random
], 1);
}
function
decrGoodsStockNums()
{
$redis
= getRedis();
//获取商品库存数
$ret
=
$redis
->get(
'goods_stock_nums'
);
if
(
$ret
=== false) {
return
false;
}
if
(
$ret
<= 0) {
return
false;
}
$random
= mt_rand();
//先获取锁
if
(lock(
'goods_stock_nums_lock'
,
$random
)) {
//修改库存数
$redis
->decr(
'goods_stock_nums'
);
//释放锁
unlock(
'goods_stock_nums_lock'
,
$random
);
return
true;
}
else
{
usleep(100);
decrGoodsStockNums();
}
}
decrGoodsStockNums();
|
五、使用 publish + subscribe 完成发布和订阅
发布代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
<?php
$redis
=
new
Redis();
$redis
->pconnect(
'127.0.0.1'
, 6379);
$ix
= 0;
//发布内容
while
(true) {
$redis
->publish(
'news'
, json_encode([
'title'
=>
'我是新闻标题'
.
$ix
,
'content'
=>
'我是新闻内容'
.
$ix
,
'time'
=>
date
(
'Y-m-d H:i:s'
),
]));
$ix
++;
sleep(1);
}
|
订阅代码：
|
1
2
3
4
5
6
7
8
9
10
|
<?php
$redis
=
new
Redis();
$redis
->pconnect(
'127.0.0.1'
, 6379);
//订阅内容
$redis
->subscribe([
'news'
],
function
(
$redis
,
$channel
,
$msg
) {
$msg
= json_decode(
$msg
, true);
echo
"标题: {$msg['title']} 内容: {$msg['content']} 时间: {$msg['time']} <br>"
;
});
|