万科网络科技

# Ubuntu/Debian
sudo apt update && sudo apt install redis-server -y
# CentOS/RHEL
sudo yum install redis -y

# 启动并设置开机自启
sudo systemctl start redis
sudo systemctl enable redis

# 验证Redis是否运行
redis-cli ping  # 输出PONG则正常

# 方法1：通过包管理器（推荐）
sudo apt install php-redis  # Ubuntu
sudo yum install php-redis  # CentOS

# 方法2：通过PECL（适用于自定义PHP版本）
pecl install redis
# 安装后需在php.ini中添加扩展（通常自动添加）
# extension=redis.so

# 重启PHP服务（以FPM为例）
sudo systemctl restart php7.4-fpm  # 替换为你的PHP版本

<?php
// 创建Redis连接
$redis = new Redis();
try {
    // 连接本地Redis（默认端口6379，无密码）
    $redis->connect('127.0.0.1', 6379);
    // 若Redis设置了密码，添加：$redis->auth('你的密码');
    
    // 测试写入/读取
    $redis->set('test_key', 'Hello Redis!', 30); // 有效期30秒
    echo $redis->get('test_key'); // 输出：Hello Redis!
    
    $redis->close(); // 关闭连接（可选，PHP会自动回收）
} catch (Exception $e) {
    die("Redis连接失败：" . $e->getMessage());
}
?>

<?php
class ProductCache {
    private $redis;
    private $pdo;

    public function __construct() {
        // 初始化Redis连接
        $this->redis = new Redis();
        $this->redis->connect('127.0.0.1', 6379);
        
        // 初始化数据库连接
        $this->pdo = new PDO(
            'mysql:host=localhost;dbname=shop;charset=utf8',
            'root',
            'your_password',
            [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION]
        );
    }

    /**
     * 获取商品信息（带缓存）
     * @param int $productId 商品ID
     * @return array 商品数据
     */
    public function getProduct($productId) {
        $cacheKey = "product:info:$productId";
        
        // 1. 先查Redis缓存
        $product = $this->redis->get($cacheKey);
        if ($product) {
            return json_decode($product, true);
        }

        // 2. 缓存未命中，查数据库
        try {
            $stmt = $this->pdo->prepare("SELECT * FROM products WHERE id = ?");
            $stmt->execute([$productId]);
            $product = $stmt->fetch(PDO::FETCH_ASSOC);

            // 3. 处理缓存穿透：对不存在的商品设置空缓存（有效期60秒）
            if (!$product) {
                $this->redis->setex($cacheKey, 60, json_encode(null));
                return null;
            }

            // 4. 将数据库结果写入Redis（有效期2小时，准静态数据可设更长）
            $this->redis->setex($cacheKey, 7200, json_encode($product));
            return $product;
        } catch (Exception $e) {
            error_log("获取商品失败：" . $e->getMessage());
            return null;
        }
    }

    /**
     * 更新商品信息（同步删除缓存）
     * @param int $productId 商品ID
     * @param array $data 要更新的数据
     * @return bool 是否成功
     */
    public function updateProduct($productId, $data) {
        try {
            // 1. 先更新数据库
            $fields = [];
            $params = [];
            foreach ($data as $key => $value) {
                $fields[] = "$key = ?";
                $params[] = $value;
            }
            $params[] = $productId;
            $stmt = $this->pdo->prepare(
                "UPDATE products SET " . implode(', ', $fields) . " WHERE id = ?"
            );
            $stmt->execute($params);

            // 2. 再删除缓存（关键：避免缓存脏数据）
            $cacheKey = "product:info:$productId";
            $this->redis->del($cacheKey);
            return true;
        } catch (Exception $e) {
            error_log("更新商品失败：" . $e->getMessage());
            return false;
        }
    }
}

// 用法示例
$cache = new ProductCache();
// 获取商品（首次查数据库，后续查Redis）
$product = $cache->getProduct(1001);
print_r($product);

// 更新商品（自动删除对应缓存）
$cache->updateProduct(1001, ['price' => 99.9, 'stock' => 500]);
?>

<?php
// 初始化Redis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 1. 缓存导航栏片段（有效期12小时）
$navKey = "page:fragment:nav";
$navHtml = $redis->get($navKey);
if (!$navHtml) {
    // 模拟查询导航数据并生成HTML
    $navData = [['name' => '首页', 'url' => '/'], ['name' => '商品分类', 'url' => '/category']];
    $navHtml = '<nav>';
    foreach ($navData as $item) {
        $navHtml .= "<a href='{$item['url']}'>{$item['name']}</a>";
    }
    $navHtml .= '</nav>';
    // 写入Redis
    $redis->setex($navKey, 43200, $navHtml);
}
echo $navHtml;

// 2. 页面其他动态内容（如用户信息）直接渲染（不缓存）
echo '<div>欢迎你，' . $_SESSION['username'] . '</div>';
?>

# 修改php.ini
session.save_handler = redis
session.save_path = "tcp://127.0.0.1:6379?auth=你的密码（可选）"
session.gc_maxlifetime = 1800  # 会话有效期30分钟

<?php
// 开启会话（自动使用Redis存储）
session_start();

// 读写会话数据（和原生用法一致）
$_SESSION['user_id'] = 10086;
$_SESSION['username'] = "test_user";

// 读取会话
echo "用户ID：" . $_SESSION['user_id'];

// 销毁会话
// session_destroy();
?>

<?php
/**
 * 接口限流函数
 * @param string $userId 用户ID/IP（限流维度）
 * @param int $limit 单位时间内较大请求数
 * @param int $expire 限流时间窗口（秒）
 * @return bool 是否允许请求
 */
function isRequestAllowed($userId, $limit = 10, $expire = 60) {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    
    $key = "limit:api:{$userId}";
    // 自增请求数（首次创建会设为1）
    $requestCount = $redis->incr($key);
    // 首次请求时设置过期时间（避免key永久存在）
    if ($requestCount == 1) {
        $redis->expire($key, $expire);
    }
    
    // 判断是否超出限流阈值
    return $requestCount <= $limit;
}

// 用法示例：限制每个IP每分钟较多10次请求
$clientIp = $_SERVER['REMOTE_ADDR'];
if (!isRequestAllowed($clientIp, 10, 60)) {
    http_response_code(429);
    echo "请求过于频繁，请1分钟后重试";
    exit;
}

// 正常执行接口逻辑
echo "接口请求成功";
?>