ネイティブな日本語で順番を言い換えたもの。オプションは1つだけです:spring redis 分布式ロックの実装

2年 ago
芽依, 雨夜
1 minute

RedisTemplateを活用することでSpring内でRedisの分散ロックを実装し、ロックとロック解除を実行できます。

まず分散ロックのエンティティクラスを定義する必要があります。そこにはロックの名前とロックの有効期限が含まれます。

public class RedisLock {

    private String name; // 锁名称
    private long expireTime; // 锁的过期时间

    // 构造方法和Getter/Setter省略
}

次に、ロックとアンロックのロジックを実装するためのユーティリティクラスを作成できます。

@Component
public class RedisLockUtil {

    private static final String LOCK_PREFIX = "redis_lock_"; // 锁的前缀
    private static final long DEFAULT_EXPIRE_TIME = 30000L; // 默认锁的过期时间

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    /**
     * 加锁
     * @param lockName 锁的名称
     * @return 加锁成功返回true，否则返回false
     */
    public boolean lock(String lockName) {
        String key = LOCK_PREFIX + lockName;
        RedisLock redisLock = new RedisLock(key, DEFAULT_EXPIRE_TIME);
        ValueOperations<String, Object> operations = redisTemplate.opsForValue();
        Boolean absent = operations.setIfAbsent(key, redisLock);
        if (absent != null && absent) {
            return true; // 加锁成功
        }

        // 判断锁是否过期
        RedisLock currentLock = (RedisLock) operations.get(key);
        if (currentLock != null && currentLock.getExpireTime() < System.currentTimeMillis()) {
            RedisLock newLock = new RedisLock(key, DEFAULT_EXPIRE_TIME);
            RedisLock oldLock = (RedisLock) operations.getAndSet(key, newLock);
            if (oldLock != null && oldLock.getExpireTime() < System.currentTimeMillis()) {
                return true; // 加锁成功
            }
        }

        return false; // 加锁失败
    }

    /**
     * 解锁
     * @param lockName 锁的名称
     */
    public void unlock(String lockName) {
        String key = LOCK_PREFIX + lockName;
        redisTemplate.delete(key);
    }
}

例:

@Service
public class MyService {

    @Autowired
    private RedisLockUtil redisLockUtil;

    public void doSomething() {
        // 加锁
        boolean locked = redisLockUtil.lock("myLock");
        if (locked) {
            try {
                // 执行业务逻辑
            } finally {
                // 解锁
                redisLockUtil.unlock("myLock");
            }
        } else {
            // 加锁失败，处理业务逻辑
        }
    }
}

RedisLockUtilクラスでは、lockメソッドによりロックが実行され、setIfAbsentメソッドを使用して、ロックの値をRedisに格納しようとします。返り値がtrueの場合、ロックが成功したことを示します。ロックが失敗した場合は、現在のロックが期限切れかどうかを判定します。期限切れしている場合は、getAndSetメソッドを使用して、ロックの値を更新しようとします。そのうえで、返された旧値が期限切れかどうかを判定します。期限切れしている場合は、ロックが成功したことを示します。最後に、unlockメソッドにより、ロックのキーが削除されて、ロックが解除されます。

bannerAds