基于Redis-Shake实现Redis实时同步的示例代码
作者:宇轩辞白
本文主要介绍了基于Redis-Shake实现Redis实时同步的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
一、前言
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-Shake实现Redis实时同步的示例代码的文章就介绍到这了,更多相关Redis-Shake Redis实时同步内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
