抛开单机限制：Spring Boot集成Redisson解锁分布式锁新姿势

2023-10-07 13:30:54

Redisson：分布式锁在Spring Boot中的强大应用

在分布式系统中，数据的一致性和可靠性至关重要。分布式锁作为协调并发访问的手段，在保障数据完整性方面发挥着举足轻重的作用。今天，我们将深入探讨Redisson，一个基于Redis的分布式锁解决方案，带你领略分布式锁的魅力。

Redisson 简介

Redisson是一个用Java实现的分布式协调框架，它提供了丰富的分布式对象，包括分布式锁、分布式队列、分布式集合等。Redisson以Redis作为底层存储，充分利用Redis的高性能和可扩展性，为分布式应用提供了一套强大的解决方案。

Redisson 实现原理

Redisson的分布式锁实现基于Redis的SETNX和EXPIRE命令。SETNX用于设置一个键值对，只有当键不存在时才成功。EXPIRE用于设置键的过期时间。当一个线程获取锁时，它会在Redis中设置一个键值对，并将键的过期时间设置为锁的持有时间。如果另一个线程尝试获取同一个锁，它会检查键是否存在，如果存在，则说明锁已被持有，如果不存在，则表示锁可用，可以获取。

Spring Boot 集成 Redisson

引入依赖：

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.17.3</version>
</dependency>

配置 Redisson：

@Configuration
public class RedissonConfig {

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

    @Value("${spring.redis.port}")
    private int port;

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

    @Bean(destroyMethod = "shutdown")
    public RedissonClient redissonClient() {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://" + host + ":" + port);
        if (StringUtils.isNotBlank(password)) {
            config.useSingleServer().setPassword(password);
        }
        return Redisson.create(config);
    }
}

使用分布式锁：

@Service
public class DistributedLockService {

    @Autowired
    private RedissonClient redissonClient;

    public void lock(String key, long leaseTime, TimeUnit unit) {
        RLock lock = redissonClient.getLock(key);
        lock.lock(leaseTime, unit);
    }

    public void unlock(String key) {
        RLock lock = redissonClient.getLock(key);
        lock.unlock();
    }
}

实战应用

我们以一个简单的库存管理系统为例，演示Redisson分布式锁在实际场景中的应用。

@Service
public class StockService {

    @Autowired
    private DistributedLockService lockService;

    public void decreaseStock(String productId, int count) {
        String key = "stock:" + productId;

        try {
            lockService.lock(key, 10, TimeUnit.SECONDS);

            // 获取库存
            int stock = getStock(productId);

            // 减库存
            if (stock >= count) {
                setStock(productId, stock - count);
            }
        } finally {
            lockService.unlock(key);
        }
    }
}