Redis缓存和Redis分布式锁使用及说明

// 设置过期时间
db.KeyExpire("temp_data", TimeSpan.FromMinutes(30));

// 滑动过期
db.StringSet("session:1001", data, TimeSpan.FromMinutes(20), when: When.Always);

// 示例：使用 Redlock 或 StackExchange.Redis 锁
var redisLock = _redis.AcquireLock("lock:order_123", TimeSpan.FromSeconds(30));
try
{
    if (redisLock.IsAcquired)
    {
        // 执行业务逻辑（如扣减库存）
        _stockService.ReduceStock(productId, 1);
    }
}
finally
{
    redisLock?.Release(); // 释放锁
}

//锁信息集合
var trayBarcodeLockInfos = new List<IRedLock>(); 
try
 {
   //获取锁
     var lockInfo = await _redLockLead.AcquireLockAsync(moveTrayBalance.TrayBarcode);

     _ = !lockInfo.IsAcquired ? throw new BusinessException(message: _localizer["_TrayBarcodeRequestExist", moveTrayBalance.TrayBarcode]) : false;

     trayBarcodeLockInfos.Add(lockInfo); //获取锁成功 将锁加入集合中

  //执行业务逻辑
  ··········

 }
 catch (BusinessException ex)
 {

 } 
finally
 {
    //释放锁
     foreach (var lockInfo in trayBarcodeLockInfos)
     {
         await _redLockLead.ReleaseLockAsync(lockInfo);
     }
 }

/// <summary>
/// 获取锁(获取不到立即返回失败)
/// </summary>
/// <param name="lockKey"></param>
/// <returns></returns>
public virtual async Task<IRedLock> AcquireLockAsync(string lockKey)
{
    var redLock = await _factoryProvider.RedLockFactoryInstance.CreateLockAsync(lockKey, _defaultKeyExpiry);
    return redLock;
}

/// <summary>
/// 获取锁(阻塞直到获取锁成功或者1h后仍获取不到，返回失败)
/// </summary>
/// <param name="lockKey"></param>
/// <returns></returns>
public virtual async Task<IRedLock> AcquireLockUntilSuccessAsync(string lockKey)
{
    var redLock = await _factoryProvider.RedLockFactoryInstance.CreateLockAsync(lockKey, _defaultKeyExpiry, _wait, _retry);
    return redLock;
}


public async Task<IRedLock> CreateLockAsync(string resource, TimeSpan expiryTime, TimeSpan waitTime, TimeSpan retryTime, CancellationToken? cancellationToken = null)
{
    return await RedLock.CreateAsync(loggerFactory.CreateLogger<RedLock>(), redisCaches, resource, expiryTime, waitTime, retryTime, configuration.RetryConfiguration, cancellationToken ?? CancellationToken.None).ConfigureAwait(continueOnCapturedContext: false);
}

/// <summary>
/// 释放锁
/// </summary>
/// <param name="redLock"></param>
/// <returns></returns>
public virtual async Task ReleaseLockAsync(IRedLock redLock)
{
    await redLock.DisposeAsync();
}