Redis缓存与数据库一致性的完整指南

public void updateData(Data data) {  
    // 1. 更新数据库  
    dataDao.update(data);  
    
    // 2. 首次删除缓存  
    redis.del("data:" + data.getId());  
    
    // 3. 延迟二次删除  
    executor.schedule(() -> {  
        redis.del("data:" + data.getId());  
    }, 500, TimeUnit.MILLISECONDS); // 根据主从延迟调整  
}  

# 写入更新命令  
XADD data_ops * type update id 123 value 100  

# 消费者顺序执行  
XREAD BLOCK 0 STREAMS data_ops $  

canal.instance.master.address=127.0.0.1:3306  
canal.instance.dbUsername=canal  
canal.instance.dbPassword=canal  
canal.mq.topic=data_cache  

@GlobalTransactional  
public void updateData(Data data) {  
    dataDao.update(data); // 更新DB  
    redisTemplate.delete("data:" + data.getId()); // 删缓存  
}  

public Data getData(long id) {  
    String cacheKey = "data:" + id;  
    Data data = redis.get(cacheKey);  
    if (data == null) {  
        data = db.query("SELECT * FROM data WHERE id=?", id);  
        redis.set(cacheKey, data);  
    } else if (data.version < db.getVersion(id)) {  
        // 版本落后则刷新  
        data = refreshFromDb(id);  
    }  
    return data;  
}  

// 带重试的删除  
void deleteWithRetry(String key, int maxRetries) {  
    int retry = 0;  
    while (retry < maxRetries) {  
        if (redis.del(key) == 1) break;  
        Thread.sleep(100);  
        retry++;  
    }  
    if (retry == maxRetries) {  
        mq.send("cache_clean", key); // 投递消息队列  
    }  
}  

延迟双删的等待时间 > 主从延迟最大值  

// 伪代码:标准操作顺序  
void updateData(Data data) {  
    1. db.update(data);  
    2. redis.delete(key);  
    3. // 可选:延迟二次删除  
}  

# 缓存不一致率 = (缓存错误数 / 总请求数)  
redis-cli info | grep keyspace_misses  
mysql> SHOW STATUS LIKE 'Innodb_rows_read';