java8 和redission分布式锁写法

Java8 和 Redisson 都提供了方便易用的分布式锁实现，下面分别介绍它们的写法。

Java8 实现分布式锁

Java8 提供了 `java.util.concurrent.locks.StampedLock` 类来实现乐观读写锁，可以用它来实现分布式锁。但是需要注意的是，StampedLock 并不是一个分布式锁，它只能实现本地线程之间的锁控制，需要结合其他技术来实现分布式锁。

下面是一个基于 Java8 和 Redis 的分布式锁实现示例代码：

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;
import java.util.function.Supplier;

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;

public class DistributedLock {

    private RedissonClient redissonClient;

    public DistributedLock(RedissonClient redissonClient) {
        this.redissonClient = redissonClient;
    }

    public <T> T lock(String lockKey, Supplier<T> supplier) {
        RLock lock = redissonClient.getLock(lockKey);
        lock.lock();
        try {
            return supplier.get();
        } finally {
            lock.unlock();
        }
    }

    public <T> T tryLock(String lockKey, Supplier<T> supplier, long timeout, TimeUnit unit) {
        RLock lock = redissonClient.getLock(lockKey);
        boolean locked = false;
        try {
            locked = lock.tryLock(timeout, unit);
            if (locked) {
                return supplier.get();
            } else {
                return null;
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return null;
        } finally {
            if (locked) {
                lock.unlock();
            }
        }
    }

    public void park(long timeout, TimeUnit unit) {
        LockSupport.parkNanos(unit.toNanos(timeout));
    }

}

上述示例代码中，`lock` 方法是阻塞获取锁的方法，如果获取锁失败，线程会一直阻塞，直到获取到锁。`tryLock` 方法是非阻塞获取锁的方法，如果获取锁失败，会返回 null。`park` 方法是挂起当前线程的方法。

Redisson 实现分布式锁

Redisson 是一个开源的 Java Redis 客户端，提供了丰富的 Redis 分布式相关功能，包括分布式锁。下面是一个基于 Redisson 的分布式锁实现示例代码：

import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;

public class DistributedLock {

    private RedissonClient redissonClient;

    public DistributedLock(RedissonClient redissonClient) {
        this.redissonClient = redissonClient;
    }

    public <T> T lock(String lockKey, Supplier<T> supplier) {
        RLock lock = redissonClient.getLock(lockKey);
        lock.lock();
        try {
            return supplier.get();
        } finally {
            lock.unlock();
        }
    }

    public <T> T tryLock(String lockKey, Supplier<T> supplier, long timeout, TimeUnit unit) {
        RLock lock = redissonClient.getLock(lockKey);
        boolean locked = false;
        try {
            locked = lock.tryLock(timeout, unit);
            if (locked) {
                return supplier.get();
            } else {
                return null;
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return null;
        } finally {
            if (locked) {
                lock.unlock();
            }
        }
    }

    public void park(long timeout, TimeUnit unit) {
        LockSupport.parkNanos(unit.toNanos(timeout));
    }

}

上述示例代码中，`lock` 方法和 `tryLock` 方法都是通过 Redisson 提供的 `RLock` 接口来实现的。其中，`lock` 方法是阻塞获取锁的方法，如果获取锁失败，线程会一直阻塞，直到获取到锁。`tryLock` 方法是非阻塞获取锁的方法，如果获取锁失败，会返回 null。`park` 方法是挂起当前线程的方法。