Redis Hashes存储二进制数据的能力解析与实践

<?php
// 确保已安装并配置phpredis扩展
// composer require phpredis/phpredis

try {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379); // 连接到Redis服务器
    echo "成功连接到Redis服务器。\n";

    // 1. 准备二进制数据
    // 示例1: 读取一个图片文件作为二进制数据
    $imagePath = __DIR__ . '/example.jpg'; // 假设当前目录下有一个example.jpg文件
    if (!file_exists($imagePath)) {
        // 创建一个简单的模拟图片文件（如果不存在）
        $dummyImage = imagecreatetruecolor(10, 10);
        imagejpeg($dummyImage, $imagePath);
        imagedestroy($dummyImage);
        echo "已创建模拟图片文件: example.jpg\n";
    }
    $binaryData = file_get_contents($imagePath);

    // 示例2: 序列化一个包含二进制内容的PHP数组
    // $complexData = ['id' => 1, 'name' => 'Test User', 'raw_bytes' => chr(0) . chr(255) . 'some_binary'];
    // $binaryData = serialize($complexData);

    if ($binaryData === false) {
        die("无法读取二进制数据，请检查文件路径或权限。\n");
    }
    echo "待存储二进制数据长度: " . strlen($binaryData) . " 字节。\n";

    // 2. 将二进制数据存储到Redis Hash
    $hashKey = 'user:profile:123';
    $field = 'avatar_image'; // 字段名
    $result = $redis->hSet($hashKey, $field, $binaryData);

    if ($result !== false) {
        echo "二进制数据成功存储到Hash键 '{$hashKey}' 的字段 '{$field}' 中。\n";
    } else {
        echo "存储失败。\n";
    }

    // 3. 从Redis Hash检索二进制数据
    $retrievedData = $redis->hGet($hashKey, $field);

    if ($retrievedData !== false) {
        echo "成功从Hash中检索到数据，长度: " . strlen($retrievedData) . " 字节。\n";
        // 验证检索到的数据是否与原始数据一致
        if ($retrievedData === $binaryData) {
            echo "检索到的数据与原始二进制数据完全匹配。\n";
            // 可以将检索到的数据写回文件或进行反序列化处理
            // file_put_contents(__DIR__ . '/retrieved_example.jpg', $retrievedData);
            // $unserializedData = unserialize($retrievedData);
        } else {
            echo "错误：检索到的数据与原始数据不匹配。\n";
        }
    } else {
        echo "未能从Hash中检索到数据。\n";
    }

    // 清理示例数据 (可选)
    // $redis->hDel($hashKey, $field);
    // echo "已清理示例数据。\n";

    $redis->close();
    echo "Redis连接已关闭。\n";

} catch (RedisException $e) {
    echo "Redis连接失败或操作错误: " . $e->getMessage() . "\n";
}
?>