php使用redis的几种常见操作方式和用法示例
本文实例讲述了php使用redis的几种常见操作方式和用法。分享给大家供大家参考,具体如下:
一、简单的字符串缓存
比如针对一些sql查询较慢,更新不频繁的数据进行缓存。
connect('127.0.0.1',6379,60); $sql='select*fromtb_orderorderbyiddesclimit10'; //伪代码,从数据库中获取数据 $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脚本从队列中读取任务去发送邮件。
也可以用来处理商品秒杀,用户点击抢购时,把一个个的用户抢购任务放入队列中,串行化处理,判断队列数量,防止超卖的发生。
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}
"; $task=$redis->rpop('send_email_queue'); $task=json_decode($task,true); //伪代码,发送邮件 $mailer->send($task['send'],$task['receive'],$task['title'],$task['body']); echo"任务{$task['id']}邮件发送成功
"; }
三、通过watch+multi来实现乐观锁
乐观锁,顾名思义,乐观的认为数据不会被修改,只有当更新时才去判断数据是否被修改过,通常用版本号或时间戳来实现。
redis中通过watch和multi来实现,watch会监视给定的key是否发生更改,当exec的时候如果监视的key发生过改变,则整个事务会失败。
当然我们可以调用多次watch监视多个key。
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来实现悲观锁
悲观锁,顾名思义,悲观的认为数据总是会被修改,所以在操作前都会先加上锁,操作完后,再释放锁。
connect('127.0.0.1',6379,60); return$redis; } functionlock($key,$random) { $redis=getRedis(); return$redis->set($key,$random,['nx','ex'=>3]); } functionunlock($key,$random) { $redis=getRedis(); //使用lua脚本保证原子性 $script='ifredis.call("get",KEYS[1])==ARGV[1]thenreturnredis.call("del",KEYS[1])elsereturn0end'; return$redis->eval($script,[$key,$random],1); } functiondecrGoodsStockNums() { $redis=getRedis(); //获取商品库存数 $ret=$redis->get('goods_stock_nums'); if($ret===false){ returnfalse; } if($ret<=0){ returnfalse; } $random=mt_rand(); //先获取锁 if(lock('goods_stock_nums_lock',$random)){ //修改库存数 $redis->decr('goods_stock_nums'); //释放锁 unlock('goods_stock_nums_lock',$random); returntrue; }else{ usleep(100); decrGoodsStockNums(); } } decrGoodsStockNums();
五、使用publish+subscribe完成发布和订阅
发布代码:
pconnect('127.0.0.1',6379); $ix=0; //发布内容 while(true){ $redis->publish('news',json_encode([ 'title'=>'我是新闻标题'.$ix, 'content'=>'我是新闻内容'.$ix, 'time'=>date('Y-m-dH:i:s'), ])); $ix++; sleep(1); }
订阅代码:
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']}
"; });
更多关于PHP相关内容感兴趣的读者可查看本站专题:《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。