public class App
{
private static String zkAdminUser = "zookeeper";
private static String zkAdminPassword = "********";
private static String theServers = "**.**.***.***:10181,**.**.***.***:10181,**.**.***.***:10181";
public static void main(String[] args)
{
CuratorFrameworkFactory.Builder builder =
CuratorFrameworkFactory.builder().connectString(theServers).retryPolicy(new ExponentialBackoffRetry(30000, 20)).connectionTimeoutMs(30000)
.sessionTimeoutMs(10000);
builder = builder.aclProvider(new ACLProvider()
{
@Override
public List<ACL> getDefaultAcl()
{
return ZooDefs.Ids.CREATOR_ALL_ACL;
}
@Override
public List<ACL> getAclForPath(String path)
{
// TODO Auto-generated method stub
return null;
}
}
);
if (zkAdminUser != null && zkAdminPassword != null)
{
String authenticationString = zkAdminUser + ":" + zkAdminPassword;
builder.authorization("ztpasswd", authenticationString.getBytes());
// .aclProvider(new ACLProvider()
// {
// @Override
// public List<ACL> getDefaultAcl()
// {
// return ZooDefs.Ids.CREATOR_ALL_ACL;
// }
//
// @Override
// public List<ACL> getAclForPath(String path)
// {
// return ZooDefs.Ids.CREATOR_ALL_ACL;
// }
// });
}
CuratorFramework client = builder.build();
client.start();
try
{
client.create().withMode(CreateMode.PERSISTENT).forPath("/beans/demo");
}
catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
finally
{
client.close();
}
}
}
{
private static String zkAdminUser = "zookeeper";
private static String zkAdminPassword = "********";
private static String theServers = "**.**.***.***:10181,**.**.***.***:10181,**.**.***.***:10181";
public static void main(String[] args)
{
CuratorFrameworkFactory.Builder builder =
CuratorFrameworkFactory.builder().connectString(theServers).retryPolicy(new ExponentialBackoffRetry(30000, 20)).connectionTimeoutMs(30000)
.sessionTimeoutMs(10000);
builder = builder.aclProvider(new ACLProvider()
{
@Override
public List<ACL> getDefaultAcl()
{
return ZooDefs.Ids.CREATOR_ALL_ACL;
}
@Override
public List<ACL> getAclForPath(String path)
{
// TODO Auto-generated method stub
return null;
}
}
);
if (zkAdminUser != null && zkAdminPassword != null)
{
String authenticationString = zkAdminUser + ":" + zkAdminPassword;
builder.authorization("ztpasswd", authenticationString.getBytes());
// .aclProvider(new ACLProvider()
// {
// @Override
// public List<ACL> getDefaultAcl()
// {
// return ZooDefs.Ids.CREATOR_ALL_ACL;
// }
//
// @Override
// public List<ACL> getAclForPath(String path)
// {
// return ZooDefs.Ids.CREATOR_ALL_ACL;
// }
// });
}
CuratorFramework client = builder.build();
client.start();
try
{
client.create().withMode(CreateMode.PERSISTENT).forPath("/beans/demo");
}
catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
finally
{
client.close();
}
}
}