php使用redis最常用示例

Posted wzg-bky

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了php使用redis最常用示例相关的知识,希望对你有一定的参考价值。

一、简单的字符串缓存

比如针对一些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>";
);

以上是关于php使用redis最常用示例的主要内容,如果未能解决你的问题,请参考以下文章

30个php操作redis常用方法代码例子

30个php操作redis常用方法代码例子

Redis | Redis常用命令及示例总结(API)

redis在php中使用的常用命令

php Redis常用命令

30个php操作redis常用方法代码例子