溪云阁：专注编程教学，架构，JAVA，Python，微服务，机器学习等领域，欢迎关注，一起学习。

前言

在现在很多分布式环境中有非常多的场景，如唯一主键ID生成、秒杀系统，特别是电商系统中，高并发中的情况最常见。在现有的技术上有几种方式实现，基于DB，基于ZK，基于Redis，今天我们介绍基于Redis官方推荐的方式-----Redission。

几种分布式优缺点对比

基于DB层面的分布式锁

1、DB层面性能比较差，存在锁表的风险。

2、针对非阻塞操作，如果存在失败的操作，需要不断进行轮训操作查询，此时CPU的占用率是个问题。

3、存在长时间的等待状态，即没有commit状态，此时连接资源一直处于被占用状态。

基于Redis层面的分布式锁

1、锁删除失败后，存在过期时间无法控制问题，需要进行二开封装，默认有个过期时间

2、与DB操作一样，针对非阻塞操作，如果存在失败的操作，需要不断进行轮训操作查询，此时CPU的占用率是个问题。

基于ZK层面的分布式锁

1、性能上强于DB，但是并不如Redis，介于中间态

总结

从性能上分析：Redis＞ZK＞DB

从复杂度分析：DB＞Redis＞ZK

从可靠性分析：ZK＞Redis＞DB

基于Redission实现

<!-- 引入Redission包 -->
<dependency>
			<groupId>org.redisson</groupId>
			<artifactId>redisson</artifactId>
			<version>3.14.1</version>
</dependency>

#### 编写配置文件
# redis地址
boots.redis.host: 127.0.0.1
# redis端口号
boots.redis.port: 6379
# redis密码，如果没有不用填写，建议还是得有
boots.redis.password: 123456

/**
 * Redission配置文件
 * @author：OprCalf
 * @date：2021-1-9 15:03:35
 */
@Configuration
public class RedissonConfig {

    @Value("${boots.redis.host}")
    private String host;

    @Value("${boots.redis.port}")
    private String port;

    @Value("${boots.redis.password}")
    private String password;

    /**
     * 初始化Redission连接客户端
     * @author OprCalf
     * @Date 2021-1-9 15:10:08
     * @return RedissonClient
     */
    @Bean
    public RedissonClient initRedisson() {
        final Config config = new Config();
        // 设置数据传输模式为NIO
        config.setTransportMode(TransportMode.NIO);
        // 采用单体redis进行配置
        final SingleServerConfig singleConfig = config.useSingleServer();
        // 配置连接地址
        singleConfig.setAddress("redis://" + host + ":" + port);
        // 配置密码
        singleConfig.setPassword(password);
        return Redisson.create(config);
    }

@Api(tags = { "web服务：分布式锁接口" })
@RestController
@RequestMapping("view/redission")
@Slf4j
public class RedissionView {

    @Autowired
    private RedissonClient redissonClient;

    /**
     *
     * @author OprCalf
     * @Date 2021-1-9 15:52:54
     * @param lockKey 锁密钥
     * @return ResponseMsg<String>
     */
    @ApiOperation(value = "获取加锁数据")
    @GetMapping(value = "/getLock", produces = MediaType.APPLICATION_JSON_VALUE)
    @SneakyThrows(CommonRuntimeException.class)
    public ResponseMsg<String> getLock(@RequestParam(value = "lockKey") String lockKey) {
        // 根据入参获取当前锁
        final RLock lock = redissonClient.getLock(lockKey);
        boolean getLock = false;
        try {
            // 开始加锁，最多等待2秒，上锁以后5秒自动解锁
            if (getLock = lock.tryLock(2, 5, TimeUnit.SECONDS)) {
                return MsgUtils.buildSuccessMsg("拿到锁成功");
            } else {
                return MsgUtils.buildFailureMsg("拿到锁失败");
            }
        }
        catch (final InterruptedException e) {
            return MsgUtils.buildFailureMsg("获取分布式锁发生异常");
        }
        finally {
            if (getLock) {
                lock.unlock();
                log.info("释放锁成功");
            }
        }
    }

总结

目前在现有的技术栈采用Redission是最常见的一种实现方式，也是最便捷的方式，整体性从性能，稳健度来说是比较靠谱的方案。

--END--

作者：@溪云阁

原创作品，抄袭必究

如需要源码，请转发，关注后私信我

部分图片或代码来源网络，如侵权请联系删除，谢谢！