PHP 實現 Redis 實例間數據遷移：支援 String/List/Hash/ZSet 全類型同步腳本

Redis 實例間遷移（如分庫、換機房、版本升級）需保持類型與結構完整。本文提供支援 String、List、Hash、ZSet 四大核心類型的 PHP 遷移腳本，採用 phpredis 擴展，含進度顯示與錯誤處理。

完整遷移腳本

<?php
// 配置來源與目標：host:port/db
$from = '127.0.0.1:6200/6';
$to   = '127.0.0.1:6200/8';

$fromRedis = redisInit($from);
$toRedis   = redisInit($to);

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

foreach ($keys as $key) {
    if (++$count % 100 === 1) {
        echo "$count/$total\n";
    }

    $type = $fromRedis->type($key);
    switch ($type) {
        case Redis::REDIS_STRING:
            $val = $fromRedis->get($key);
            $toRedis->set($key, $val);
            break;

        case Redis::REDIS_LIST:
            $list = $fromRedis->lRange($key, 0, -1);
            foreach ($list as $val) {
                $toRedis->rPush($key, $val);
            }
            break;

        case Redis::REDIS_HASH:
            $hash = $fromRedis->hGetAll($key);
            $toRedis->hMSet($key, $hash);
            break;

        case Redis::REDIS_ZSET:
            $zset = $fromRedis->zRange($key, 0, -1, true); // withscores
            foreach ($zset as $member => $score) {
                $toRedis->zAdd($key, $score, $member);
            }
            break;

        default:
            echo "SKIP $key (unsupported type: $type)\n";
    }
}

function redisInit(string $conf): Redis {
    $redis = new Redis();
    // 解析 host:port/db
    if (!preg_match('/^([^:]+)(:(\d+))?\/(\d+)?$/', $conf, $m)) {
        throw new InvalidArgumentException("Invalid redis config: $conf");
    }
    $host = $m[1];
    $port = $m[3] ?? 6379;
    $db   = $m[4] ?? 0;
    $redis->connect($host, $port);
    $redis->select($db);
    return $redis;
}

類型處理細節對照

生產環境增強清單

• 掃描替代 KEYS：生產禁用 KEYS *（阻塞），改用 SCAN 游標迭代：

  $it = null;
  while ($keys = $fromRedis->scan($it, '*', 1000)) {
      foreach ($keys as $key) { ... }
  }
  

• Pipeline 批量寫入：目標端啟用 Pipeline 減少 RTT：

  $toRedis->pipeline();
  foreach (...) { $toRedis->set(...); }
  $toRedis->exec();
  

• 大 Key 分批：List/Hash/ZSet 元素超萬時，分批讀寫，避免記憶體飆升。
• TTL 保持：遷移前 TTL key 獲取過期時間，寫入後 EXPIRE key ttl 恢復。
• 校驗一致性：遷移後抽樣 TYPE、STRLEN、HLEN、ZCARD 對比。
• 斷點續傳：記錄已遷移 Key 至文件/Redis，中斷後跳過。
• 雙寫過渡期：遷移期間應用雙寫新舊實例，驗證無誤後切換讀流量。

替代方案對比

選對遷移策略，配合驗證與回滾預案，才能確保 Redis 數據零損失、零停機平滑流轉。