概述

提到分布式鎖大家都會想到如下兩種：

• 基于Redisson組件，使用redlock算法實現(xiàn)
• 基于Apache Curator，利用Zookeeper的臨時順序節(jié)點模型實現(xiàn)

今天我們來說說第三種，使用Spring Integration實現(xiàn)。

Spring Integration在基于Spring的應(yīng)用程序中實現(xiàn)輕量級消息傳遞，并支持通過聲明適配器與外部系統(tǒng)集成。

Spring Integration的主要目標是提供一個簡單的模型來構(gòu)建企業(yè)集成解決方案，同時保持關(guān)注點的分離，這對于生成可維護，可測試的代碼至關(guān)重要。我們熟知的 Spring Cloud Stream的底層就是Spring Integration。

官方地址：https://github.com/spring-projects/spring-integration

Spring Integration提供的全局鎖目前為如下存儲提供了實現(xiàn)：

• Gemfire
• JDBC
• Redis
• Zookeeper

它們使用相同的API抽象，這意味著，不論使用哪種存儲，你的編碼體驗是一樣的。試想一下你目前是基于zookeeper實現(xiàn)的分布式鎖，哪天你想換成redis的實現(xiàn)，我們只需要修改相關(guān)依賴和配置就可以了，無需修改代碼。下面是你使用Spring Integration實現(xiàn)分布式鎖時需要關(guān)注的方法：

實戰(zhàn)

話不多說，我們看看使用Spring Integration如何基于redis和zookeeper快速實現(xiàn)分布式鎖，至于Gemfire 和 Jdbc的實現(xiàn)大家自行實踐。

基于Redis實現(xiàn)

• 引入相關(guān)組件

org.springframework.boot
spring-boot-starter-integration



org.springframework.integration
spring-integration-redis



org.springframework.boot
spring-boot-starter-data-redis

• 在application.yml中添加redis的配置

spring:
redis:
host:172.31.0.149
port:7111

• 建立配置類，注入RedisLockRegistry

@Configuration
publicclassRedisLockConfiguration{

@Bean
publicRedisLockRegistryredisLockRegistry(RedisConnectionFactoryredisConnectionFactory){
returnnewRedisLockRegistry(redisConnectionFactory,"redis-lock");
}

}

• 編寫測試代碼

@RestController
@RequestMapping("lock")
@Log4j2
publicclassDistributedLockController{
@Autowired
privateRedisLockRegistryredisLockRegistry;

@GetMapping("/redis")
publicvoidtest1(){
Locklock=redisLockRegistry.obtain("redis");
try{
//嘗試在指定時間內(nèi)加鎖，如果已經(jīng)有其他鎖鎖住，獲取當(dāng)前線程不能加鎖，則返回false，加鎖失敗；加鎖成功則返回true
if(lock.tryLock(3,TimeUnit.SECONDS)){
log.info("lockisready");
TimeUnit.SECONDS.sleep(5);
}
}catch(InterruptedExceptione){
log.error("obtainlockerror",e);
}finally{
lock.unlock();
}
}
}

• 測試
  啟動多個實例，分別訪問/lock/redis端點，一個正常秩序業(yè)務(wù)邏輯，另外一個實例訪問出現(xiàn)如下錯誤說明第二個實例沒有拿到鎖，證明了分布式鎖的存在。

注意，如果使用新版Springboot進行集成時需要使用Redis4版本，否則會出現(xiàn)下面的異常告警，主要是unlock()釋放鎖時使用了UNLINK命令，這個需要Redis4版本才能支持。

2020-05-141124,781WARNRedisLockRegistry:339-TheUNLINKcommandhasfailed(notsupportedontheRedisserver?);fallingbacktotheregularDELETEcommand
org.springframework.data.redis.RedisSystemException:Errorinexecution;nestedexceptionisio.lettuce.core.RedisCommandExecutionException:ERRunknowncommand'UNLINK'

基于Zookeeper實現(xiàn)

• 引入組件

org.springframework.boot
spring-boot-starter-integration



org.springframework.integration
spring-integration-zookeeper

• 在application.yml中添加zookeeper的配置

zookeeper:
host:172.31.0.43:2181

• 建立配置類，注入ZookeeperLockRegistry

@Configuration
publicclassZookeeperLockConfiguration{
@Value("${zookeeper.host}")
privateStringzkUrl;


@Bean
publicCuratorFrameworkFactoryBeancuratorFrameworkFactoryBean(){
returnnewCuratorFrameworkFactoryBean(zkUrl);
}

@Bean
publicZookeeperLockRegistryzookeeperLockRegistry(CuratorFrameworkcuratorFramework){
returnnewZookeeperLockRegistry(curatorFramework,"/zookeeper-lock");
}
}

• 編寫測試代碼

@RestController
@RequestMapping("lock")
@Log4j2
publicclassDistributedLockController{

@Autowired
privateZookeeperLockRegistryzookeeperLockRegistry;

@GetMapping("/zookeeper")
publicvoidtest2(){
Locklock=zookeeperLockRegistry.obtain("zookeeper");
try{
//嘗試在指定時間內(nèi)加鎖，如果已經(jīng)有其他鎖鎖住，獲取當(dāng)前線程不能加鎖，則返回false，加鎖失敗；加鎖成功則返回true
if(lock.tryLock(3,TimeUnit.SECONDS)){
log.info("lockisready");
TimeUnit.SECONDS.sleep(5);
}
}catch(InterruptedExceptione){
log.error("obtainlockerror",e);
}finally{
lock.unlock();
}
}
}