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)
