分布式锁的实现(java)

coding

  当对接第三方接口时,往往会碰到同一时间发送了大量相同的请求,这个时候或许就是第三方发送接口的失误了。而我们需要做的就是针对这个情况来强化我们的系统。这个时候就需要用到分布式锁" title="分布式锁">分布式锁。让这些请求只有一个能发送进来。

分布式锁的实现一般有三种:

  1. 基于数据库的乐观锁;
  2. 基于redis的分布式锁;
  3. 基于zookeeper的分布式锁。

  这里我们讲的是第二种:基于redis的分布式锁的原理以及实现。

下面是代码的实现:

publicclass DistributeLock {

/**

* setnx(key,value):如果key-value存在,缓存成功并返回1,否则返回0.

* getset(key,value):返回旧的value,然后更新旧的value为新的value.

* expire(key,seconds):设置key的过期时间为seconds秒.

* get(key):获取key对应的value,不存在返回nil.

*/

privatefinalstaticlong expire = 1000; // 设置锁的过期时间

publicstaticboolean getLockByRedis(Jedis jedis,String lock){

boolean success = false;

long flag = jedis.setnx(lock, String.valueOf(System.currentTimeMillis() + expire + 1));

// 获取分布式锁成功

if (flag == 1) {

success = true;

}else{ // 可能其他线程持有锁,也有可能是锁超时

long getVale = Long.valueOf(jedis.get(lock));

if (getVale < System.currentTimeMillis()) { //超时

String oldValue = jedis.getSet(lock,String.valueOf(System.currentTimeMillis() + expire + 1));

if (oldValue != null) {

// 被其他线程抢占

if (Long.valueOf(oldValue) == getVale) {

success = false;

}else{

success = true;

}

}

}else{

success = false;

}

}

return success;

}

/**

* 谁上锁,谁释放

* @param jedis

* @param lock

*/

publicstaticvoid releaseLock(Jedis jedis,String lock) {

if (System.currentTimeMillis() < Long.valueOf(jedis.get(lock))) {

jedis.del(lock);

}

}

}

以上是 分布式锁的实现(java) 的全部内容, 来源链接: utcz.com/z/508890.html

回到顶部