面试题：Redis有序集合加速MySQL范围查询中的数据一致性问题

可能出现数据不一致的场景

更新操作不同步：当在MySQL中更新数据后，如果没有及时同步到Redis有序集合，此时查询Redis可能得到旧数据。例如电商项目中商品价格在MySQL更新，但Redis未更新，用户通过Redis加速查询到旧价格。
删除操作不同步：在MySQL删除数据记录，而Redis有序集合未及时删除对应的记录。比如博客系统中一篇文章在MySQL删除，但Redis仍保留其相关排名数据，导致查询时出现已删除数据仍在列表中的情况。
高并发下同步冲突：在高并发环境中，多个更新操作同时进行，可能导致MySQL和Redis同步顺序混乱。例如多个用户同时对商品销量进行更新，可能使Redis数据更新顺序与MySQL不一致，进而造成数据不一致。

同步策略及技术手段

基于事务的同步：在实际项目中，如订单系统，将MySQL更新操作和Redis更新操作放在同一个事务中。在Java中可以使用Spring的事务管理，确保要么两者都成功更新，要么都回滚。例如：

@Transactional
public void updateOrderAndRedis(Order order) {
    // 更新MySQL订单数据
    orderRepository.save(order);
    // 更新Redis有序集合，假设使用Jedis
    Jedis jedis = new Jedis("localhost");
    jedis.zadd("order_score", order.getScore(), order.getId().toString());
    jedis.close();
}

消息队列异步同步：引入消息队列如Kafka，当MySQL数据发生变化时，发送消息到队列。消费者监听队列，接收到消息后更新Redis。以电商库存管理为例，MySQL库存数据变化时，发送库存更新消息到Kafka，消费者消费消息更新Redis库存有序集合，保证数据最终一致性。
定期数据校对：设置定时任务，定期对比MySQL和Redis数据。例如每晚凌晨对关键数据进行校对，发现不一致则进行修复。在Python中可以使用APScheduler库实现定时任务，通过对比MySQL和Redis的数据记录，对不一致的数据进行重新同步。

from apscheduler.schedulers.background import BackgroundScheduler
import redis
import pymysql

def check_and_sync():
    # 连接MySQL
    conn = pymysql.connect(host='localhost', user='root', password='password', database='test')
    cursor = conn.cursor()
    cursor.execute('SELECT id, score FROM data_table')
    mysql_data = cursor.fetchall()
    conn.close()

    # 连接Redis
    r = redis.Redis(host='localhost', port=6379, db=0)
    redis_data = r.zrange('data_score', 0, -1, withscores=True)

    # 对比并同步数据
    for item in mysql_data:
        id = item[0]
        score = item[1]
        if (str(id).encode('utf-8'), score) not in redis_data:
            r.zadd('data_score', {str(id): score})
    for item in redis_data:
        id = item[0].decode('utf-8')
        score = item[1]
        if (int(id), score) not in mysql_data:
            r.zrem('data_score', id)

scheduler = BackgroundScheduler()
scheduler.add_job(check_and_sync, 'cron', hour=0)
scheduler.start()

星途面试题库

面试题：Redis有序集合加速MySQL范围查询中的数据一致性问题

知识考点

面试题答案

可能出现数据不一致的场景

同步策略及技术手段