读《分布式一致性原理》CURATOR客户端3

时间：2018-05-26 20:23:00 阅读：149 评论：0 收藏：0 [点我收藏+]

标签：[] curator bsp ace EDA 服务服务器 ima gets

分布式锁

在分布式环境中，为了保证数据的一致性，经常在程序运行的某个运行点。需要进行同步控制。

package master;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.CountDownLatch;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.locks.InterProcessLock;
import org.apache.curator.framework.recipes.locks.InterProcessMultiLock;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class Recipes_Lock {
    
    static String lock_path="/lock_paht";
    static CuratorFramework client = CuratorFrameworkFactory.builder().
            connectString("192.168.64.60:2181")
            .connectionTimeoutMs(5000).
            retryPolicy(new ExponentialBackoffRetry(3000, 3))
            .build();
    
    public static void main(String[] args) {
        client.start();
        final InterProcessMutex lock= new InterProcessMutex(client,lock_path);
        final CountDownLatch down = new CountDownLatch(1);
        
        for (int i = 0; i <30; i++) {
            new Thread(new  Runnable() {
                public void run() {
                    try {
                        down.wait();
                        lock.acquire();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss|SSS");
                    String orderNo = dateFormat.format(new Date());
                    System.out.println("生成的订单号是："+orderNo);
                    try {
                        lock.release();
                    } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }).start();;
            
        }
        down.countDown();
    }
}

上面这个程序借助Curator来实现了一个简单的分布式锁。其核心接口如下：

技术分享图片

工具

curator也提供了了很多的工具类，其中用的最多的就是zkPath和EnsurePath。

ZKPaths

ZKPaths提供了一些简单的API来构建ZNode路径，递归创建和删除节点等，

package utils;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.curator.utils.ZKPaths;
import org.apache.curator.utils.ZKPaths.PathAndNode;
import org.apache.zookeeper.ZooKeeper;

public class ZKPaths_sample {
    
    static String path="/zkpath_path";
    static CuratorFramework client = CuratorFrameworkFactory.builder().
            connectString("192.168.64.60:2181")
            .connectionTimeoutMs(5000).
            retryPolicy(new ExponentialBackoffRetry(3000, 3))
            .build();
    
    public static void main(String[] args) throws Exception {
        client.start();
        
        ZooKeeper zooKeeper = client.getZookeeperClient().getZooKeeper();
        System.out.println(ZKPaths.fixForNamespace(path, "sub"));
        System.out.println(ZKPaths.makePath(path, "sub"));
        System.out.println(ZKPaths.getNodeFromPath("zkapth_path/sub1"));
        
        PathAndNode pn = ZKPaths.getPathAndNode("/zkpath_path/sub1");
        System.out.println(pn.getPath());
        System.out.println(pn.getNode());
        
        ZKPaths.mkdirs(zooKeeper, path+"/child1");
        ZKPaths.mkdirs(zooKeeper, path+"/child2");
        System.out.println(ZKPaths.getSortedChildren(zooKeeper, path));
        
    }
    
}