面试题：如何自定义Redis RDB自动间隔性保存异常处理的部分策略

监控机制

定期检查RDB文件：
- 可以编写一个定时脚本（如使用Linux的crontab），每隔一定时间（例如每小时）检查最新生成的RDB文件是否存在，以及文件大小是否正常。如果文件不存在或者文件大小明显小于预期（可以设定一个阈值，比如小于上一次正常RDB文件大小的80%），则判定为保存异常。
- 在脚本中可以使用Redis命令LASTSAVE获取最后一次成功保存RDB文件的时间戳，与当前时间进行对比，如果时间差超过设定的合理保存间隔（如正常保存间隔为1小时，若超过1.5小时还未成功保存则判定异常），也视为异常情况。
监控Redis日志：
- 配置Redis将日志输出到一个文件（在redis.conf中设置logfile参数）。编写一个脚本实时监控这个日志文件，例如使用tail -f命令结合grep来捕捉与RDB保存失败相关的错误信息，如“Can't save in background”等。一旦捕捉到此类错误，立即触发相应的应急措施。
使用Redis INFO命令：
- 编写程序定期（如每分钟）调用Redis的INFO命令获取服务器信息。在返回的信息中，关注rdb_last_save_time字段（上次成功保存RDB的时间）和rdb_last_bgsave_status字段（上次后台保存RDB的状态，值应为“ok”表示成功）。如果状态不为“ok”，则认为保存出现异常。

应急措施

手动触发RDB保存：
- 当监控到RDB保存异常时，通过Redis命令SAVE（阻塞式保存，会暂停Redis服务处理其他命令直到保存完成）或BGSAVE（非阻塞式，在后台进行保存）手动触发RDB保存操作。可以在脚本中使用Redis客户端（如Python的redis - py库）连接到Redis实例并执行相应命令。例如在Python中：

import redis
r = redis.Redis(host='localhost', port=6379, db = 0)
r.bgsave()

切换到AOF模式（如果未启用）：
- 如果Redis当前没有启用AOF（Append - Only File）持久化模式，可以在配置文件（redis.conf）中启用AOF，将appendonly参数设置为yes。然后重启Redis服务（可以先进行平滑重启，使用redis - cli SHUTDOWN NOSAVE关闭服务，再启动）。AOF模式可以通过追加写操作日志的方式保证数据的完整性，即使RDB保存出现问题，也能在一定程度上恢复数据。
备份现有数据：
- 当RDB保存异常时，立即对当前Redis内存中的数据进行备份。可以使用DBSIZE命令获取数据库中键的数量，然后通过KEYS *（不建议在生产环境中直接使用，因为会阻塞Redis，可使用SCAN命令分批获取）获取所有键，再使用MGET或GET命令获取对应的值，将数据备份到其他存储介质（如文件系统或远程数据库）。例如在Python中：

import redis
import json
r = redis.Redis(host='localhost', port=6379, db = 0)
keys = r.keys('*')
data = {}
for key in keys:
    data[key.decode('utf - 8')] = r.get(key)
with open('redis_backup.json', 'w') as f:
    json.dump(data, f)

通知管理员：
- 当检测到RDB保存异常并执行了应急措施后，通过邮件、短信等方式通知管理员。可以使用Python的smtplib库发送邮件，或者调用短信发送API发送短信，告知管理员RDB保存出现问题以及采取的应急措施，以便管理员进一步排查问题。例如发送邮件的Python代码：

import smtplib
from email.mime.text import MIMEText

sender = 'your_email@example.com'
receivers = ['admin_email@example.com']
message = MIMEText('Redis RDB save has an issue. Manual save triggered and AOF enabled if not already.', 'plain', 'utf - 8')
message['Subject'] = 'Redis RDB Save Problem'
message['From'] = sender
message['To'] = ','.join(receivers)

try:
    smtpObj = smtplib.SMTP('your_smtp_server.com', 587)
    smtpObj.starttls()
    smtpObj.login(sender, "your_password")
    smtpObj.sendmail(sender, receivers, message.as_string())
    smtpObj.quit()
    print("Successfully sent email")
except smtplib.SMTPException as e:
    print("Error: unable to send email", e)

星途面试题库

面试题：如何自定义Redis RDB自动间隔性保存异常处理的部分策略

知识考点

面试题答案

监控机制

应急措施