Redis主从切换过程中数据丢失问题排查与解决

1. 修正waitReplias()的调用逻辑 #

• 必须在**事务执行完成（exec()调用后）**立即调用waitReplias()，Redis事务的原子执行仅保证主节点操作完成，复制是异步触发的，事务结束后调用才能确保等待的是当前事务数据的同步。
• 核对参数有效性：waitReplias(replicasCount, timeout)中，replicasCount要设置为集群中需要确认同步的从节点数量（比如2个从节点就设为2），timeout需设置合理阈值（如1000ms，避免过短导致同步未完成就终止等待）。
• 必须校验返回值：waitReplias()返回成功同步的从节点数，只有当返回值等于设定的replicasCount时，才能确认数据已同步，否则要执行重试或告警逻辑，不能仅调用方法而忽略结果。

2. 配置主节点同步强制策略 #

在主节点的redis.conf中开启以下配置，从源头避免未同步数据的写操作：

min-slaves-to-write 1  # 至少1个从节点完成同步才接受写请求
min-slaves-max-lag 10  # 从节点同步延迟不得超过10秒

这样主节点会在没有足够可用从节点时拒绝写请求，防止数据仅存在于主节点内存就发生切换。

3. 重构UnifiedJedis的写确认逻辑 #

不要把事务的OK返回作为数据安全的标志，事务成功仅代表主节点执行完成，需结合同步确认实现强一致性：

try (UnifiedJedis jedis = jedisPool.getResource()) {
    jedis.multi();
    // 执行事务内的读写操作
    jedis.set("user:1001", "{\"name\":\"test\"}");
    List<Object> execResult = jedis.exec();
    
    if (execResult != null && !execResult.isEmpty()) {
        // 等待从节点同步当前事务数据
        long syncedNum = jedis.waitReplias(1, 1000);
        if (syncedNum < 1) {
            throw new RuntimeException("数据未同步至指定从节点，操作回滚");
        }
    } else {
        throw new RuntimeException("事务执行失败");
    }
}

4. 优化主从切换机制 #

• 检查哨兵/集群管理工具（如Redis Cluster、K8s StatefulSet）的切换策略：确保主节点下线后，等待所有从节点完成数据同步再晋升新主，避免仓促切换导致数据断层。
• 配置从节点replica-priority值：将同步最完整的从节点设置为较低优先级（优先级更高），确保晋升的新主是数据最新的节点。

5. 排查事务使用误区 #

• Redis事务不支持运行时回滚，仅在命令入队出错时才会取消事务，需检查事务内所有操作的执行结果，避免因单条命令执行失败导致部分数据未写入。
• 避免事务执行期间有其他客户端修改同一键值，导致数据被覆盖。

内容的提问来源于stack exchange，提问作者Ganesh Gudghe