Symfony 怎样把Redis缓存项转数组

serialize()

CacheInterface

RedisAdapter

$cache->get($key, ...)

<?php

namespace App\Service;

use Psr\Cache\CacheItemPoolInterface;
use Symfony\Contracts\Cache\ItemInterface;

class MyCacheService
{
    private $cache;

    public function __construct(CacheItemPoolInterface $cache)
    {
        $this->cache = $cache;
    }

    public function getMyArrayData(string $key): array
    {
        // 尝试从缓存中获取数据
        $data = $this->cache->get($key, function (ItemInterface $item) {
            // 如果缓存中没有，或者缓存失效，这个回调函数会被执行
            // 在这里，你通常会从数据库或其他源获取原始数据
            $item->expiresAfter(3600); // 设置缓存有效期为1小时

            $someArray = [
                'id' => 123,
                'name' => '示例数据',
                'details' => [
                    'version' => '1.0',
                    'active' => true,
                ],
                'tags' => ['symfony', 'redis', 'cache']
            ];

            // Symfony的缓存组件会自动处理 $someArray 的序列化
            return $someArray;
        });

        // 理论上，如果原始存入的是数组，且没有外部干扰，这里 $data 就应该是一个数组
        if (is_array($data)) {
            return $data;
        }

        // 实际情况可能更复杂：
        // 1. 缓存中存入的不是数组，比如一个字符串或数字。
        // 2. 缓存项是直接通过Redis客户端写入的，而不是通过Symfony的缓存组件，
        //    这时它可能是一个JSON字符串、PHP序列化字符串或其他原始格式。
        // 3. 极少数情况下，序列化/反序列化过程出现了意外。

        // 如果 $data 不是数组，我们尝试根据常见格式进行反序列化
        // 优先尝试JSON，因为JSON是跨语言、可读性强的常用格式
        $decodedData = json_decode($data, true); // true表示解码为关联数组

        if (json_last_error() === JSON_ERROR_NONE && is_array($decodedData)) {
            return $decodedData;
        }

        // 如果不是有效的JSON，尝试PHP的unserialize
        // 注意：unserialize存在安全风险，只应反序列化你信任的数据源
        // 并且如果数据不是有效的序列化字符串，unserialize会返回false并抛出警告
        // 使用 @ 抑制警告，然后检查返回值
        $unserializedData = @unserialize($data);

        // PHP序列化一个布尔值false会得到 'b:0;'，unserialize('b:0;') 也是 false
        // 所以这里需要特别处理一下，避免误判
        if (($unserializedData !== false || $data === 'b:0;') && is_array($unserializedData)) {
            return $unserializedData;
        }

        // 如果以上尝试都失败了，说明缓存项不是一个可转换为数组的格式，
        // 或者它本身就不是一个数组。此时可以抛出异常、返回空数组或记录日志。
        // 根据业务需求决定如何处理这种“异常”情况。
        throw new \RuntimeException(sprintf('Redis cache item for key "%s" could not be converted to an array. Original type: %s', $key, gettype($data)));
    }
}

phpredis

predis

serialize()

json_decode($string, true)

serialize()

unserialize()

unserialize()

CacheItemPoolInterface

serialize

unserialize

config/packages/cache.yaml

serializer

# config/packages/cache.yaml
framework:
    cache:
        app:
            adapter: cache.adapter.redis
            provider: 'redis://localhost' # 或者你的Redis DSN
            # 可以指定序列化器，例如 'json'
            # serializer: cache.serializer.json
            # 或者使用 PHP 原生序列化，这是默认行为
            # serializer: cache.serializer.php
            # 如果你安装了 msgpack 或 igbinary 扩展，也可以使用它们
            # serializer: cache.serializer.msgpack
            # serializer: cache.serializer.igbinary

json

JsonSerializable

php_serialize

serialize

unserialize

msgpack

igbinary

json

php_serialize

MULTI

EXEC