zookeeper-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sunil singh <sunilsingh0...@yahoo.com>
Subject Re: Zookeeper programming with java(Intial Stage Programming)
Date Wed, 29 Aug 2012 09:44:49 GMT
This is one simple program to connect to the server and fetch some data on
znode.
Please go through it it may help you.
by,
Sunil Singh

import java.io.*;
import java.util.List;
//import java.util.List;
import org.apache.zookeeper.*;
import org.apache.zookeeper.Watcher.Event.KeeperState;
//import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Stat;
//import org.apache.zookeeper.data.ACL;
//import org.apache.zookeeper.ZooDefs.Ids;
//import org.apache.zookeeper.CreateMode;


class DisplayChange 
{
	static ZooKeeper zk;
	
	
	//connection establishment
	public void connect() throws IOException, KeeperException
	{
		zk = new ZooKeeper("10.10.10.10:2181", 3000, new Watcher()
		{
			public void process(WatchedEvent event)
			{
				if(event.getState()== KeeperState.SyncConnected)
					System.out.println("Connected to server");
			}
		});
		
	}
	
	// connection close
	public void close() throws InterruptedException
	{
		zk.close();
		System.out.println("Connection closed");
	}

	public static void main(String args[])throws KeeperException, IOException,
InterruptedException
	{
		DisplayChange myzoo = new DisplayChange();
		myzoo.connect();
		//setting watch with GetData();
		Stat stat = new Stat();
		byte [] getdata = zk.getData("/zk/abc", true, stat);
		String s = new String(getdata);
		String s2 = new String(s); //saved data of privious znode
		//System.out.println("First time data of znode is  :"+s);
	
		//setting new data for znode.
		byte [] newdata = {'c','o','n','f','i','g','_','=','4'};
		zk.setData("/zk/abc", newdata,-1);
		//zk.setData(path, data, version)
		
		byte [] getnewdata = zk.getData("/zk/abc", true, stat);
		String snew = new String(getnewdata);
		System.out.println("new data of /zk/abc is  :"+snew);
		System.out.println("The privious data of /zk/abc:"+s2);
		
		
	
	}
	
}	



--
View this message in context: http://zookeeper-user.578899.n2.nabble.com/Zookeeper-programming-with-java-Intial-Stage-Programming-tp7577832p7577854.html
Sent from the zookeeper-user mailing list archive at Nabble.com.

Mime
View raw message