保证MySQL与Redis数据一致性的6种实现方案

// 更新MySQL
userMapper.update(user);
// 更新Redis
redisTemplate.opsForValue().set("user_" + user.getId(), user);

// 更新MySQL
userMapper.update(user);
// 发送消息
rabbitTemplate.convertAndSend("updateUser", user.getId());
然后在消息消费者中更新Redis。

@RabbitListener(queues = "updateUser")
public void updateUser(String userId) {
    User user = userMapper.selectById(userId);
    redisTemplate.opsForValue().set("user_" + user.getId(), user);
}

@EventListener
public void onBinlogEvent(BinlogEvent event) {
    if (event.getTable().equals("user") && event.getType().equals("UPDATE")) {
        String userId = event.getData().get("id");
        User user = userMapper.selectById(userId);
        redisTemplate.opsForValue().set("user_" + user.getId(), user);
    }
}

// 更新MySQL
userMapper.update(user);
// 更新Redis
redisTemplate.opsForValue().set("user_" + user.getId(), user);
// 更新版本号
redisTemplate.opsForValue().increment("version_user_" + user.getId());

redisTemplate.execute(new SessionCallback<Object>() {
    @Override
    public Object execute(RedisOperations operations) throws DataAccessException {
        // 开启事务
        operations.multi();
        // 更新MySQL
        userMapper.update(user);
        // 更新Redis
        operations.opsForValue().set("user_" + user.getId(), user);
        // 执行事务
        operations.exec();
        return null;
    }
});