Symfony 怎么将缓存项转为PHP数组

json_decode

unserialize

Psr\Cache\CacheItemPoolInterface

Symfony\Contracts\Cache\CacheInterface

use Psr\Cache\CacheItemPoolInterface;

class MyService
{
    private $cache;

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

    public function getMyArrayFromCache(string $key): ?array
    {
        $item = $this->cache->getItem($key);

        if (!$item->isHit()) {
            // 缓存里没有，或者过期了，这时候你可能需要重新生成数据并存入
            // 比如：
            $data = $this->generateSomeArrayData();
            $item->set(json_encode($data)); // 存的时候记得编码
            $this->cache->save($item);
            return $data;
        }

        // 取出来的时候，先拿到字符串
        $cachedString = $item->get();

        // 尝试解码。这里有个坑，如果存进去的不是JSON，或者JSON格式不对，json_decode会返回null或false
        $arrayData = json_decode($cachedString, true); // true表示解码成关联数组

        // 简单的类型检查，确保确实是数组，不是null也不是其他类型
        if (is_array($arrayData)) {
            return $arrayData;
        }

        // 如果不是数组，说明缓存数据有问题，可以考虑日志记录或重新生成
        error_log("Cache item '{$key}' could not be decoded to an array.");
        // 也可以选择清掉这个坏掉的缓存项，然后重新生成并返回
        $this->cache->deleteItem($key);
        $data = $this->generateSomeArrayData();
        $item->set(json_encode($data));
        $this->cache->save($item);
        return $data;
    }

    private function generateSomeArrayData(): array
    {
        // 模拟生成一些数据
        return [
            'id' => uniqid(),
            'name' => '示例数据',
            'values' => [1, 2, 3],
            'timestamp' => time()
        ];
    }
}

json_encode($data)

json_decode($cachedString, true)

json_encode

JsonSerializable

serialize

unserialize

serialize

json_encode

json_decode

$cache->getItem()

// 这是一个简化版，实际项目中可能更复杂
class MyArrayCacheService
{
    private $cache;
    private $keyPrefix; // 方便管理不同类型数据的缓存键

    public function __construct(CacheItemPoolInterface $cache, string $keyPrefix = 'my_array_data_')
    {
        $this->cache = $cache;
        $this->keyPrefix = $keyPrefix;
    }

    /**
     * 从缓存获取一个数组，如果不存在或无效则通过回调函数生成并存入。
     * @param string $id 缓存项的唯一标识
     * @param callable $callback 用于生成数据的回调函数，返回一个数组
     * @param int|null $ttl 缓存过期时间，秒
     * @return array
     */
    public function getOrGenerateArray(string $id, callable $callback, ?int $ttl = null): array
    {
        $cacheKey = $this->keyPrefix . $id;
        $item = $this->cache->getItem($cacheKey);

        if ($item->isHit()) {
            $cachedString = $item->get();
            $arrayData = json_decode($cachedString, true);

            // 防御性检查：确保解码后是数组
            if (is_array($arrayData)) {
                return $arrayData;
            } else {
                // 缓存数据损坏或格式不正确，记录日志并清除坏数据
                error_log("Cache item '{$cacheKey}' is corrupted or not a valid JSON array. Regenerating.");
                $this->cache->deleteItem($cacheKey); // 清除坏数据
            }
        }

        // 缓存未命中或数据已损坏，通过回调函数生成新数据
        $data = $callback();
        if (!is_array($data)) {
            throw new \InvalidArgumentException("Callback for cache key '{$id}' must return an array.");
        }

        $item->set(json_encode($data));
        if ($ttl !== null) {
            $item->expiresAfter($ttl);
        }
        $this->cache->save($item);

        return $data;
    }
}

MyArrayCacheService::getOrGenerateArray()