php使用redis的几种常见方式和用法
浏览量:200
why:
how:
一、简单的字符串缓存
比如针对一些sql查询较慢，更新不频繁的数据进行缓存。
<?php
$redis = new Redis();
$redis->connect(\127.0.0.1\, 6379, 60);
$sql = \ 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脚本从队列中读取任务去发送邮件。
也可以用来处理商品秒杀，用户点击抢购时，把一个个的用户抢购任务放入队列中，串行化处理，判断队列数量，防止超卖的发生。
<?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是否发生更改，当的时候如果监视的key发生过改变，则整个事务会失败。
当然我们可以调用多次watch监视多个key。
<?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->()) {
echo \抢购成功\;
} else {
echo \数据错误，请重新再试\;
}
四、使用 set 来实现悲观锁
悲观锁，顾名思义，悲观的认为数据总是会被修改，所以在操作前都会先加上锁，操作完后，再释放锁。
<?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 完成发布和订阅
发布代码：
<?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>";
});
感谢支持与鼓励～