Curator提供的分布式锁怎么用

本篇内容主要讲解“Curator提供的分布式锁怎么用”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Curator提供的分布式锁怎么用”吧!

Curator 提供的分布式锁用法，很简单：

packagecurator.lock;

importorg.apache.curator.RetryPolicy;
importorg.apache.curator.framework.CuratorFramework;
importorg.apache.curator.framework.CuratorFrameworkFactory;
importorg.apache.curator.framework.recipes.locks.InterProcessMutex;
importorg.apache.curator.retry.ExponentialBackoffRetry;

publicclassInterProcessMutexDemo{

	publicstaticvoidmain(String[]args){
		RetryPolicyretryPolicy=newExponentialBackoffRetry(1000,3);
		finalCuratorFrameworkclient=CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(5000).connectionTimeoutMs(10000).retryPolicy(retryPolicy).namespace("text").build();
		client.start();
		
		InterProcessMutexlock=newInterProcessMutex(client,"/lock");
		try{
			lock.acquire();
			System.err.println("生成订单号");
			Thread.currentThread().sleep(5000L);
		}catch(Exceptione){
		}finally{
			try{
				lock.release();
			}catch(Exceptione){
				e.printStackTrace();
			}
		}
		
		try{
			lock.acquire();
			System.err.println("生成订单号");
			Thread.currentThread().sleep(Long.MAX_VALUE);
		}catch(Exceptione){
		}finally{
			try{
				lock.release();
			}catch(Exceptione){
				e.printStackTrace();
			}
		}		
	}
}

到此，相信大家对“Curator提供的分布式锁怎么用”有了更深的了解，不妨来实际操作一番吧！