PHP怎样使用Redis缓存？Predis客户端教程

<?php  require 'vendor/autoload.php';  use PredisClient;  try {     // 建立与Redis的连接     // 默认连接 '127.0.0.1:6379'     $redis = new Client([         'scheme' => 'tcp',         'host'   => '127.0.0.1',         'port'   => 6379,         // 如果Redis设置了密码，需要在这里添加         // 'password' => 'your_redis_password',         // 'database' => 0, // 选择数据库     ]);      // 缓存一个简单的字符串     $key = 'my_simple_data';     $value = 'Hello Redis Cache!';     $redis->set($key, $value);     echo "设置键 '{$key}' 成功，值为 '{$value}'n";      // 获取缓存数据     $cachedValue = $redis->get($key);     echo "获取键 '{$key}'，值为 '{$cachedValue}'n";      // 设置带有过期时间的缓存 (例如：60秒)     $expiringKey = 'user:1:profile';     $userData = [         'id' => 1,         'name' => '张三',         'email' => 'zhangsan@example.com'     ];     // 通常我们会把复杂数据结构序列化成字符串再存入Redis     $redis->setex($expiringKey, 60, json_encode($userData)); // SETEX = SET with EXpiration     echo "设置键 '{$expiringKey}' 成功，60秒后过期。n";      // 获取并解析缓存的用户数据     $cachedUserDataJson = $redis->get($expiringKey);     if ($cachedUserDataJson) {         $cachedUserData = json_decode($cachedUserDataJson, true);         echo "获取用户数据：n";         print_r($cachedUserData);     } else {         echo "用户数据缓存未命中或已过期。n";         // 实际应用中，这里会从数据库等数据源获取数据，并重新缓存     }      // 删除缓存     $redis->del($key);     echo "删除键 '{$key}' 成功。n";     $deletedValue = $redis->get($key);     echo "再次获取键 '{$key}'，值为 " . ($deletedValue === null ? 'null' : $deletedValue) . "n";  } catch (PredisConnectionConnectionException $e) {     echo "无法连接到Redis服务器: " . $e->getMessage() . "n";     // 实际应用中，这里应该有更健壮的错误处理和降级策略 } catch (Exception $e) {     echo "发生错误: " . $e->getMessage() . "n"; } 

json_decode

vendor

autoload.php

vendor/autoload.php

PredisClient

127.0.0.1

6379

use PredisClient; $redis = new Client();

$redis = new Client([     'scheme' => 'tcp',       // 连接协议，可以是tcp或tls     'host'   => 'your_redis_host', // Redis服务器IP或域名     'port'   => 6379,         // Redis端口     'password' => 'your_redis_password', // 如果Redis设置了密码     'database' => 0,         // 选择Redis数据库，默认是0     // 'timeout' => 5.0,     // 连接超时时间，单位秒     // 'read_write_timeout' => 5.0, // 读写超时时间 ]);

PredisConnectionConnectionException

$cacheKey = 'hot_products_category:' . $categoryId; $hotProducts = $redis->get($cacheKey);  if (!$hotProducts) {     // 缓存未命中，从数据库查询     $hotProducts = getHotProductsFromDatabase($categoryId);     // 缓存结果，并设置过期时间，比如10分钟     $redis->setex($cacheKey, 600, json_encode($hotProducts)); } else {     $hotProducts = json_decode($hotProducts, true); } // 使用 $hotProducts

// 不使用管道，多次网络往返 // $redis->set('key1', 'value1'); // $redis->set('key2', 'value2');  // 使用管道，一次网络往返 $responses = $redis->pipeline(function ($pipe) {     $pipe->set('key1', 'value1');     $pipe->set('key2', 'value2');     $pipe->get('key1');     $pipe->incr('counter'); });  // $responses 是一个数组，包含了所有命令的执行结果 // print_r($responses);

json_encode/json_decode

serialize/unserialize

try {     $redis = new Client(['host' => '127.0.0.1', 'port' => 6379]);     $data = $redis->get('some_data');     if ($data === null) {         // 缓存未命中         $data = getDataFromDatabase();         $redis->setex('some_data', 300, $data);     }     // 使用 $data } catch (PredisConnectionConnectionException $e) {     // Redis连接失败，降级到数据库     error_log("Redis connection failed: " . $e->getMessage());     $data = getDataFromDatabase();     // 使用 $data } catch (Exception $e) {     // 其他Predis操作错误     error_log("Redis operation failed: " . $e->getMessage());     $data = getDataFromDatabase();     // 使用 $data }