面试题：Redis预计算结果在复杂MySQL风险评估查询中的一致性维护

实现思路

主动更新：当MySQL数据发生变化时，主动去更新Redis中的预计算结果。这需要在MySQL数据更新的业务逻辑中添加更新Redis的代码。例如，在执行UPDATE、INSERT、DELETE等操作后，紧接着执行相应的Redis更新操作。
被动失效：不主动更新Redis，而是在查询Redis预计算结果时，检查数据是否过期或与MySQL不一致。若不一致，则重新从MySQL获取数据并重新计算预计算结果，更新到Redis中。

可能用到的技术手段

数据库触发器：在MySQL中创建触发器，当特定表的数据发生变化时，触发相应的操作，如调用外部脚本去更新Redis。例如，针对risk_assessment表创建AFTER UPDATE触发器，在数据更新后调用脚本更新Redis。

DELIMITER //
CREATE TRIGGER risk_assessment_update
AFTER UPDATE ON risk_assessment
FOR EACH ROW
BEGIN
    -- 这里可以调用外部脚本去更新Redis
    CALL update_redis_precomputed_result(); 
END //
DELIMITER ;

消息队列：使用消息队列（如Kafka、RabbitMQ），当MySQL数据更新时，发送一条消息到消息队列。有一个消费者监听该队列，接收到消息后更新Redis中的预计算结果。例如，在Java中使用Spring Boot和RabbitMQ实现：
- 生产者：

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class MysqlUpdateProducer {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMysqlUpdateMessage(String message) {
        rabbitTemplate.convertAndSend("mysql-update-exchange", "mysql-update-routing-key", message);
    }
}

- **消费者**：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class RedisUpdateConsumer {
    @RabbitListener(queues = "mysql-update-queue")
    public void handleMysqlUpdateMessage(String message) {
        // 在这里更新Redis预计算结果
    }
}

缓存标记：在Redis中设置一个标记，每次查询预计算结果时，先检查这个标记。若标记表明MySQL数据已更新，则重新计算并更新Redis。例如，在Redis中设置一个键值对mysql_risk_assessment_update_flag: true，当MySQL数据更新时，将该标记设为true。查询时：

import redis

redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)

def get_risk_assessment_result():
    flag = redis_client.get('mysql_risk_assessment_update_flag')
    if flag == b'true':
        # 从MySQL获取数据重新计算预计算结果
        result = calculate_from_mysql()
        # 更新Redis预计算结果
        redis_client.set('risk_assessment_precomputed_result', result)
        # 重置标记
        redis_client.set('mysql_risk_assessment_update_flag', 'false')
        return result
    else:
        return redis_client.get('risk_assessment_precomputed_result')

星途面试题库

面试题：Redis预计算结果在复杂MySQL风险评估查询中的一致性维护

知识考点

面试题答案

实现思路

可能用到的技术手段