这样实现分布式锁，才叫优雅

　　概述
　　提到分布式锁大家都会想到如下两种：基于Redisson组件，使用redlock算法实现基于ApacheCurator，利用Zookeeper的临时顺序节点模型实现
　　今天我们来说说第三种，使用SpringIntegration实现。
　　SpringIntegration在基于Spring的应用程序中实现轻量级消息传递，并支持通过声明适配器与外部系统集成。SpringIntegration的主要目标是提供一个简单的模型来构建企业集成解决方案，同时保持关注点的分离，这对于生成可维护，可测试的代码至关重要。我们熟知的SpringCloudStream的底层就是SpringIntegration。
　　官方地址：https：github。comspringprojectsspringintegration
　　SpringIntegration提供的全局锁目前为如下存储提供了实现：GemfireJDBCRedisZookeeper
　　它们使用相同的API抽象，这意味着，不论使用哪种存储，你的编码体验是一样的。试想一下你目前是基于zookeeper实现的分布式锁，哪天你想换成redis的实现，我们只需要修改相关依赖和配置就可以了，无需修改代码。下面是你使用SpringIntegration实现分布式锁时需要关注的方法：
　　方法名描述lock（）Acquiresthelock。加锁，如果已经被其他线程锁住或者当前线程不能获取锁则阻塞lockInterruptibly（）Acquiresthelockunlessthecurrentthreadisinterrupted。加锁，除非当前线程被打断。tryLock（）Acquiresthelockonlyifitisfreeatthetimeofinvocation。尝试加锁，如果已经有其他锁锁住，获取当前线程不能加锁，则返回false，加锁失败；加锁成功则返回truetryLock（longtime，TimeUnitunit）Acquiresthelockifitisfreewithinthegivenwaitingtimeandthecurrentthreadhasnotbeeninterrupted。尝试在指定时间内加锁，如果已经有其他锁锁住，获取当前线程不能加锁，则返回false，加锁失败；加锁成功则返回trueunlock（）Releasesthelock。解锁实战
　　话不多说，我们看看使用SpringIntegration如何基于redis和zookeeper快速实现分布式锁，至于Gemfire和Jdbc的实现大家自行实践。基于Redis实现引入相关组件dependencygroupIdorg。springframework。bootgroupIdspringbootstarterintegrationartifactIddependencydependencygroupIdorg。springframework。integrationgroupIdspringintegrationredisartifactIddependencydependencygroupIdorg。springframework。bootgroupIdspringbootstarterdataredisartifactIddependency在application。yml中添加redis的配置spring：redis：host：172。31。0。149port：7111建立配置类，注入RedisLockRegistryConfigurationpublicclassRedisLockConfiguration｛BeanpublicRedisLockRegistryredisLockRegistry（RedisConnectionFactoryredisConnectionFactory）｛returnnewRedisLockRegistry（redisConnectionFactory，redislock）；｝｝编写测试代码RestControllerRequestMapping（lock）Log4j2publicclassDistributedLockController｛AutowiredprivateRedisLockRegistryredisLockRegistry；GetMapping（redis）publicvoidtest1（）｛LocklockredisLockRegistry。obtain（redis）；try｛尝试在指定时间内加锁，如果已经有其他锁锁住，获取当前线程不能加锁，则返回false，加锁失败；加锁成功则返回trueif（lock。tryLock（3，TimeUnit。SECONDS））｛log。info（lockisready）；TimeUnit。SECONDS。sleep（5）；｝｝catch（InterruptedExceptione）｛log。error（obtainlockerror，e）；｝finally｛lock。unlock（）；｝｝｝测试
　　启动多个实例，分别访问lockredis端点，一个正常秩序业务逻辑，另外一个实例访问出现如下错误说明第二个实例没有拿到锁，证明了分布式锁的存在。
　　注意，如果使用新版Springboot进行集成时需要使用Redis4版本，否则会出现下面的异常告警，主要是unlock（）释放锁时使用了UNLINK命令，这个需要Redis4版本才能支持。2020051411：30：24，781WARNRedisLockRegistry：339TheUNLINKcommandhasfailed（notsupportedontheRedisserver？）；fallingbacktotheregularDELETEcommandorg。springframework。data。redis。RedisSystemException：Errorinexecution；nestedexceptionisio。lettuce。core。RedisCommandExecutionException：ERRunknowncommandUNLINK基于Zookeeper实现引入组件dependencygroupIdorg。springframework。bootgroupIdspringbootstarterintegrationartifactIddependencydependencygroupIdorg。springframework。integrationgroupIdspringintegrationzookeeperartifactIddependency在application。yml中添加zookeeper的配置zookeeper：host：172。31。0。43：2181建立配置类，注入ZookeeperLockRegistryConfigurationpublicclassZookeeperLockConfiguration｛Value（｛zookeeper。host｝）privateStringzkUrl；BeanpublicCuratorFrameworkFactoryBeancuratorFrameworkFactoryBean（）｛returnnewCuratorFrameworkFactoryBean（zkUrl）；｝BeanpublicZookeeperLockRegistryzookeeperLockRegistry（CuratorFrameworkcuratorFramework）｛returnnewZookeeperLockRegistry（curatorFramework，zookeeperlock）；｝｝编写测试代码RestControllerRequestMapping（lock）Log4j2publicclassDistributedLockController｛AutowiredprivateZookeeperLockRegistryzookeeperLockRegistry；GetMapping（zookeeper）publicvoidtest2（）｛LocklockzookeeperLockRegistry。obtain（zookeeper）；try｛尝试在指定时间内加锁，如果已经有其他锁锁住，获取当前线程不能加锁，则返回false，加锁失败；加锁成功则返回trueif（lock。tryLock（3，TimeUnit。SECONDS））｛log。info（lockisready）；TimeUnit。SECONDS。sleep（5）；｝｝catch（InterruptedExceptione）｛log。error（obtainlockerror，e）；｝finally｛lock。unlock（）；｝｝｝测试
　　启动多个实例，分别访问lockzookeeper端点，一个正常秩序业务逻辑，另外一个实例访问出现如下错误说明第二个实例没有拿到锁，证明了分布式锁的存在。