分布式锁解决方案之Redis分布式锁不可重入问题

系列文章目录

提示：这里可以添加系列文章的所有文章的目录，目录需要自己手动添加
分布式锁解决方案之Redis分布式锁不可重入问题

提示：写完文章后，目录可以自动生成，如何生成可参考右边的帮助文档

文章目录

系列文章目录
前言
一、什么是分布式锁不可重入问题？
二、解决方案
- 1.hash数据结构
- 2.可重入锁
总结

前言

提示：这里可以添加本文要记录的大概内容：

在分布式系统中，为了确保数据的一致性和避免竞态条件，我们常常需要使用分布式锁。而 Redis 作为一种高性能、高可用的缓存数据库，被广泛应用于实现分布式锁。然而，在使用 Redis 实现分布式锁时，我们可能会遇到一个常见的问题：不可重入。
不可重入问题是指，当一个线程或进程已经获取到了锁，并且在持有锁的期间再次尝试获取锁时，会被阻塞，无法获取到锁。这可能会导致线程或进程阻塞在获取锁的操作上，从而影响系统的性能和可靠性。在本博客中，我们将深入探讨 Redis 分布式锁的不可重入问题，并提供一些解决方案来避免或解决这个问题。

提示：以下是本篇文章正文内容，下面案例可供参考

一、什么是分布式锁不可重入问题？

在 Redis 分布式锁的使用中，可能会遇到不可重入问题。不可重入是指同一个线程或进程在持有锁的情况下再次尝试获取锁时会被阻塞，无法获取到锁。当一个线程或进程已经获取到了锁，并且在持有锁的期间再次尝试获取锁，这就会导致不可重入问题。在这种情况下，第二次获取锁的请求会被阻塞，因为锁已经被当前持有锁的线程或进程所持有。
为了解决不可重入问题，可以redis中的hash数据结构来解决或者用可重入锁来解决。像不可重入问题，大部分都是发生在同一个线程或进程在持有锁的情况下再次尝试获取锁时会被阻塞，无法获取到锁。所以我们让线程ID来当hash中的字段，value则以数值表示，0表示该锁没有被获取，1表示已有线程获取该锁，2表示该锁被同一线程或进程再次获取，当释放锁的时候就-1，获得锁的时候就+1.

二、解决方案

1.hash数据结构

像不可重入问题，大部分都是发生在同一个线程或进程在持有锁的情况下再次尝试获取锁时会被阻塞，无法获取到锁。所以我们让线程ID来当hash中的字段，value则以数值表示，0表示该锁没有被获取，1表示已有线程获取该锁，2表示该锁被同一线程或进程再次获取，当释放锁的时候就-1，获得锁的时候就+1，当value等于0的时候就可以删除锁了。

2.可重入锁

注：引入Jedis依赖没有具体写出，需要大家自己实现，网上都有资料，该段代码只做演示使用，具体需求具体分析

import redis.clients.jedis.Jedis;

public class RedisMutex {
    private final Jedis jedis;
    private final String lockName;
    private final String requestId;

    public RedisMutex(String host, int port, String lockName) {
        // 创建 Jedis 实例，连接到 Redis
        jedis = new Jedis(host, port);
        this.lockName = lockName;
        requestId = generateRequestId();
    }

    public boolean tryAcquire() {
        // 使用 SET 命令设置锁，同时设置超时时间
        String result = jedis.set(lockName, requestId, "NX", "EX", 5);
        return "OK".equals(result);
    }

    public void release() {
        // 使用 DEL 命令删除锁
        jedis.del(lockName);
    }

    private String generateRequestId() {
        // 生成唯一的请求 ID
        return "" + System.currentTimeMillis() + "-" + Thread.currentThread().getId();
    }
}

public class Main {
    public static void main(String[] args) {
        String host = "localhost";
        int port = 6379;
        String lockName = "my_lock";

        RedisMutex mutex = new RedisMutex(host, port, lockName);

        // 获取锁
        if (mutex.tryAcquire()) {
            try {
                System.out.println("Holding lock...");
                // 持有锁期间的操作
            } finally {
                // 释放锁
                mutex.release();
            }
        } else {
            System.out.println("Failed to acquire lock");
        }
    }
}