Heily.Abp.DistributedLock 0.0.14

公司项目需要在现有abp框架的基础上自行扩展一套分布式锁模块出来，github没翻到类似的项目，自己照着abp的模块基于RedLockNet 封了一套，基本满足我目前所在项目的需求，这里简单记录下用法

1.在Host项目Module上加入模块依赖特性

[DependsOn(typeof(RedLockModule))]

2.StartUp初始化

在StartUp 的ConfigureServices方法中对redlock做初始化操作

services.AddRedLock(config =>
            {
                config.AddEndPoint(new RedLockEndPoint(new List<EndPoint>
                {
                    new DnsEndPoint("192.168.23.101", 6379),
                    new DnsEndPoint("192.168.23.101", 6380),
                }));
            });

3.Module初始化

也可以直接在Host项目Module的模块方法PreInitialize中对Redlock做初始化操作

if (!Configuration.Modules.RedLockConfiguration().IsInit)
            {
                Configuration.Modules.RedLockConfiguration().AddEndPoint(new RedLockEndPoint(new List<EndPoint>
                {
                    new DnsEndPoint("192.168.23.101", 6379),
                    new DnsEndPoint("192.168.23.101", 6380),
                }));

                Configuration.Modules.RedLockConfiguration().Expiry = 130;
                Configuration.Modules.RedLockConfiguration().Disabled = true;
                Configuration.Modules.RedLockConfiguration().Wait = 50;
            }

注意，2，3两条只能任选其一进行初始化，否则应用将无法启动

4.全方法加锁

基于winsor拦截器实现 该用法只需要在要加锁的方法前标记特性 Lock 即可生效，默认锁定的资源名称为当前方法名，支持自定义锁定资源key的名称和过期时间，支持自定义未获取锁的错误提示信息，默认未获取锁不会执行方法

// 领域层方法
public class MyCustomerDomainService : DomainService
    {
        private readonly ILockManager _lockManager;

        public MyCustomerDomainService(ILockManager lockManager)
        {
            _lockManager = lockManager;
        }

        [Lock]
        public virtual void Lock_DomainService_Test()
        {
            using (var varLock = _lockManager.CreateLock().Lock(nameof(Lock_DomainService_Test), null))
            {
                Assert.False(varLock.IsAcquired);
            }
        }
    }

// 应用层方法
public class MyCustomerAppService : ApplicationService
    {
        private readonly ILockManager _lockManager;

        public MyCustomerAppService(ILockManager lockManager)
        {
            _lockManager = lockManager;
        }

        [Lock]
        public virtual void Lock_ApplicationService_Test()
        {

            using (var varLock = _lockManager.CreateLock().Lock(nameof(Lock_ApplicationService_Test), null))
            {
                Assert.False(varLock.IsAcquired);
            }
        }
    }

5.自定义加锁逻辑

自定义加锁，只需要注入加锁服务对象ILockManager,使用对象的CreateLock方法或者CreateLockAsync创建加锁对象，调用其Lock方法，即可完成加锁过程

       private readonly ILockManager _redLockManager;
       public RedLockTest(ILockManager lockManager)
       {
           _redLockManager = lockManager;
       }
       public void LockTest()
       {
           using (var redLock = _redLockManager.CreateLock().Lock(nameof(LockTest), null))
               {
                   if(redLock.IsAcquired){
                       // 这里就是你的业务代码
                   }
               }
       }