面试题：Redis分布式锁分段设计应对复杂业务流程的协调

基于Redis分布式锁分段设计实现业务流程协调
- 用户账户余额检查：
  - 首先获取一个名为balance_check_lock的Redis分布式锁。可以使用SETNX（SET if Not eXists）命令，例如在Python中使用redis - py库：

import redis

r = redis.Redis(host='localhost', port = 6379, db = 0)
lock_key = 'balance_check_lock'
lock_value = 'unique_value' # 可以是UUID等唯一值
acquired = r.set(lock_key, lock_value, nx = True, ex = 10) # ex表示锁的过期时间10秒
if acquired:
    try:
        # 执行账户余额检查逻辑
        pass
    finally:
        r.delete(lock_key)
else:
    # 处理获取锁失败的情况，例如重试
    pass

 - 通过获取锁确保在同一时间只有一个进程可以检查用户账户余额，保证数据一致性。在检查余额后释放锁，以便其他进程可以进行后续操作。

资金冻结：
- 获取一个名为fund_freeze_lock的Redis分布式锁。同样使用SETNX命令：

lock_key = 'fund_freeze_lock'
acquired = r.set(lock_key, lock_value, nx = True, ex = 10)
if acquired:
    try:
        # 执行资金冻结逻辑
        pass
    finally:
        r.delete(lock_key)
else:
    # 处理获取锁失败的情况
    pass

 - 在获取到锁后，进行资金冻结操作。这一步需要依赖于前一步账户余额检查的结果，确保有足够余额才进行冻结。由于前一步余额检查已经释放了锁，所以这一步获取锁时不受余额检查锁的直接影响，但逻辑上依赖余额检查结果。

资金转移：
- 获取一个名为fund_transfer_lock的Redis分布式锁：

lock_key = 'fund_transfer_lock'
acquired = r.set(lock_key, lock_value, nx = True, ex = 10)
if acquired:
    try:
        # 执行资金转移逻辑
        pass
    finally:
        r.delete(lock_key)
else:
    # 处理获取锁失败的情况
    pass

 - 在获取到锁后，进行资金转移操作。此步骤依赖于前一步资金冻结成功，并且前一步的锁已经释放，它独立获取自己的锁来保证并发控制。

2. 处理不同步骤间锁的依赖和释放问题

锁的依赖：
- 业务逻辑上，资金冻结依赖账户余额检查结果，资金转移依赖资金冻结成功。虽然每个步骤的锁是独立获取的，但在代码逻辑中，需要在前一步骤成功完成且锁释放后，才进行下一步骤的锁获取和操作。例如，只有在账户余额检查通过且balance_check_lock释放后，才尝试获取fund_freeze_lock进行资金冻结。
锁的释放：
- 在每个步骤完成相应操作后，无论操作成功与否，都要及时释放锁。如上述代码示例，使用try - finally块，在finally中通过delete命令删除Redis中的锁键，以避免死锁。即使在操作过程中出现异常，锁也能被正确释放，确保其他进程可以获取锁继续执行后续操作。

星途面试题库

面试题：Redis分布式锁分段设计应对复杂业务流程的协调

知识考点

面试题答案