分布式锁之Jedis大招，掌握独门绝技，稳稳拿捏！

2023-04-14 21:30:14

分布式锁：利用 Redis 和 Jedis 避免并发数据污染

导语

在分布式微服务架构中，多服务同时访问共享数据时，数据污染是一个常见的挑战。分布式锁是一种技术解决方案，可以防止这种污染，确保数据的一致性和完整性。本文将深入探讨如何使用流行的 Redis 客户端库 Jedis 在 Redis 中实现分布式锁，以应对并发问题。

单机锁与分布式锁

单机锁

在单体应用程序中使用，仅控制单机上的并发访问。
Java 中的 juc 库提供了单机锁，但无法解决分布式环境中的并发问题。

分布式锁

适用于分布式微服务架构，控制多个服务对共享数据的并发访问。
跨服务进行并发控制，避免数据污染。

使用 Jedis 实现分布式锁

1. 添加依赖

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.8.1</version>
</dependency>

2. Java 实现

import redis.clients.jedis.Jedis;

public class RedisDistributedLock {
    private static Jedis jedis = new Jedis("localhost");

    public static void main(String[] args) {
        String key = "my_lock";
        String value = "1";
        // 加锁：NX 表示不存在才设置，EX 表示设置过期时间（单位：秒）
        String result = jedis.set(key, value, "NX", "EX", 10);
        if ("OK".equals(result)) {
            // 执行业务逻辑
            System.out.println("加锁成功，执行业务逻辑");
            // 释放锁：先判断锁是否属于自己，防止误删
            if (value.equals(jedis.get(key))) {
                jedis.del(key);
            }
        } else {
            System.out.println("加锁失败，锁已被占用");
        }
        jedis.close();
    }
}

3. 可重入锁实现

可重入锁允许同一线程多次获取同一把锁，防止死锁。

import redis.clients.jedis.Jedis;

public class RedisDistributedLockReenterable {
    private static Jedis jedis = new Jedis("localhost");

    public static void main(String[] args) {
        String key = "my_lock";
        String requestId = UUID.randomUUID().toString();
        // 加锁：NX 表示不存在才设置，EX 表示设置过期时间（单位：秒）
        String result = jedis.set(key, requestId, "NX", "EX", 10);
        if ("OK".equals(result)) {
            // 执行业务逻辑
            System.out.println("加锁成功，执行业务逻辑");
            // 释放锁：先判断锁是否属于自己，防止误删
            if (requestId.equals(jedis.get(key))) {
                jedis.del(key);
            }
        } else {
            System.out.println("加锁失败，锁已被占用");
        }
        jedis.close();
    }
}