php使用redis的幾種常見操作方式和用法示例

更新時間：2020年02月20日 11:51:33 作者：懷素真

這篇文章主要介紹了php使用redis的幾種常見操作方式和用法,結合實例形式總結分析了PHP使用redis實現(xiàn)字符串緩存、隊列模擬、樂觀鎖與悲觀鎖實現(xiàn)、發(fā)布和訂閱等相關操作技巧,需要的朋友可以參考下

本文實例講述了php使用redis的幾種常見操作方式和用法。分享給大家供大家參考，具體如下：

一、簡單的字符串緩存

比如針對一些sql查詢較慢，更新不頻繁的數(shù)據進行緩存。

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
$sql = 'select * from tb_order order by id desc limit 10';
//偽代碼，從數(shù)據庫中獲取數(shù)據
$data = $db->query($sql);
$data = json_encode($data, JSON_UNESCAPED_UNICODE);
$key = md5($sql);
//緩存數(shù)據
$redis->set($key, $value, 60);
//獲取數(shù)據
$data = $redis->get($key);
print_r(json_decode($data, true));

二、通過列表模擬簡單隊列

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

也可以用來處理商品秒殺，用戶點擊搶購時，把一個個的用戶搶購任務放入隊列中，串行化處理，判斷隊列數(shù)量，防止超賣的發(fā)生。

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 60);
//循環(huán)的把發(fā)送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);
//從隊列中取任務，執(zhí)行任務
while ($count = $redis->lLen('send_email_queue')) {
  echo "當前任務隊列數(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 "任務 {$task['id']} 郵件發(fā)送成功<br>";
}

三、通過watch + multi 來實現(xiàn)樂觀鎖

樂觀鎖，顧名思義，樂觀的認為數(shù)據不會被修改，只有當更新時才去判斷數(shù)據是否被修改過，通常用版本號或時間戳來實現(xiàn)。

redis中通過watch和multi來實現(xiàn)，watch會監(jiān)視給定的key是否發(fā)生更改，當exec的時候如果監(jiān)視的key發(fā)生過改變，則整個事務會失敗。

當然我們可以調用多次watch監(jiān)視多個key。

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

四、使用 set 來實現(xiàn)悲觀鎖

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

<?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ā)布內容
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數(shù)據庫程序設計技巧總結》、《php面向對象程序設計入門教程》、《PHP基本語法入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結》、《php+mysql數(shù)據庫操作入門教程》及《php常見數(shù)據庫操作技巧匯總》

希望本文所述對大家PHP程序設計有所幫助。

您可能感興趣的文章: