首页 > 作文

php使用redis的几种常见操作方式和用法示例

更新时间:2023-04-08 16:06:48 阅读: 评论:0

本文实例讲述了php使用redis的几种常见操作方式和用法。分享给大家供大家参考,具体如下:

一、简单的字符串缓存

比如针对一些sql查询较慢,更新不频繁的数据进行缓存。

<?php$redis = new redis();$redis->connect('127.0.0.1', 6379, 60);$sql = 'lect * from tb_order order by id desc limit 10';//伪代码,从数据库中获取数据$data = $db->query($sql);$data = json_encode($data, json_unescaped_unicode);$key = md5($sql);//缓存数据$redis->t($key, $value, 60);//获取数据$data = $redis->get($key);print_r(json_decode($data, true));

二、通过列表模拟简单队列

比如我们需要批量的发送邮件,可以把发送邮件如何学好唱歌的任务存入队列中,然后启多个php脚本从队列中读取任务去发送邮件。

也可以用来处理商品秒杀,用户点击抢购时,把一个个的用户抢购任务放入队列中,串行化处理,判断队列数量,防止超卖的发生。

<?php$redis = new redis();$redis->connect('127.0.0.1', 6379, 60);//循环的把发送1000条邮件任务插入队列f2的2次方or ($ix = 0; $ix < 1000; $ix++) {  $redis->lpush('nd_email_queue', json_encode([    'id' => $ix,    'nd' => 'xxx@qq.com',    'receive' => 'yyy@qq.com',    'title' => 'xxx',    'body' => 'xxx',  ]));}sleep(3);//从队列中取任务,执行任务while ($count = $redis->llen('nd_email_queue')) {  echo "当前任务队列数 {$count} <br>";  $task = $redis->rpop('nd_email_queue');  $task = json_decode($task, true);  //伪代码,发送邮件  $mailer->nd($task['nd'], $task['receive'], $task['title'], $task['body']);  echo "任务 {$task['id']} 邮件发送成功<br>";}

三、通过watch + multi 来实现乐观锁

乐观锁,顾名思义,乐观的认为数据不会被修改,只有当更新时才去判断数据是否被修改过,通常用版本号或时间戳来实现。

redis中通过watch和multi来实现,watch会监视给定的key是否发生更改,当exec的时候如果监视的key发生过改变,则整个事务会失败。

当然我们可以调用多次watch监视多个key。

<?php$redis = new redis();$redis->connect('127.0.0.1', 6379, 60);//设置商品的库存数为100$redis->t('goods_stock_nums', 100);//监视该key$redis->watch('goods_stock_nums');//开启事务$redis->multi();//修改库存数$redis->decr('goods_stock_nums');//提交事务,如果在此期间有其他请求修改了该key,那么事务会失败if ($redis->exec()) {  echo '抢购成功';} el {  echo '数据错误,请重新再试';}

四、使用 t 来实现悲观锁

悲观锁,顾名思义,悲观的认为数据总是会被修改吉拉特,所以在操作前都会先加上锁,操作完后,再释放锁。

<?phpfunc汇总凭证tion getredis(){  $redis = new redis();  $redis->connect('127.0.0.1', 6379, 60);  return $redis;}function lock($key, $random){  $redis = getredis();  return $redis->t($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]) el return 0 end';  return $redis->eval($script, [$key, $random], 1);}function decrgoodsstocknums(){  $redis = getredis();  //获取商品库存数  $ret = $redis->get('goods_stock_nums');  if ($ret === fal) {    return fal;  }  if ($ret <= 0) {    return fal;  }  $random = mt_rand();  //先获取锁  if (lock('goods_stock_nums_lock', $random)) {    //修改库存数    $redis->decr('goods_stock_nums');    //释放锁    unlock('goods_stock_nums_lock', $random);    return true;  } el {    usleep(100);    decrgoodsstocknums();  }}decrgoodsstocknums();

五、使用 publish + subscribe 完成发布和订阅

发布代码:

<?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);}

订阅代码:

<?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>";});

本文发布于:2023-04-08 16:06:47,感谢您对本站的认可!

本文链接:https://www.wtabcd.cn/fanwen/zuowen/7238e7808222a331a824e06599cc6246.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

本文word下载地址:php使用redis的几种常见操作方式和用法示例.doc

本文 PDF 下载地址:php使用redis的几种常见操作方式和用法示例.pdf

标签:队列   数据   来实现   发送邮件
相关文章
留言与评论(共有 0 条评论)
   
验证码:
Copyright ©2019-2022 Comsenz Inc.Powered by © 专利检索| 网站地图