php使用redis的几种常见操作方式和用法示例
时间:2022-07-27
本文章向大家介绍php使用redis的几种常见操作方式和用法示例,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
本文实例讲述了php使用redis的几种常见操作方式和用法。分享给大家供大家参考,具体如下:
一、简单的字符串缓存
比如针对一些sql查询较慢,更新不频繁的数据进行缓存。
<?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脚本从队列中读取任务去发送邮件。
也可以用来处理商品秒杀,用户点击抢购时,把一个个的用户抢购任务放入队列中,串行化处理,判断队列数量,防止超卖的发生。
<?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。
<?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 来实现悲观锁
悲观锁,顾名思义,悲观的认为数据总是会被修改,所以在操作前都会先加上锁,操作完后,再释放锁。
<?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 ";
});
更多关于PHP相关内容感兴趣的读者可查看本站专题:《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
- CNN预测股票走势基于Tensorflow(思路+程序)
- 路径查找器AI
- android推荐使用dialogFrament而不是alertDialog
- 自定义圆角和园边的实现
- Rafy 中的 Linq 查询支持(根据聚合子条件查询聚合父)
- 应用潜在语义分析技术将文档进行3D可视化
- 利用神经网络算法的C#手写数字识别
- fastText、TextCNN、TextRNN…这套NLP文本分类深度学习方法库供你选择
- nfc开发
- N-CryptoAsset投资组合 | 使用PCA识别高度相关的加密货币(最近听说某币很疯狂哦!)
- 仿刮刮乐刮奖效果
- Spacebuilder在Mono上运行修改备忘
- maven配置详解
- 这一新的可视化方法教你优雅地探索相关性
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 蓝桥杯 试题 基础练习 矩形面积交
- 蓝桥杯 试题 基础练习 完美的代价(详细c++)
- 牛客小白月赛23 部分题解
- AtCoder Beginner Contest 159 A~~D
- 最大连续子序列和(最大子数组和)四种最详细的解法
- 玩转 Linux 环境下日期的语法
- dubbo学习之事件通知实践
- Panasonic Programming Contest 2020 A ~~C
- 采用递归生成排列
- UCF Local Programming Contest 2015 A~~H
- python之循环控制语句
- python之结合if条件判断和生成随机数的相关知识,完成石头剪刀布的游戏
- AtCoder Beginner Contest 172
- python的import与 from……import
- 题目 1159: [偶数求和]