一、引言
在分布式系统中，多个服务实例可能会同时访问共享资源。为了避免数据不一致或其他并发问题，需要使用分布式锁来保证同一时间只有一个服务实例能够访问该资源。Redis 是一个高性能的键值存储数据库，由于其单线程的特性，非常适合用来实现分布式锁。本文将详细介绍在 .NET Core 中如何使用 Redis 创建分布式锁。
二、Redis 分布式锁的原理
Redis 分布式锁的核心原理是利用 Redis 的原子性操作。当一个客户端尝试获取锁时，会向 Redis 服务器发送一个 SET 命令，并且设置一个唯一的锁标识（通常是一个随机字符串）和过期时间。如果该键不存在，SET 命令会成功执行，客户端就获取到了锁；如果键已经存在，SET 命令会失败，客户端就无法获取到锁。当客户端完成操作后，会使用 DEL 命令释放锁。
三、环境准备
1. 安装 Redis
首先，你需要在本地或服务器上安装 Redis。可以从 Redis 官方网站（https://redis.io/download）下载并安装 Redis。安装完成后，启动 Redis 服务器。
2. 创建 .NET Core 项目
打开命令行工具，使用以下命令创建一个新的 .NET Core 控制台项目：
dotnet new console -n RedisDistributedLockDemo
cd RedisDistributedLockDemo
3. 安装 StackExchange.Redis 包
StackExchange.Redis 是一个流行的 Redis 客户端库，用于在 .NET 应用程序中与 Redis 服务器进行交互。使用以下命令安装该包：
dotnet add package StackExchange.Redis
四、实现 Redis 分布式锁
1. 编写分布式锁类
在项目中创建一个名为 RedisDistributedLock 的类，用于实现分布式锁的获取和释放操作。以下是该类的代码示例：
using StackExchange.Redis;
using System;
using System.Threading;
using System.Threading.Tasks;
publicclassRedisDistributedLock : IDisposable
{
privatereadonly IDatabase _database;
privatereadonlystring _lockKey;
privatereadonlystring _lockValue;
privatereadonly TimeSpan _expiry;
privatebool _isDisposed;
public RedisDistributedLock(IDatabase database, string lockKey, TimeSpan expiry)
{
_database = database;
_lockKey = lockKey;
_lockValue = Guid.NewGuid().ToString();
_expiry = expiry;
}
public async Task<bool> AcquireAsync(CancellationToken cancellationToken = default)
{
while (!cancellationToken.IsCancellationRequested)
{
var acquired = await _database.StringSetAsync(_lockKey, _lockValue, _expiry, When.NotExists);
if (acquired)
{
returntrue;
}
await Task.Delay(100, cancellationToken);
}
returnfalse;
}
public async Task ReleaseAsync()
{
var storedValue = await _database.StringGetAsync(_lockKey);
if (storedValue.HasValue && storedValue.ToString() == _lockValue)
{
await _database.KeyDeleteAsync(_lockKey);
}
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
protected virtual void Dispose(bool disposing)
{
if (!_isDisposed)
{
if (disposing)
{
ReleaseAsync().Wait();
}
_isDisposed = true;
}
}
}
2. 使用分布式锁
在 Program.cs 文件中，编写代码来使用分布式锁。以下是示例代码：
using StackExchange.Redis;
using System;
using System.Threading;
using System.Threading.Tasks;
classProgram
{
static async Task Main()
{
var connection = ConnectionMultiplexer.Connect("localhost");
var database = connection.GetDatabase();
var lockKey = "myDistributedLock";
var expiry = TimeSpan.FromSeconds(10);
using (var distributedLock = new RedisDistributedLock(database, lockKey, expiry))
{
var acquired = await distributedLock.AcquireAsync(CancellationToken.None);
if (acquired)
{
try
{
Console.WriteLine("Lock acquired. Performing critical section...");
await Task.Delay(5000); // 模拟耗时操作
Console.WriteLine("Critical section completed.");
}
finally
{
await distributedLock.ReleaseAsync();
Console.WriteLine("Lock released.");
}
}
else
{
Console.WriteLine("Failed to acquire lock.");
}
}
}
}
五、代码解释
1. RedisDistributedLock 类
_database：用于与 Redis 数据库进行交互的 IDatabase 对象。
_lockValue：锁的唯一标识，使用 Guid.NewGuid().ToString() 生成。
