使用curator实现zookeeper锁服务的示例分享
2014-11-14 17:14
639 查看
这篇文章主要介绍了使用curator实现zookeeper锁服务的示例,需要的朋友可以参考下
import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import com.netflix.curator.RetryPolicy; import com.netflix.curator.framework.CuratorFramework; import com.netflix.curator.framework.CuratorFrameworkFactory; import com.netflix.curator.framework.recipes.locks.InterProcessMutex; import com.netflix.curator.retry.ExponentialBackoffRetry; public class TestCuratorLock { /** * @param args * @throws InterruptedException */ public static void main(String[] args) throws InterruptedException { // TODO Auto-generated method stub CountDownLatch latch = new CountDownLatch(5); String zookeeperConnectionString = "localhost:2181,localhost:2182,localhost:2183"; RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3); CuratorFramework client = CuratorFrameworkFactory.newClient( zookeeperConnectionString, retryPolicy); client.start(); System.out.println("客户端启动。。。。"); ExecutorService exec = Executors.newCachedThreadPool(); for (int i = 0; i < 5; i++) { exec.submit(new MyLock("client" + i, client, latch)); } exec.shutdown(); latch.await(); System.out.println("所有任务执行完毕"); client.close(); System.out.println("客户端关闭。。。。"); } static class MyLock implements Runnable { private String name; private CuratorFramework client; private CountDownLatch latch; public MyLock(String name, CuratorFramework client, CountDownLatch latch) { this.name = name; this.client = client; this.latch = latch; } public String getName() { return name; } public void setName(String name) { this.name = name; } @Override public void run() { // TODO Auto-generated method stub InterProcessMutex lock = new InterProcessMutex(client, "/test_group"); try { if (lock.acquire(120, TimeUnit.SECONDS)) { try { // do some work inside of the critical section here System.out.println("----------" + this.name + "获得资源----------"); System.out.println("----------" + this.name + "正在处理资源----------"); Thread.sleep(10 * 1000); System.out.println("----------" + this.name + "资源使用完毕----------"); latch.countDown(); } finally { lock.release(); System.out.println("----------" + this.name + "释放----------"); } } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
相关文章推荐
- 使用curator实现zookeeper锁服务的示例分享
- zookeeper 实现分布式锁zookeeper 使用 Curator 示例监听、分布式锁
- 不使用jquery实现js打字效果示例分享
- 使用zookeeper实现服务路由和负载均衡
- 在ASP.NET AJAX中使用应用程序服务和本地化(2):示例程序:实现用户登录和注销
- 使用curator实现对zookeeper的增、删、改、查、回调
- 使用curator实现对zookeeper的增、删、改、查、回调
- php生成缩略图示例代码分享(使用gd库实现)
- 使用Apache Curator实现服务的注册和发现
- 使用java反射和zookeeper实现的分布式服务
- java使用zookeeper实现的分布式锁示例
- 使用curator实现对zookeeper的增、删、改、查、回调
- 利用curator实现的zookeeper分布式锁服务
- 使用curator实现对zookeeper的增、删、改、查、回调
- Zookeeper 进阶之——Zookeeper编程示例(如何使用Zookeeper实现屏障Barriers和队列Queues)
- 分享在Linux下使用OSGi.NET插件框架快速实现一个分布式服务集群的方法
- 利用curator实现的zookeeper分布式锁服务
- 使用zookeeper实现服务路由和负载均衡
- 使用curator实现对zookeeper的增、删、改、查、回调
- 使用curator实现对zookeeper的增、删、改、查、回调