基于Redis-Shake实现Redis实时同步的示例代码

那朵莲 · 发表于 2025-11-18 08:29:24

一、前言

Redis-Shake是阿里云技术团队开源的一款Redis数据迁移与处理工具，支持数据迁移、备份、恢复和实时同步等多种功能。能够帮助你在不同Redis环境之间稳定高效的移动数据。

核心功能

sync（同步）：支持全量数据迁移和增量数据实时同步，适用于业务不停服迁移、异地容灾、多活架构
dump（备份）：将源Redis的数据备份到RDB文件中，适用于为数据备份、数据恢复做准备
Restore（恢复）：将RDB文件中的数据恢复到目标Redis实例。适用于数据恢复、从备份文件快速搭建新环境
rump(扫描): 通过SCMP命令迁移数据，适用于不支持SYNC/PSYNC命令的环境。适用于迁移Codis、Twemproxy等代理架构的数据

二、实施步骤

2.1 下载redis-shake二进制安装包

#wget https://github.com/alibaba/RedisShake/releases/download/v3.1.7/redis-shake-linux-amd64.tar.gz
#tar zxvf redis-shake-linux-amd64.tar.gz -C /root/

2.2 配置rsync模块文件

在这里定义源端redis和目标redis相关信息即可

[sync_reader]
address = "源Redis地址:端口"  # 例如：192.168.1.1:6379

[redis_writer]
address = "目标Redis地址:端口" # 例如：r-bp1xxxxx.redis.rds.aliyuncs.com:6379

[advanced]
parallel = 32  # 并发线程数，根据服务器性能调整

[filter]
# 可选：跳过以"temp:"或"cache:"开头的Key
block_key_prefix = ["temp:", "cache:"]

2.3 配置systemd

配置redis-shake服务，将其托管至systemd

#vim /etc/systemd/system/redis-shake.service
[Unit]
Description=RedisShake Data Sync Service
After=network.target

[Service]
Type=simple
User=root
Group=root
WorkingDirectory=/root/redis-shake
ExecStart=/root/redis-shake/redis-shake /root/redis-shake/sync.toml
Restart=always
RestartSec=10
StandardOutput=journal
StandardError=journal

[Install]
WantedBy=multi-user.target

2.4 启动并设置为自启

启动后，Redis-Shake会先在屏幕上打印全量同步的进度日志。当你看到 sync rdb done 的提示时，就意味着它已经进入了增量同步阶段，会持续将源实例的变更实时同步到目标实例

#systemctl daemon-reload
# systemctl enable --now redis-shake
Created symlink from /etc/systemd/system/multi-user.target.wants/redis-shake.service to /etc/systemd/system/redis-shake.service.

三、验证

测试我们可以在源端redis创建测试键值对。如下

127.0.0.1:6379> SELECT 1
OK
127.0.0.1:6379[1]> SET test_bxy "test_value1"
OK

在目标端redis验证键值对是否同步过来。

redis-cli -h 192.168.x.x  -p 9736 -a 123456 -n 1 GET test_bxy

由此可见，目标端键值对数据已同步过来了。

[Redis] 基于Redis-Shake实现Redis实时同步的示例代码

目录