通过SpringBoot更优雅的实现分布式锁（Spring Integration）

• 基于关系型数据库
  
• 基于Redission组件
  
• 基于Apache Curator组件，通过Zk的临时顺序节点模子实现的
  

• Redis
  
• Zookeeper
  
• Gemfire
  
• JDBC
  

• 依赖
  

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-integration</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.integration</groupId>
        <artifactId>spring-integration-zookeeper</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.integration</groupId>
        <artifactId>spring-integration-redis</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
</dependencies>
复制代码

• 设置
  

# 端口随意改几个，分别启动，模拟多个实例
server.port=12010
spring.redis.host=192.168.56.10
复制代码

• Redis锁设置类
  

package com.ideax.lock.plus.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.integration.redis.util.RedisLockRegistry;
/**
 * Redis锁配置类
 *
 * @author zhangxs
 **/
@Configuration
public class RedisLockConfiguration {
    @Bean
    public RedisLockRegistry redisLockRegistry(RedisConnectionFactory redisConnectionFactory) {
        return new RedisLockRegistry(redisConnectionFactory, "redis-lock");
    }
}
复制代码

• Zookeeper锁设置类
  

package com.ideax.lock.plus.config;
import org.apache.curator.framework.CuratorFramework;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.zookeeper.config.CuratorFrameworkFactoryBean;
import org.springframework.integration.zookeeper.lock.ZookeeperLockRegistry;
/**
 * Zk锁配置类
 *
 * @author zhangxs
 **/
@Configuration
public class ZkLockConfiguration {
    @Bean
    public CuratorFrameworkFactoryBean curatorFrameworkFactoryBean() {
        return new CuratorFrameworkFactoryBean("10.18.28.115:2181");
    }
    @Bean
    public ZookeeperLockRegistry zookeeperLockRegistry(CuratorFramework curatorFramework) {
        return new ZookeeperLockRegistry(curatorFramework, "/zookeeper-lock");
    }
}
复制代码

• 测试代码
  

package com.ideax.lock.plus.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.redis.util.RedisLockRegistry;
import org.springframework.integration.zookeeper.lock.ZookeeperLockRegistry;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
/**
 * 锁测试接口
 *
 * @author zhangxs
 **/
@RestController
@RequestMapping("lock")
public class LockController {
    @Autowired
    private RedisLockRegistry redisLockRegistry;
    @Autowired
    private ZookeeperLockRegistry zookeeperLockRegistry;
    @GetMapping("redis")
    public void redisDual() {
        businessMethod(redisLockRegistry.obtain("redis"));
    }
    @GetMapping("zk")
    public void zkDual() {
        businessMethod(zookeeperLockRegistry.obtain("zookeeper"));
    }
    protected void businessMethod(Lock lock) {
        try {
            if (lock.tryLock(3, TimeUnit.SECONDS)) {
                System.out.println("锁对象就绪...");
                TimeUnit.SECONDS.sleep(5);
            }
        } catch (InterruptedException ie) {
            System.out.println("锁获取失败...");
            ie.printStackTrace();
        } finally {
            lock.unlock();
        }
    }
}
复制代码

• 启动多个实例，发哀求看测试效果