5、Spring Cloud Alibaba微服务系列-分布式锁

2021-05-28 本文已影响0人小虎哥的技术博客

目录 Spring Cloud Alibaba 微服务系列文章

一、前言

什么是锁，为什么需要锁，拿一个简单例子，注册账号，一般需要三步：

根据账号查询数据库，获取查询结果
判断结果账号是否为空
如果为空则进行注册，不为空返回该账户已被注册。

如果两个人同时用同一个账号注册，第一个人已经走到了第三步，已经判断了数据库该账号没有被注册，正准备注册但是还没有注册，此时第二个人判断数据库该账户没有被注册，也走到了第三步。然后两个人用同一个账号都注册了一次，数据库产生了两条相同的记录。

涉及到抢购资源的时候就会涉及到锁，单体应用中简单粗暴的方式就是用synchronized,或者用乐观锁，在数据库上加上一个类似version的判断。

但是在微服务中，一个服务会部署多个实例，而且数据库有可能也是分库分表的，所以就需要借助第三方中间件来解决分布式锁。Redis利用它数据结构的特性可以做分布式锁，但是需要自己写脚本，Redisson是基于Redis封装的，简单好用，不需要自己再写脚本。

二、Maven依赖

pom.xml添加如下依赖

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
</dependency>

三、application.properties

配置文件加上redis的配置信息

# redis 相关
spring.redis.host=localhost
spring.redis.port=6379

四、使用Redisson

这里模拟客户下单：先减商品库存、然后创建订单

QQ截图20210524132953.png

package com.llh.consumer.service.impl;

import com.llh.consumer.service.ConsumerService;
import com.llh.order.api.feign.OrderApi;
import com.llh.product.api.feign.ProductApi;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;


/**
 * @author 小虎哥的技术博客
 */
@Service
public class ConsumerServiceImpl implements ConsumerService {
    @Resource
    private RedissonClient redissonClient;

    @Resource
    private ProductApi productApi;

    @Resource
    private OrderApi orderApi;

    @Override
    public Boolean buy(Long productId, Integer number) {
        RLock lock = redissonClient.getLock("lock_key");
        // 加锁
        lock.lock();
        // 先减商品库存
        boolean decreaseResult = productApi.decrease(productId, number);
        if (decreaseResult) {
            // 商品库存减成功后 创建订单
            boolean createResult = orderApi.create(productId, number);
            // 解锁
            lock.unlock();
            return createResult;
        }
        return false;
    }
}