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

composer require predis/predis

<?php

require 'vendor/autoload.php';

use Predis\Client;

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 (Predis\Connection\ConnectionException $e) {
    echo "无法连接到Redis服务器: " . $e->getMessage() . "\n";
    // 实际应用中，这里应该有更健壮的错误处理和降级策略
} catch (Exception $e) {
    echo "发生错误: " . $e->getMessage() . "\n";
}

json_encode

json_decode

composer require predis/predis

vendor

autoload.php

vendor/autoload.php

Predis\Client

127.0.0.1

6379

use Predis\Client;
$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, // 读写超时时间
]);

try-catch

Predis\Connection\ConnectionException

$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 (Predis\Connection\ConnectionException $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
}