基于zookeeper应用——简单统一命名服务实现
2016-04-17 09:10
741 查看
基于
zookeeper的应用在
http://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/index.html
上已经列举出来，本文根据自己业务需要，实现了公司的统一命名服务。
统一命名服务（Name Service）
分布式应用中，通常需要有一套完整的命名规则，既能够产生唯一的名称又便于人识别和记住，通常情况下用树形的名称结构是一个理想的选择，树形的名称结构是一个有层次的目录结构，既对人友好又不会重复。说到这里你可能想到了 JNDI，没错 Zookeeper 的 Name Service 与 JNDI 能够完成的功能是差不多的，它们都是将有层次的目录结构关联到一定资源上，但是 Zookeeper 的 Name Service 更加是广泛意义上的关联，也许你并不需要将名称关联到特定资源上，你可能只需要一个不会重复名称，就像数据库中产生一个唯一的数字主键一样。
Name Service 已经是 Zookeeper 内置的功能，你只要调用 Zookeeper 的 API 就能实现。如调用 create 接口就可以很容易创建一个目录节点。
在zk系统中创建的节点可以保证在分布式服务器上是全局唯一的。
命名服务提供注册、注销和查看命名等接口。
命名服务的关键逻辑
[java] view
plain copy
/**
* 标题：统一命名服务
* 作者：
* 时间：2013-04-17
* 描述：提供了Naming类，给分布式程序开发人员或其一个分布式全局唯一的命名。
*/
package com.my.nameservice;
import java.util.ArrayList;
import java.util.List;
[java] view
plain copy
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.ZooDefs.Ids;
public class Naming {
private ZooKeeper zk = null; // ZooKeeper对象
private String nameroot = "/NameService";
private String namerootvalue = "IsNameService";
private String namevalue = "IsName";
/**
* @函数：命名服务构造函数
* @参数：zk的地址端口 描述：初始化zk实例，创建命名服务根路径
*/
public Naming(String url) {
try {
// 初始化，如果当前有alive的zk连接则先关闭
if (zk != null && zk.getState().isAlive() == true)
zk.close();
zk = new ZooKeeper(url, 30000, null); // 重新建立连接
System.out.println("zookeeper connect success:url=" + url);
} catch (Exception e) {
e.printStackTrace();
}
// 判断是否有/NameService，如果没有，则创建该路径，用来作为所有的集中配置信息的根目录
try {
if (zk.exists(nameroot, false) == null) {
zk.create(nameroot, namerootvalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(nameroot + " create success!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
}
/**
* @函数： 注销zk实例
*/
public void UnNaming() {
if (zk != null) {
try {
zk.close();
System.out.println("zookeeper close success!");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
zk = null;
}
}
/**
* @函数：注册一个全局名字
* @描述：待注册的名字字符串name，在zk中创建一个/NameService/name的znode路径
* @参数： 待注册的名字字符串name
* @返回值： 0 表示注册成功 -1 表示出错 1 表示该命名已被注册
*/
@SuppressWarnings("finally")
public int Registered(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) == null) {
zk.create(path, namevalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(name + " registered success!");
} else {
ret = 1;
System.out.println(name + " is exists, can not regist again!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：注销一个全局名字
* @描述：待注销的名字字符串name，在zk中删除/NameService/name的znode路径
* @参数： 待注销的名字字符串name
* @返回值： 0 表示注销成功 -1 表示出错 1 表示该命名未注册，不存在命名服务系统中
*/
@SuppressWarnings("finally")
public int Canceled(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) != null) {
zk.delete(path, -1);
System.out.println(name + " canceled success!");
} else {
ret = 1;
System.out.println(name + " is not exists, can not canceled!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：获取命名服务系统的所有命名
* @描述：
* @参数：
* @返回值：命名列表
*/
public List<String> Readall() {
List<String> namelist = new ArrayList<String>();
try {
namelist = zk.getChildren(nameroot, false);
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return namelist;
}
}
标签： 命名服务
2013-04-24 13:13 2126人阅读 评论(2) 收藏 举报
分类：
分布式计算/hadoop（16）
版权声明：本文为博主原创文章，未经博主允许不得转载。
zookeeper的应用在
http://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/index.html
上已经列举出来，本文根据自己业务需要，实现了公司的统一命名服务。
统一命名服务（Name Service）
分布式应用中，通常需要有一套完整的命名规则，既能够产生唯一的名称又便于人识别和记住，通常情况下用树形的名称结构是一个理想的选择，树形的名称结构是一个有层次的目录结构，既对人友好又不会重复。说到这里你可能想到了 JNDI，没错 Zookeeper 的 Name Service 与 JNDI 能够完成的功能是差不多的，它们都是将有层次的目录结构关联到一定资源上，但是 Zookeeper 的 Name Service 更加是广泛意义上的关联，也许你并不需要将名称关联到特定资源上，你可能只需要一个不会重复名称，就像数据库中产生一个唯一的数字主键一样。
Name Service 已经是 Zookeeper 内置的功能，你只要调用 Zookeeper 的 API 就能实现。如调用 create 接口就可以很容易创建一个目录节点。
在zk系统中创建的节点可以保证在分布式服务器上是全局唯一的。
命名服务提供注册、注销和查看命名等接口。
命名服务的关键逻辑
[java] view
plain copy
/**
* 标题：统一命名服务
* 作者：
* 时间：2013-04-17
* 描述：提供了Naming类，给分布式程序开发人员或其一个分布式全局唯一的命名。
*/
package com.my.nameservice;
import java.util.ArrayList;
import java.util.List;
[java] view
plain copy
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.ZooDefs.Ids;
public class Naming {
private ZooKeeper zk = null; // ZooKeeper对象
private String nameroot = "/NameService";
private String namerootvalue = "IsNameService";
private String namevalue = "IsName";
/**
* @函数：命名服务构造函数
* @参数：zk的地址端口 描述：初始化zk实例，创建命名服务根路径
*/
public Naming(String url) {
try {
// 初始化，如果当前有alive的zk连接则先关闭
if (zk != null && zk.getState().isAlive() == true)
zk.close();
zk = new ZooKeeper(url, 30000, null); // 重新建立连接
System.out.println("zookeeper connect success:url=" + url);
} catch (Exception e) {
e.printStackTrace();
}
// 判断是否有/NameService，如果没有，则创建该路径，用来作为所有的集中配置信息的根目录
try {
if (zk.exists(nameroot, false) == null) {
zk.create(nameroot, namerootvalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(nameroot + " create success!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
}
/**
* @函数： 注销zk实例
*/
public void UnNaming() {
if (zk != null) {
try {
zk.close();
System.out.println("zookeeper close success!");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
zk = null;
}
}
/**
* @函数：注册一个全局名字
* @描述：待注册的名字字符串name，在zk中创建一个/NameService/name的znode路径
* @参数： 待注册的名字字符串name
* @返回值： 0 表示注册成功 -1 表示出错 1 表示该命名已被注册
*/
@SuppressWarnings("finally")
public int Registered(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) == null) {
zk.create(path, namevalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(name + " registered success!");
} else {
ret = 1;
System.out.println(name + " is exists, can not regist again!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：注销一个全局名字
* @描述：待注销的名字字符串name，在zk中删除/NameService/name的znode路径
* @参数： 待注销的名字字符串name
* @返回值： 0 表示注销成功 -1 表示出错 1 表示该命名未注册，不存在命名服务系统中
*/
@SuppressWarnings("finally")
public int Canceled(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) != null) {
zk.delete(path, -1);
System.out.println(name + " canceled success!");
} else {
ret = 1;
System.out.println(name + " is not exists, can not canceled!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：获取命名服务系统的所有命名
* @描述：
* @参数：
* @返回值：命名列表
*/
public List<String> Readall() {
List<String> namelist = new ArrayList<String>();
try {
namelist = zk.getChildren(nameroot, false);
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return namelist;
}
}
zookeeper应用——简单统一命名服务实现
zookeeper的应用在http://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/index.html
上已经列举出来，本文根据自己业务需要，实现了公司的统一命名服务。
统一命名服务（Name Service）
分布式应用中，通常需要有一套完整的命名规则，既能够产生唯一的名称又便于人识别和记住，通常情况下用树形的名称结构是一个理想的选择，树形的名称结构是一个有层次的目录结构，既对人友好又不会重复。说到这里你可能想到了 JNDI，没错 Zookeeper 的 Name Service 与 JNDI 能够完成的功能是差不多的，它们都是将有层次的目录结构关联到一定资源上，但是 Zookeeper 的 Name Service 更加是广泛意义上的关联，也许你并不需要将名称关联到特定资源上，你可能只需要一个不会重复名称，就像数据库中产生一个唯一的数字主键一样。
Name Service 已经是 Zookeeper 内置的功能，你只要调用 Zookeeper 的 API 就能实现。如调用 create 接口就可以很容易创建一个目录节点。
在zk系统中创建的节点可以保证在分布式服务器上是全局唯一的。
命名服务提供注册、注销和查看命名等接口。
命名服务的关键逻辑
[java] view
plain copy
/**
* 标题：统一命名服务
* 作者：
* 时间：2013-04-17
* 描述：提供了Naming类，给分布式程序开发人员或其一个分布式全局唯一的命名。
*/
package com.my.nameservice;
import java.util.ArrayList;
import java.util.List;
[java] view
plain copy
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.ZooDefs.Ids;
public class Naming {
private ZooKeeper zk = null; // ZooKeeper对象
private String nameroot = "/NameService";
private String namerootvalue = "IsNameService";
private String namevalue = "IsName";
/**
* @函数：命名服务构造函数
* @参数：zk的地址端口 描述：初始化zk实例，创建命名服务根路径
*/
public Naming(String url) {
try {
// 初始化，如果当前有alive的zk连接则先关闭
if (zk != null && zk.getState().isAlive() == true)
zk.close();
zk = new ZooKeeper(url, 30000, null); // 重新建立连接
System.out.println("zookeeper connect success:url=" + url);
} catch (Exception e) {
e.printStackTrace();
}
// 判断是否有/NameService，如果没有，则创建该路径，用来作为所有的集中配置信息的根目录
try {
if (zk.exists(nameroot, false) == null) {
zk.create(nameroot, namerootvalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(nameroot + " create success!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
}
/**
* @函数： 注销zk实例
*/
public void UnNaming() {
if (zk != null) {
try {
zk.close();
System.out.println("zookeeper close success!");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
zk = null;
}
}
/**
* @函数：注册一个全局名字
* @描述：待注册的名字字符串name，在zk中创建一个/NameService/name的znode路径
* @参数： 待注册的名字字符串name
* @返回值： 0 表示注册成功 -1 表示出错 1 表示该命名已被注册
*/
@SuppressWarnings("finally")
public int Registered(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) == null) {
zk.create(path, namevalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(name + " registered success!");
} else {
ret = 1;
System.out.println(name + " is exists, can not regist again!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：注销一个全局名字
* @描述：待注销的名字字符串name，在zk中删除/NameService/name的znode路径
* @参数： 待注销的名字字符串name
* @返回值： 0 表示注销成功 -1 表示出错 1 表示该命名未注册，不存在命名服务系统中
*/
@SuppressWarnings("finally")
public int Canceled(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) != null) {
zk.delete(path, -1);
System.out.println(name + " canceled success!");
} else {
ret = 1;
System.out.println(name + " is not exists, can not canceled!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：获取命名服务系统的所有命名
* @描述：
* @参数：
* @返回值：命名列表
*/
public List<String> Readall() {
List<String> namelist = new ArrayList<String>();
try {
namelist = zk.getChildren(nameroot, false);
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return namelist;
}
}
zookeeper应用——简单统一命名服务实现
标签： 命名服务2013-04-24 13:13 2126人阅读 评论(2) 收藏 举报
分类：
分布式计算/hadoop（16）
版权声明：本文为博主原创文章，未经博主允许不得转载。
zookeeper的应用在
http://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/index.html
上已经列举出来，本文根据自己业务需要，实现了公司的统一命名服务。
统一命名服务（Name Service）
分布式应用中，通常需要有一套完整的命名规则，既能够产生唯一的名称又便于人识别和记住，通常情况下用树形的名称结构是一个理想的选择，树形的名称结构是一个有层次的目录结构，既对人友好又不会重复。说到这里你可能想到了 JNDI，没错 Zookeeper 的 Name Service 与 JNDI 能够完成的功能是差不多的，它们都是将有层次的目录结构关联到一定资源上，但是 Zookeeper 的 Name Service 更加是广泛意义上的关联，也许你并不需要将名称关联到特定资源上，你可能只需要一个不会重复名称，就像数据库中产生一个唯一的数字主键一样。
Name Service 已经是 Zookeeper 内置的功能，你只要调用 Zookeeper 的 API 就能实现。如调用 create 接口就可以很容易创建一个目录节点。
在zk系统中创建的节点可以保证在分布式服务器上是全局唯一的。
命名服务提供注册、注销和查看命名等接口。
命名服务的关键逻辑
[java] view
plain copy
/**
* 标题：统一命名服务
* 作者：
* 时间：2013-04-17
* 描述：提供了Naming类，给分布式程序开发人员或其一个分布式全局唯一的命名。
*/
package com.my.nameservice;
import java.util.ArrayList;
import java.util.List;
[java] view
plain copy
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.ZooDefs.Ids;
public class Naming {
private ZooKeeper zk = null; // ZooKeeper对象
private String nameroot = "/NameService";
private String namerootvalue = "IsNameService";
private String namevalue = "IsName";
/**
* @函数：命名服务构造函数
* @参数：zk的地址端口 描述：初始化zk实例，创建命名服务根路径
*/
public Naming(String url) {
try {
// 初始化，如果当前有alive的zk连接则先关闭
if (zk != null && zk.getState().isAlive() == true)
zk.close();
zk = new ZooKeeper(url, 30000, null); // 重新建立连接
System.out.println("zookeeper connect success:url=" + url);
} catch (Exception e) {
e.printStackTrace();
}
// 判断是否有/NameService，如果没有，则创建该路径，用来作为所有的集中配置信息的根目录
try {
if (zk.exists(nameroot, false) == null) {
zk.create(nameroot, namerootvalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(nameroot + " create success!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
}
/**
* @函数： 注销zk实例
*/
public void UnNaming() {
if (zk != null) {
try {
zk.close();
System.out.println("zookeeper close success!");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println(e.getMessage());
}
zk = null;
}
}
/**
* @函数：注册一个全局名字
* @描述：待注册的名字字符串name，在zk中创建一个/NameService/name的znode路径
* @参数： 待注册的名字字符串name
* @返回值： 0 表示注册成功 -1 表示出错 1 表示该命名已被注册
*/
@SuppressWarnings("finally")
public int Registered(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) == null) {
zk.create(path, namevalue.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(name + " registered success!");
} else {
ret = 1;
System.out.println(name + " is exists, can not regist again!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：注销一个全局名字
* @描述：待注销的名字字符串name，在zk中删除/NameService/name的znode路径
* @参数： 待注销的名字字符串name
* @返回值： 0 表示注销成功 -1 表示出错 1 表示该命名未注册，不存在命名服务系统中
*/
@SuppressWarnings("finally")
public int Canceled(String name) {
String path = nameroot + "/" + name;
int ret = 0;
try {
if (zk.exists(path, false) != null) {
zk.delete(path, -1);
System.out.println(name + " canceled success!");
} else {
ret = 1;
System.out.println(name + " is not exists, can not canceled!");
}
} catch (KeeperException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
ret = -1;
e.printStackTrace();
System.out.println(e.getMessage());
} finally {
return ret;
}
}
/**
* @函数：获取命名服务系统的所有命名
* @描述：
* @参数：
* @返回值：命名列表
*/
public List<String> Readall() {
List<String> namelist = new ArrayList<String>();
try {
namelist = zk.getChildren(nameroot, false);
} catch (KeeperException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return namelist;
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- PHP垃圾回收机制
- 程序员必须要掌握的排序算法以及查找方法
- iOS之const,static,extern简介
- 项目内部IT/电商/信息化类简报，分享电子版
- MySql 数据库常用的sql语句
- Web安全测试之XSS
- 管道 && 消息队列 && 共享内存
- 对话吴恩达（Andrew Ng）：超级大咖深度解析人工智能 以及如何成为已经数据挖掘工程师
- "Couldn't communicate with a helper application" in Xcode 7
- 第七周学习进度
- Eclipse中改变默认的workspace的方法及说明详解
- BZOJ 4206 转换之后求LIS
- 限制UITextField的最大输入字符数
- 常用链接
- 理解javascript对象继承
- JDK之jstat的用法
- Juel 表达式使用
- Juel 表达式使用
- JAVA中List,Map,Set接口的区别
- 一些比特率值