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

# 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

# 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()

# 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)