一、简单的字符串缓存
比如针对一些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
|
<?phpfunction 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>";}); |
