基于zookeeper ApI 操作实例

zooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

1 首先启动本地zookeeper

2 构建zookeeper案例 

public class ZookeepperDemo {

public static void main(String[] args) throws Exception {

        CuratorFramework curatorFramework =         CuratorFrameworkFactory.builder().connectString("127.0.0.1:2181").sessionTimeoutMs(5000)

        .retryPolicy(new ExponentialBackoffRetry(1000,3 )).build();

//        curatorFramework.start();//启动

//        createData(curatorFramework);//创建节点数据

//        updateData(curatorFramework);

         deleteData(curatorFramework);

    }

private static void createData(CuratorFramework curatorFramework) throws Exception{

    curatorFramework.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).forPath("/data/program", "test".getBytes());

    }

private static void updateData(CuratorFramework curatorFramework)throws Exception{

    curatorFramework.setData().forPath("/data/program", "up".getBytes());

    }

private static void deleteData(CuratorFramework curatorFramework)throws Exception{

        Stat stat = new Stat();

        String value = new                String(curatorFramework.getData().storingStatIn(stat).forPath("/data/program"));

        curatorFramework.delete().withVersion(stat.getVersion()).forPath("/data/program");

    }

}

3 zookeeper客户端查看