在.Net中使用RedLock實現分布式鎖

⒈簡介

　　RedLock 分布式鎖算法由 Redis 的作者提出，大部分語言都有對應的實現，查看，RedLock.net 是 RedLock 分布式鎖算法的 .NET 版實現，用來解決分布式下的並發問題。

　　RedLock 的思想是使用多台 Redis Master ，節點之間完全獨立，節點間不需要進行數據同步，因為 Master-Slave 架構一旦 Master 發生故障時數據沒有復制到 Slave，被選為 Master 的 Slave 就丟掉了鎖，另一個客戶端就可以再次拿到鎖。

　　鎖通過 setNX（原子操作） 命令設置，在有效時間內當獲得鎖的數量大於 (n/2+1) 代表成功，失敗后需要向所有節點發送釋放鎖的消息。

　　獲取鎖：

SET resource_name my_random_value NX PX 30000

　　釋放鎖：

if redis.call("get",KEYS[1]) == ARGV[1] then
    return redis.call("del",KEYS[1])
else
    return 0
end

⒉使用

　　1.創建 .NETCore API 項目

　　2.Nuget 安裝 RedLock.net

Install-Package RedLock.net

　　3.appsettings.json 添加 redis 配置

{
  "Logging": {
    "LogLevel": {
      "Default": "Warning"
    }
  },
  "AllowedHosts": "*",
  "RedisUrls": [
    "127.0.0.1:6379",
    "192.168.214.128:6379"
  ]
}

　　4.添加 ProductService.cs，模擬商品購買

// 有10個商品庫存，如果同時啟動多個API服務進行測試，這里改成存數據庫或其他方式
private static int stockCount = 10;
public async Task<bool> BuyAsync()
{
    // 模擬執行的邏輯代碼花費的時間
    await Task.Delay(new Random().Next(100, 500));
    if (stockCount > 0)
    {
        stockCount--;
        return true;
    }
    return false;
}

　　5.修改 Startup.cs ，創建 RedLockFactory

　　　　1.定義RedLockFactory屬性

        private RedLockFactory lockFactory
        {
            get
            {
                var redisUrls = Configuration.GetSection("RedisUrls").GetChildren().Select(s => s.Value).ToArray();
                if(redisUrls.Length <= 0)
                {
                    throw new ArgumentException("RedisUrl 不能為空");
                }
                var endPoints = new List<RedLockEndPoint>();
                foreach (var item in redisUrls)
                {
                    var arr = item.Split(":");
                    endPoints.Add(new DnsEndPoint(arr[0], Convert.ToInt32(arr[1])));
                }
                return RedLockFactory.Create(endPoints);
            }
        }

　　　　2.在 ConfigureServices 注入 IDistributedLockFactory：

        // This method gets called by the runtime. Use this method to add services to the container.
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
            services.AddSingleton(typeof(IDistributedLockFactory), lockFactory);
            services.AddScoped(typeof(ProductService));
        }

　　　　3.修改 Configure，應用程序結束時釋放 lockFactory

        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
        public void Configure(IApplicationBuilder app, IHostingEnvironment env, IApplicationLifetime lifetime)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }

            app.UseMvc();

            lifetime.ApplicationStopping.Register(() =>
            {
                lockFactory.Dispose();
            });

        }

　　6.在 Controller 添加方法 DistributedLockTest

private readonly IDistributedLockFactory _distributedLockFactory;
private readonly ProductService _productService;

public HomeController(IDistributedLockFactory distributedLockFactory,
    ProductService productService)
{
    _distributedLockFactory = distributedLockFactory;
    _productService = productService;
}

[HttpGet]
public async Task<bool> DistributedLockTest()
{
    var productId = "id";
    // resource 鎖定的對象
    // expiryTime 鎖定過期時間，鎖區域內的邏輯執行如果超過過期時間，鎖將被釋放
    // waitTime 等待時間,相同的 resource 如果當前的鎖被其他線程占用,最多等待時間
    // retryTime 等待時間內，多久嘗試獲取一次
    using (var redLock = await _distributedLockFactory.CreateLockAsync(productId, TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(1), TimeSpan.FromMilliseconds(20)))
    {
        if (redLock.IsAcquired)
        {
            var result = await _productService.BuyAsync();
            return result;
        }
        else
        {
            Console.WriteLine($"獲取鎖失敗：{DateTime.Now}");
        }
    }
    return false;
}

 

　　在文章RedLock 實現分布式鎖基礎之上修改部分代碼編寫。