zookeeper分布式锁代码实例

redis分布式锁

模板：

/*** 分布式锁模板类* Created by sunyujia@aliyun.com on 2016/2/23.*/
public interface DistributedLockTemplate {/**** @param lockId 锁id(对应业务唯一ID)* @param timeout 单位毫秒* @param callback 回调函数* @return*/public Object execute(String lockId,int timeout,Callback callback);
}

public interface DistributedReentrantLock {public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException;public void unlock();
}

zk锁：

public class ZkDistributedLockTemplate implements DistributedLockTemplate {private static final org.slf4j.Logger log = LoggerFactory.getLogger(ZkDistributedLockTemplate.class);private CuratorFramework client;public ZkDistributedLockTemplate(CuratorFramework client) {this.client = client;}private boolean tryLock(ZkReentrantLock distributedReentrantLock,Long timeout) throws Exception {return distributedReentrantLock.tryLock(timeout, TimeUnit.MILLISECONDS);}@Overridepublic Object execute(String lockId, int timeout, Callback callback) {ZkReentrantLock distributedReentrantLock = null;boolean getLock=false;try {distributedReentrantLock = new ZkReentrantLock(client,lockId);if(tryLock(distributedReentrantLock,new Long(timeout))){getLock=true;return callback.onGetLock();}else{return callback.onTimeout();}}catch(InterruptedException ex){log.error(ex.getMessage(), ex);Thread.currentThread().interrupt();}catch (Exception e) {log.error(e.getMessage(), e);}finally {if(getLock){distributedReentrantLock.unlock();}}return null;}
}

/*** 基于Zookeeper的可重入互斥锁(关于重入:仅限于持有zk锁的jvm内重入)* Created by sunyujia@aliyun.com on 2016/2/24.*/
public class ZkReentrantLock implements DistributedReentrantLock {private static final org.slf4j.Logger log = LoggerFactory.getLogger(ZkReentrantLock.class);/*** 线程池*/private static final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(10);/*** 所有PERSISTENT锁节点的根位置*/public static final String ROOT_PATH = "/ROOT_LOCK/";/*** 每次延迟清理PERSISTENT节点的时间  Unit:MILLISECONDS*/private long delayTimeForClean = 1000;/*** zk 共享锁实现*/private InterProcessMutex interProcessMutex = null;/*** 锁的ID,对应zk一个PERSISTENT节点,下挂EPHEMERAL节点.*/private String path;/*** zk的客户端*/private CuratorFramework client;public ZkReentrantLock(CuratorFramework client, String lockId) {init(client, lockId);}public void init(CuratorFramework client, String lockId) {this.client = client;this.path = ROOT_PATH + lockId;interProcessMutex = new InterProcessMutex(client, this.path);}@Overridepublic boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException {try {return interProcessMutex.acquire(timeout, unit);} catch (InterruptedException e) {throw e;} catch (Exception e) {log.error(e.getMessage(),e);throw new RuntimeException(e.getMessage(),e);}}@Overridepublic void unlock() {try {interProcessMutex.release();} catch (Throwable e) {log.error(e.getMessage(), e);} finally {executorService.schedule(new Cleaner(client, path), delayTimeForClean, TimeUnit.MILLISECONDS);}}static class Cleaner implements Runnable {CuratorFramework client;String path;public Cleaner(CuratorFramework client, String path) {this.client = client;this.path = path;}@Overridepublic void run() {try {List list = client.getChildren().forPath(path);if (list == null || list.isEmpty()) {client.delete().forPath(path);}} catch (KeeperException.NoNodeException e1) {//nothing} catch (KeeperException.NotEmptyException e2) {//nothing} catch (Exception e) {log.error(e.getMessage(), e);//准备删除时,正好有线程创建锁}}}
}

zookeeper分布式锁代码实例相关推荐

zookeeper分布式锁原理及实现
前言本文介绍下 zookeeper方式实现分布式锁原理简介 zookeeper实现分布式锁的原理就是多个节点同时在一个指定的节点下面创建临时会话顺序节点,谁创建的节点序号最小,谁就获得了锁,并且 ...
架构系列---利用zookeeper 分布式锁解决缓存重建冲突实战
上一篇分布式缓存重建并发冲突问题以及zookeeper分布式锁解决方案, 主要讲解了分布式缓存重建冲突原因及利用zookeeper分布式锁解决缓存重建冲突问题,本篇接着上篇,实现上篇思路,带你利用z ...
zookeeper 分布式锁原理
zookeeper 分布式锁原理: 1 大家也许都很熟悉了多个线程或者多个进程间的共享锁的实现方式了,但是在分布式场景中我们会面临多个Server之间的锁的问题,实现的复杂度比较高.利用基于googl ...
分布式锁（一） Zookeeper分布式锁
什么是Zookeeper? Zookeeper(业界简称zk)是一种提供配置管理.分布式协同以及命名的中心化服务,这些提供的功能都是分布式系统中非常底层且必不可少的基本功能,但是如果自己实现这些功能而 ...
Zookeeper分布式锁的使用
由于公司引入了dubbo+zookeeper框架,里面不可避免的引入的zookeeper分布式锁,所以自己大致了解了一下.由于是自己研究,有不正确的地方还请大佬批评指正. 首先先介绍一下自己对zook ...
Zookeeper分布式锁
原文作者:阿凡卢出处:http://www.cnblogs.com/luxiaoxun/ 原文连接:https://www.cnblogs.com/luxiaoxun/p/4889764.html ...
Zookeeper分布式锁原理
1.分布式锁介绍单机应用开发,涉及并发同步的时候,我们往往采用synchronized 或者Lock的方式来解决多线程间的代码同步问题,这时多线程的运行都是在同一个JVM之下,没有任何问题. 但当我 ...
Zookeeper 分布式锁
Zookeeper 分布式锁在分布式场景中,采用传统的锁并不能解决跨进程并发的问题,所以需要引入一个分布式锁,来解决多个节点之间的访问控制一.Zookeeper如何解决分布式锁基于Zookeep ...
关于分布式锁的面试题都在这里了｜Reids分布式锁｜ZooKeeper分布式锁
我今天班儿都没上,就为了赶紧把这篇文章分布式锁早点写完.我真的不能再贴心了. 边喝茶边构思,你们可不要白嫖了! 三连来一遍? 引言为什么要学习分布式锁? 最简单的理由就是作为一个社招程序员,面试的时 ...

zookeeper分布式锁代码实例

zookeeper分布式锁代码实例相关推荐

最新文章

热门文章