zoukankan      html  css  js  c++  java
  • zookeeper code

    sample code:

    package com.marulin;
    
    import java.io.IOException;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    
    import org.apache.zookeeper.CreateMode;
    import org.apache.zookeeper.KeeperException;
    import org.apache.zookeeper.WatchedEvent;
    import org.apache.zookeeper.Watcher;
    import org.apache.zookeeper.ZooDefs.Ids;
    import org.apache.zookeeper.ZooDefs.Perms;
    import org.apache.zookeeper.ZooKeeper;
    
    import org.apache.zookeeper.data.ACL;
    import org.apache.zookeeper.data.Id;
    import org.apache.zookeeper.data.Stat;
    
    public class Test {
    
    	/**
    	 * @param args
    	 * @throws IOException
    	 * @throws InterruptedException
    	 * @throws KeeperException
    	 */
    	public static void main(String[] args) throws IOException, KeeperException,
    			InterruptedException {
    		Watcher watcher = new MyWatch();
    		Stat st = new Stat();
    		ZooKeeper zk = new ZooKeeper("localhost:2181", 1000, null);
    		// CreateMode createMode = new CreateMode(1, false, true);
    
    		ArrayList<ACL> OPEN_ACL_UNSAFE = new ArrayList<ACL>(
    				Collections.singletonList(new ACL(Perms.ALL, new Id("world",
    						"anyone"))));
    		// zk.create("/test", "abc".getBytes(), OPEN_ACL_UNSAFE,
    		// CreateMode.PERSISTENT_SEQUENTIAL);
    
    		// zk.create("/test", "abc".getBytes(), OPEN_ACL_UNSAFE,
    		// CreateMode.PERSISTENT);
    
    		zk.create("/test/a", "abc1".getBytes(), OPEN_ACL_UNSAFE,
    				CreateMode.PERSISTENT_SEQUENTIAL);
    
    		List<String> list = zk.getChildren("/test", watcher, st);
    		for (String s : list) {
    			System.out.println(s);
    		}
    		//
    		// byte b[] = zk.getData("/test0000000029", watcher, st);
    		// System.out.println(new String(b));
    		// System.out.println(st.getMzxid());
    		// zk.create("/testt", "abct".getBytes(), OPEN_ACL_UNSAFE,
    		// CreateMode.EPHEMERAL);
    		//
    		// byte b1[] = zk.getData("/testt", watcher, st);
    		// System.out.println(new String(b1));
    		// System.out.println();
    
    		// zk.delete("/test0000000002", 0);
    		// zk.delete("/test0000000029", -1);
    		zk.exists("/test/a0000000002", watcher);
    		zk.delete("/test/a0000000002", -1);
    	}
    
    }
    
    class MyWatch implements Watcher {
    
    	@Override
    	public void process(WatchedEvent event) {
    		System.out.println("event");
    		System.out.println(event.getPath());
    	}
    
    }
    


  • 相关阅读:
    安全探讨之用Win32汇编写双进程守护
    LightTPD 1.4.12
    mysql4存在mysql5没有的性能成绩
    gcolor2-拾色器
    solaris 中挂载usb移动硬盘
    Browsershots:测试你的 Web 企图
    MythTV 0.20
    XorgEdit:xorg.conf 编纂器
    pci168c,1c无线网卡如何在64位Solaris系统上运用
    Fedora8中批改磁盘卷标
  • 原文地址:https://www.cnblogs.com/hehehaha/p/6332471.html
Copyright © 2011-2022 走看看