jedisCluster如何加锁

JedisCluster是Redis的分布式解决方案，它不支持直接的分布式锁机制。但是，我们可以利用Redis的原子性操作和Lua脚本来实现分布式锁。

以下是一个简单的JedisCluster加锁的示例代码：

public class RedisLock {

  private static final String LOCK_SUCCESS = "OK";
  private static final String SET_IF_NOT_EXIST = "NX";
  private static final String SET_WITH_EXPIRE_TIME = "PX";
  private static final Long RELEASE_SUCCESS = 1L;

  /**
   * 尝试获取分布式锁
   *
   * @param jedisCluster Redis客户端
   * @param lockKey 锁
   * @param requestId 请求标识
   * @param expireTime 超期时间
   * @return 是否获取成功
   */
  public static boolean tryGetDistributedLock(JedisCluster jedisCluster, String lockKey, String requestId, int expireTime) {

    String result = jedisCluster.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);

    if (LOCK_SUCCESS.equals(result)) {
      return true;
    }
    return false;
  }

  /**
   * 释放分布式锁
   *
   * @param jedisCluster Redis客户端
   * @param lockKey 锁
   * @param requestId 请求标识
   * @return 是否释放成功
   */
  public static boolean releaseDistributedLock(JedisCluster jedisCluster, String lockKey, String requestId) {

    String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
    Object result = jedisCluster.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));

    if (RELEASE_SUCCESS.equals(result)) {
      return true;
    }
    return false;
  }
}

这个类包含了两个方法：tryGetDistributedLock和releaseDistributedLock。

在tryGetDistributedLock方法中，我们使用JedisCluster的set方法来设置锁，其中SET_IF_NOT_EXIST表示只有在锁不存在时才能设置成功，SET_WITH_EXPIRE_TIME表示锁的超时时间。如果返回的结果是LOCK_SUCCESS，表示获取锁成功。

在releaseDistributedLock方法中，我们使用Lua脚本来释放锁。Lua脚本中首先判断锁是否属于当前请求，如果是，则删除锁，否则返回0。如果返回的结果是RELEASE_SUCCESS，表示释放锁成功。

需要注意的是，在使用JedisCluster时，我们需要确保所有节点的时间都是同步的，否则会出现锁失效的问题。