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（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。