Redisson实现阻塞等待锁

在一些场景，需要实现阻塞锁，就是可以排队等待的锁。比如API调用的扣费服务中，调用不能失败 ，所以不能使用非阻塞锁，非阻塞锁的话，直接return抢占锁失败了。这个时候的扣费逻辑，为了避免重复消费等问题，就需要实现原子性。查询费用，扣费，更新三个动作需要实现最小化，不可分割化。

简单的场景可以使用MySQL的Update原子性实现。这里就使用Redisson的阻塞等待锁实现。

把扣费相关的业务放在锁内，一个请求执行完了，释放锁，下一个请求才能进来。

本文只提供关键代码。

注入RedissonClient

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 自定义redisson
 * @date 2023/8/29 1:54 AM
 */
@Configuration
public class RedissonClientConfig {

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

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

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

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

    /** 手动装载 RedissonClient */
    @Bean(name = "redissonClient")
    public RedissonClient redissonClient() {
        Config config = new Config();
        config.useSingleServer()
                .setAddress(String.format("redis://%s:%d", redisHost, redisPort))
                .setPassword(password)
                .setDatabase(database);
        return Redisson.create(config);
    }
}

阻塞等待锁使用

// 增加redisson分布式阻塞锁，可实现顺序等待
// 根据appId实现锁定
RLock lock =
        redissonClient.getLock(
                String.format(REDISSON_LOCK_NAME, authentication.getUserChainId()));
// 加锁
lock.lock(5, TimeUnit.MINUTES);
try {

    // 执行业务
  
    // 查询余额，比较
  	// 扣减余额
  	// 更新余额
  	
  	// 其他业务

} finally {
    // 释放锁
    lock.unlock();
}