主頁(yè) > 知識(shí)庫(kù) > php使用redis的幾種常見(jiàn)操作方式和用法示例

php使用redis的幾種常見(jiàn)操作方式和用法示例

熱門(mén)標(biāo)簽:銀行業(yè)務(wù) 服務(wù)器配置 Mysql連接數(shù)設(shè)置 科大訊飛語(yǔ)音識(shí)別系統(tǒng) 團(tuán)購(gòu)網(wǎng)站 Linux服務(wù)器 電子圍欄 阿里云

本文實(shí)例講述了php使用redis的幾種常見(jiàn)操作方式和用法。分享給大家供大家參考,具體如下:

一、簡(jiǎn)單的字符串緩存

比如針對(duì)一些sql查詢(xún)較慢,更新不頻繁的數(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ù)庫(kù)中獲取數(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));

二、通過(guò)列表模擬簡(jiǎn)單隊(duì)列

比如我們需要批量的發(fā)送郵件,可以把發(fā)送郵件的任務(wù)存入隊(duì)列中,然后啟多個(gè)php腳本從隊(duì)列中讀取任務(wù)去發(fā)送郵件。

也可以用來(lái)處理商品秒殺,用戶(hù)點(diǎn)擊搶購(gòu)時(shí),把一個(gè)個(gè)的用戶(hù)搶購(gòu)任務(wù)放入隊(duì)列中,串行化處理,判斷隊(duì)列數(shù)量,防止超賣(mài)的發(fā)生。

?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
//循環(huán)的把發(fā)送1000條郵件任務(wù)插入隊(duì)列
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);
//從隊(duì)列中取任務(wù),執(zhí)行任務(wù)
while ($count = $redis->lLen('send_email_queue')) {
  echo "當(dāng)前任務(wù)隊(duì)列數(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>";
}

三、通過(guò)watch + multi 來(lái)實(shí)現(xiàn)樂(lè)觀鎖

樂(lè)觀鎖,顧名思義,樂(lè)觀的認(rèn)為數(shù)據(jù)不會(huì)被修改,只有當(dāng)更新時(shí)才去判斷數(shù)據(jù)是否被修改過(guò),通常用版本號(hào)或時(shí)間戳來(lái)實(shí)現(xiàn)。

redis中通過(guò)watch和multi來(lái)實(shí)現(xiàn),watch會(huì)監(jiān)視給定的key是否發(fā)生更改,當(dāng)exec的時(shí)候如果監(jiān)視的key發(fā)生過(guò)改變,則整個(gè)事務(wù)會(huì)失敗。

當(dāng)然我們可以調(diào)用多次watch監(jiān)視多個(gè)key。

?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
//設(shè)置商品的庫(kù)存數(shù)為100
$redis->set('goods_stock_nums', 100);
//監(jiān)視該key
$redis->watch('goods_stock_nums');
//開(kāi)啟事務(wù)
$redis->multi();
//修改庫(kù)存數(shù)
$redis->decr('goods_stock_nums');
//提交事務(wù),如果在此期間有其他請(qǐng)求修改了該key,那么事務(wù)會(huì)失敗
if ($redis->exec()) {
  echo '搶購(gòu)成功';
} else {
  echo '數(shù)據(jù)錯(cuò)誤,請(qǐng)重新再試';
}

四、使用 set 來(lái)實(shí)現(xiàn)悲觀鎖

悲觀鎖,顧名思義,悲觀的認(rèn)為數(shù)據(jù)總是會(huì)被修改,所以在操作前都會(huì)先加上鎖,操作完后,再釋放鎖。

?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();
  //獲取商品庫(kù)存數(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)) {
    //修改庫(kù)存數(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']} 時(shí)間: {$msg['time']} br>";
});

更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專(zhuān)題:《php+redis數(shù)據(jù)庫(kù)程序設(shè)計(jì)技巧總結(jié)》、《php面向?qū)ο蟪绦蛟O(shè)計(jì)入門(mén)教程》、《PHP基本語(yǔ)法入門(mén)教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫(kù)操作入門(mén)教程》及《php常見(jiàn)數(shù)據(jù)庫(kù)操作技巧匯總》

希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。

您可能感興趣的文章:
  • PHP操作Redis數(shù)據(jù)庫(kù)常用方法示例
  • PHP的Laravel框架結(jié)合MySQL與Redis數(shù)據(jù)庫(kù)的使用部署
  • php實(shí)現(xiàn)redis數(shù)據(jù)庫(kù)指定庫(kù)號(hào)遷移的方法
  • php使用redis的有序集合zset實(shí)現(xiàn)延遲隊(duì)列應(yīng)用示例
  • redis+php實(shí)現(xiàn)微博(三)微博列表功能詳解
  • redis+php實(shí)現(xiàn)微博(二)發(fā)布與關(guān)注功能詳解
  • redis+php實(shí)現(xiàn)微博(一)注冊(cè)與登錄功能詳解
  • PHP+redis實(shí)現(xiàn)的限制搶購(gòu)防止商品超發(fā)功能詳解
  • PHP商品秒殺問(wèn)題解決方案實(shí)例詳解【mysql與redis】
  • php操作redis數(shù)據(jù)庫(kù)常見(jiàn)方法實(shí)例總結(jié)

標(biāo)簽:廣元 江蘇 棗莊 衢州 大理 萍鄉(xiāng) 衡水 蚌埠

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《php使用redis的幾種常見(jiàn)操作方式和用法示例》,本文關(guān)鍵詞  ;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問(wèn)題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。
  • 相關(guān)文章
  • 收縮
    • 微信客服
    • 微信二維碼
    • 電話咨詢(xún)

    • 400-1100-266