本文實例講述了php使用redis的幾種常見操作方式和用法。分享給大家供大家參考,具體如下:
一、簡單的字符串緩存
比如針對一些sql查詢較慢,更新不頻繁的數(shù)據(jù)進(jìn)行緩存。
?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
$sql = 'select * from tb_order order by id desc limit 10';
//偽代碼,從數(shù)據(jù)庫中獲取數(shù)據(jù)
$data = $db->query($sql);
$data = json_encode($data, JSON_UNESCAPED_UNICODE);
$key = md5($sql);
//緩存數(shù)據(jù)
$redis->set($key, $value, 60);
//獲取數(shù)據(jù)
$data = $redis->get($key);
print_r(json_decode($data, true));
二、通過列表模擬簡單隊列
比如我們需要批量的發(fā)送郵件,可以把發(fā)送郵件的任務(wù)存入隊列中,然后啟多個php腳本從隊列中讀取任務(wù)去發(fā)送郵件。
也可以用來處理商品秒殺,用戶點擊搶購時,把一個個的用戶搶購任務(wù)放入隊列中,串行化處理,判斷隊列數(shù)量,防止超賣的發(fā)生。
?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
//循環(huán)的把發(fā)送1000條郵件任務(wù)插入隊列
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);
//從隊列中取任務(wù),執(zhí)行任務(wù)
while ($count = $redis->lLen('send_email_queue')) {
echo "當(dāng)前任務(wù)隊列數(shù) {$count} br>";
$task = $redis->rpop('send_email_queue');
$task = json_decode($task, true);
//偽代碼,發(fā)送郵件
$mailer->send($task['send'], $task['receive'], $task['title'], $task['body']);
echo "任務(wù) {$task['id']} 郵件發(fā)送成功br>";
}
三、通過watch + multi 來實現(xiàn)樂觀鎖
樂觀鎖,顧名思義,樂觀的認(rèn)為數(shù)據(jù)不會被修改,只有當(dāng)更新時才去判斷數(shù)據(jù)是否被修改過,通常用版本號或時間戳來實現(xiàn)。
redis中通過watch和multi來實現(xiàn),watch會監(jiān)視給定的key是否發(fā)生更改,當(dāng)exec的時候如果監(jiān)視的key發(fā)生過改變,則整個事務(wù)會失敗。
當(dāng)然我們可以調(diào)用多次watch監(jiān)視多個key。
?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
//設(shè)置商品的庫存數(shù)為100
$redis->set('goods_stock_nums', 100);
//監(jiān)視該key
$redis->watch('goods_stock_nums');
//開啟事務(wù)
$redis->multi();
//修改庫存數(shù)
$redis->decr('goods_stock_nums');
//提交事務(wù),如果在此期間有其他請求修改了該key,那么事務(wù)會失敗
if ($redis->exec()) {
echo '搶購成功';
} else {
echo '數(shù)據(jù)錯誤,請重新再試';
}
四、使用 set 來實現(xiàn)悲觀鎖
悲觀鎖,顧名思義,悲觀的認(rèn)為數(shù)據(jù)總是會被修改,所以在操作前都會先加上鎖,操作完后,再釋放鎖。
?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();
//獲取商品庫存數(shù)
$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)) {
//修改庫存數(shù)
$redis->decr('goods_stock_nums');
//釋放鎖
unlock('goods_stock_nums_lock', $random);
return true;
} else {
usleep(100);
decrGoodsStockNums();
}
}
decrGoodsStockNums();
五、使用 publish + subscribe 完成發(fā)布和訂閱
發(fā)布代碼:
?php
$redis = new Redis();
$redis->pconnect('127.0.0.1', 6379);
$ix = 0;
//發(fā)布內(nèi)容
while (true) {
$redis->publish('news', json_encode([
'title' => '我是新聞標(biāo)題' . $ix,
'content' => '我是新聞內(nèi)容' . $ix,
'time' => date('Y-m-d H:i:s'),
]));
$ix++;
sleep(1);
}
訂閱代碼:
?php
$redis = new Redis();
$redis->pconnect('127.0.0.1', 6379);
//訂閱內(nèi)容
$redis->subscribe(['news'], function ($redis, $channel, $msg) {
$msg = json_decode($msg, true);
echo "標(biāo)題: {$msg['title']} 內(nèi)容: {$msg['content']} 時間: {$msg['time']} br>";
});
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《php+redis數(shù)據(jù)庫程序設(shè)計技巧總結(jié)》、《php面向?qū)ο蟪绦蛟O(shè)計入門教程》、《PHP基本語法入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫操作入門教程》及《php常見數(shù)據(jù)庫操作技巧匯總》
希望本文所述對大家PHP程序設(shè)計有所幫助。
您可能感興趣的文章:- PHP操作Redis數(shù)據(jù)庫常用方法示例
- PHP的Laravel框架結(jié)合MySQL與Redis數(shù)據(jù)庫的使用部署
- php實現(xiàn)redis數(shù)據(jù)庫指定庫號遷移的方法
- php使用redis的有序集合zset實現(xiàn)延遲隊列應(yīng)用示例
- redis+php實現(xiàn)微博(三)微博列表功能詳解
- redis+php實現(xiàn)微博(二)發(fā)布與關(guān)注功能詳解
- redis+php實現(xiàn)微博(一)注冊與登錄功能詳解
- PHP+redis實現(xiàn)的限制搶購防止商品超發(fā)功能詳解
- PHP商品秒殺問題解決方案實例詳解【mysql與redis】
- php操作redis數(shù)據(jù)庫常見方法實例總結(jié)