redis与mysql的数据一致性问题（数据同步延迟）

GeekLiHua

发布于 2025-01-21 15:51:10

8800

代码可运行

文章被收录于专栏：Java

运行总次数：0

代码可运行

redis与mysql的数据一致性问题（数据同步延迟）

案例：考虑一个简单的电子商务网站，有一个商品信息服务，使用MySQL存储商品信息，而使用Redis缓存了商品的价格信息。用户在浏览商品页面时，系统首先查询Redis获取商品价格，如果缓存中不存在，则从MySQL中查询并写入Redis缓存。这样的设计可以提高访问速度，但可能导致数据同步延迟。

# Python代码示例 - 获取商品价格的逻辑
import redis
import MySQLdb

def get_product_price(product_id):
    redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)
    mysql_conn = MySQLdb.connect(host='localhost', user='user', password='password', db='ecommerce')
    cursor = mysql_conn.cursor()

    # 尝试从Redis中获取商品价格
    price = redis_client.get(f'product:{product_id}:price')

    if price is None:
        # 从MySQL中查询商品价格
        cursor.execute(f'SELECT price FROM products WHERE id={product_id}')
        result = cursor.fetchone()

        if result:
            price = result[0]

            # 将商品价格写入Redis缓存
            redis_client.set(f'product:{product_id}:price', price)

    cursor.close()
    mysql_conn.close()

    return price

解决方案：

使用消息队列进行异步更新： 在商品价格发生变化时，将更新操作放入消息队列，异步地更新Redis缓存。这样可以避免用户在查询商品价格时遇到同步延迟。

# Python代码示例 - 使用消息队列进行异步更新商品价格
import redis
import MySQLdb
import json
from kafka import KafkaProducer

def update_product_price(product_id, new_price):
    # 更新MySQL中商品价格
    mysql_conn = MySQLdb.connect(host='localhost', user='user', password='password', db='ecommerce')
    cursor = mysql_conn.cursor()
    cursor.execute(f'UPDATE products SET price={new_price} WHERE id={product_id}')
    mysql_conn.commit()
    cursor.close()
    mysql_conn.close()

    # 将更新操作放入消息队列
    message = {'product_id': product_id, 'new_price': new_price}
    producer = KafkaProducer(bootstrap_servers='localhost:9092', value_serializer=lambda v: json.dumps(v).encode('utf-8'))
    producer.send('product_price_updates', value=message)
    producer.close()

定期同步数据： 设置定时任务，定期从MySQL中获取商品价格并更新到Redis中，确保缓存数据的及时更新。

# Python代码示例 - 定期同步商品价格数据
import redis
import MySQLdb
import schedule
import time

def sync_product_prices():
    redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)
    mysql_conn = MySQLdb.connect(host='localhost', user='user', password='password', db='ecommerce')
    cursor = mysql_conn.cursor()

    # 获取所有商品ID
    cursor.execute('SELECT id FROM products')
    product_ids = [result[0] for result in cursor.fetchall()]

    for product_id in product_ids:
        # 从MySQL中查询商品价格
        cursor.execute(f'SELECT price FROM products WHERE id={product_id}')
        result = cursor.fetchone()

        if result:
            price = result[0]

            # 将商品价格写入Redis缓存
            redis_client.set(f'product:{product_id}:price', price)

    cursor.close()
    mysql_conn.close()

# 每小时执行一次同步
schedule.every().hour.do(sync_product_prices)

while True:
    schedule.run_pending()
    time.sleep(1)

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2025-01-20，如有侵权请联系 cloudcommunity@tencent.com 删除

redis