Redis与数据库数据一致性解决方案

import redis
import pymysql
from contextlib import contextmanager
 
# 连接Redis
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)
 
# 连接MySQL
mysql_conn = pymysql.connect(host='localhost', user='your_username', password='your_password', db='your_dbname')
mysql_cursor = mysql_conn.cursor()
 
@contextmanager
def redis_mysql_transaction(key, lock_timeout=10):
    """
    创建一个同时锁定Redis和MySQL的事务管理器
    :param key: Redis锁的key
    :param lock_timeout: Redis锁的超时时间
    :return: 事务上下文管理器
    """
    # 尝试从Redis获取锁
    lock_acquired = False
    while not lock_acquired:
        if redis_client.set(key, 'locked', ex=lock_timeout, nx=True):
            lock_acquired = True
        else:
            # 如果不能获取锁，等待一段时间再尝试
            sleep(0.1)
    
    try:
        # 开启MySQL事务
        mysql_conn.begin()
        # 此处是业务逻辑代码
        # ...
        yield
    except Exception as e:
        # 发生异常，回滚MySQL事务
        mysql_conn.rollback()
        raise e
    else:
        # 没有异常，提交MySQL事务
        mysql_conn.commit()
    finally:
        # 释放Redis锁
        redis_client.delete(key)
 
# 使用事务管理器
with redis_mysql_transaction('my_key'):
    # 在这里执行需要同步Redis和MySQL的操作
    pass

这个代码示例展示了如何创建一个同时锁定Redis和MySQL的事务管理器。它首先尝试从Redis获取一个锁，成功后开始一个MySQL事务，并在事务中执行需要的操作。如果操作成功完成，则提交MySQL事务；如果操作过程中发生异常，则回滚MySQL事务。最后，无论操作成功或者异常，都会释放Redis锁。这个示例提供了一个基本的框架，可以根据实际需求进行扩展和修改。