基于 Redis 的跨进程同步机制实现
在单机环境下，线程锁（如 C# 中的 lock 关键字）能够确保同一时刻仅有一个线程执行临界区代码。然而当应用部署到多节点集群时，不同进程运行在不同服务器上，线程锁便鞭长莫及。此时需要一种跨进程、跨服务器的协调手段——分布式锁应运而生。
Redis 凭借其极高的读写性能与原子操作特性，成为实现分布式锁的主流方案之一。其核心思路是：各进程通过竞争式地向 Redis 写入一个带有唯一标识的键值来争夺锁权，获取成功的进程方可执行业务逻辑。
核心实现
以下封装类展示了如何利用 StackExchange.Redis 完成锁的获取与释放，包含防死锁的过期机制：
using StackExchange.Redis;
using System;
using System.Threading;
namespace DistributedSyncDemo
{
public class RedisDistributedLock : IDisposable
{
private readonly ConnectionMultiplexer _redisConnection;
private readonly IDatabase _redisDb;
private readonly string _lockKey;
private readonly string _ownerIdentity;
private readonly TimeSpan _expiryDuration;
private bool _isHeld;
public RedisDistributedLock(string connectionString, string lockName, TimeSpan? expiry = null)
{
_redisConnection = ConnectionMultiplexer.Connect(connectionString);
_redisDb = _redisConnection.GetDatabase();
_lockKey = $"distributed_lock:{lockName}";
_ownerIdentity = Guid.NewGuid().ToString("N");
_expiryDuration = expiry ?? TimeSpan.FromSeconds(30);
}
/// <summary>
/// 阻塞式获取锁，直至成功
/// </summary>
public void Acquire()
{
while (true)
{
// LockTake 原子性检查并设置，NX + EX 的封装
_isHeld = _redisDb.LockTake(_lockKey, _ownerIdentity, _expiryDuration);
if (_isHeld)
{
break;
}
// 短暂退避，降低 Redis 压力
Thread.Sleep(TimeSpan.FromMilliseconds(200));
}
}
/// <summary>
/// 释放锁，仅当持有者为当前实例时生效
/// </summary>
public void Release()
{
if (_isHeld)
{
// 通过 owner 校验避免误删他人持有的锁
_redisDb.LockRelease(_lockKey, _ownerIdentity);
_isHeld = false;
}
}
public void Dispose()
{
Release();
_redisConnection?.Dispose();
}
}
}业务层调用示例
以下 Web API 演示了在库存扣减场景中的应用。通过 using 语句确保异常情况下锁仍能释放：
using Microsoft.AspNetCore.Mvc;
using System;
using System.Threading;
namespace InventoryApi.Controllers
{
[ApiController]
[Route("api/[controller]")]
public class InventoryController : ControllerBase
{
private const string RedisConn = "192.168.0.190:6379";
[HttpPost("deduct")]
public IActionResult DeductStock()
{
using (var lockInstance = new RedisDistributedLock(RedisConn, "inventory:deduct"))
{
lockInstance.Acquire();
// 模拟查询库存
var currentStock = QueryStockFromDb();
if (currentStock <= 0)
{
return new JsonResult(new { success = false, message = "库存不足，抢购结束" });
}
// 执行扣减
var newStock = currentStock - 1;
UpdateStockToDb(newStock);
return new JsonResult(new { success = true, message = $"抢购成功，剩余库存：{newStock}" });
}
}
private int QueryStockFromDb()
{
// 实际应从数据库读取
return new Random().Next(0, 5);
}
private void UpdateStockToDb(int stock)
{
// 持久化更新逻辑
}
}
}关键注意点
- 唯一标识： 每个锁实例拥有独立的
_ownerIdentity，释放时 Redis 会校验持有者，防止出现 "误删他人锁" 的竞态条件。 - 过期时间： 必须设置合理的 TTL，避免进程崩溃导致锁永远无法释放。建议 TTL 略大于业务最大执行时间。
- 可重入性： 上述实现未支持同一线程内的嵌套加锁，若需可重入特性，需额外维护线程本地的重入计数器。
- 续期机制： 对于执行时间不可预估的长任务，可引入 Watchdog 线程定期延长锁的过期时间，防止业务未完成锁已失效。
对于更高可靠性的场景，可考虑 Redlock 算法，在多个独立 Redis 节点间达成多数派共识，以容忍单点故障。
