PHP实现Redis数据库间数据迁移与同步

准备条件与环境配置

在执行数据迁移前，需确保本地环境满足以下要求：

• 运行环境：已安装PHP及phpredis扩展。new Redis()对象依赖此扩展进行通信。
• 网络连通性：能够同时访问源和目标Redis实例，注意防火墙设置及端口映射。
• 内存评估：keys('*')命令在生产环境中可能阻塞主进程。若源库数据量极大，建议先在测试库验证，或使用 scan() 替代迭代器以保证稳定性。

数据迁移操作步骤

第1步：定义连接参数与初始化函数

首先需要建立源库和目标库的连接。为了方便管理，封装一个初始化函数用于解析IP、端口及库号。

1. 定义连接串：格式为 host:port/db。
2. 解析配置：使用正则表达式提取主机地址、端口号和数据库索引号。
3. 建立连接：通过 connect() 连接主机，并使用 select() 切换至指定DB。

$from = '127.0.0.1:6200/6'; // 源：IP+端口+/数据库号6
$to   = '127.0.0.1:6200/8'; // 目标：IP+端口+/数据库号8

function redis_init($conf){
    $redis = new Redis();
    // 匹配规则：host:port/db
    preg_match('/^([^:]+)(:[0-9]+)?\/(.+)?$/', $conf, $ms);
    $host = $ms[1];       // 主机地址
    $port = trim($ms[2], ':'); // 去除冒号的端口
    $db   = $ms[3];       // 数据库索引
    
    $redis->connect($host, $port);
    if ($db) {
        $redis->select($db); // 选择目标库
    }
    return $redis;
}

$from_redis = redis_init($from);
$to_redis   = redis_init($to);

第2步：获取源库所有键列表

使用 keys('*') 获取源库中所有的Key。这将作为后续遍历迁移的基准。

$keys  = $from_redis->keys('*');
$total = count($keys);
$count = 0;

第3步：循环迁移并处理不同数据类型

遍历所有Key，判断其类型后分别执行对应的写入操作。针对四种常见数据结构，逻辑如下：

1. 普通字符串 (REDIS_STRING)：使用 get() 读取原值，通过 set() 写入目标。
2. 列表 (REDIS_LIST)：使用 lRange(key, 0, -1) 拉取全部元素，再通过 rPush() 逐个压入目标列表。
3. 哈希 (REDIS_HASH)：使用 hGetAll() 获取键值对数组，通过 hMSet() 批量写入。
4. 有序集合 (REDIS_ZSET)：使用 zRange(key, 0, -1, true) 获取带有分数的数组，遍历后通过 zAdd() 添加分数与成员。

foreach($keys as $key){
    // 每处理100条输出一次进度
    if(++$count % 100 == 1){
        echo "$count/$total\n";
    }
    
    $type = $from_redis->type($key);
    
    switch($type){
        case Redis::REDIS_STRING:
            // 字符串直接Set
            $val = $from_redis->get($key);
            $to_redis->set($key, $val);
            break;
        
        case Redis::REDIS_LIST:
            // List全量拉取再逐个插入
            $list = $from_redis->lRange($key, 0, -1);
            foreach($list as $val){
                $to_redis->rPush($key, $val);
            }
            break;
        
        case Redis::REDIS_HASH:
            // Hash使用批量写入
            $hash = $from_redis->hGetAll($key);
            $to_redis->hMSet($key, $hash);
            break;
        
        case Redis::REDIS_ZSET:
            // ZSet获取分数映射并逐个添加
            $zset = $from_redis->zRange($key, 0, -1, true);
            foreach($zset as $val => $score){
                $to_redis->zAdd($key, $score, $val);
            }
            break;
    }
}

完成判断与注意事项

• 进度监控：脚本已在代码中加入计数输出，完成后控制台会显示 Total/Total，表示已全部迁移完毕。
• 覆盖风险：该脚本默认直接写入目标库。如果目标库已有同名Key，将被新值覆盖。如目标是空库可忽略；若是增量同步场景，需修改策略保留旧值。
• 性能提示：rPush 和 zAdd 在循环中单条执行，相比 MSET 效率较低。对于超大规模数据集（千万级），建议考虑直接使用 redis-cli --raw 管道传输或使用 Redis Cluster 迁移工具。

以上就是使用PHP实现Redis数据库间数据迁移与同步的详细内容，更多关于Redis数据迁移与PHP实操的资料请关注本站其它相关文章！