您的位置：首页 > 其它

Zookeeper学习(十一)：ZooKeeper 实现命名服务

2016-03-21 15:18 274 查看

可以理解成一个分布式的ID生成器

1.命名服务

命名服务可以理解为提供名字的服务

Zookeeper的命名服务，有两个应用方向：

1.提供类似JNDI的功能：

利用zookeeper中的树形分层结构，可以把系统中的各种服务的名称，地址以及目录信息存放在zookeeper中，需要的时候去zookeeper中去读取

2.

利用zookeeper中的顺序节点的特性，制作分布式的序列号生成器（ID生成器）

（在往数据库中插入数据，通常是要有一个ID号，在单机环境下，可以利用数据库的主键自动生成id号，但是这种在分布式环境下就无法使用了，可以使用UUID，但是UUID有一个缺点，就是没有什么规律很难理解。使用zookeeper的命名服务可以生成有顺序的容易理解的，支持分布式的编号）

2.架构图

3.算法流程

生成ID的方法

package com.jike.nameservice;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.exception.ZkNodeExistsException;
import org.I0Itec.zkclient.serialize.BytesPushThroughSerializer;

public class IdMaker {

private ZkClient client = null;
private final String server;//记录服务器的地址
private final String root;//记录父节点的路径
private final String nodeName;//节点的名称
private volatile boolean running = false;
private ExecutorService cleanExector = null;

//删除节点的级别
public enum RemoveMethod{
NONE,IMMEDIATELY,DELAY

}

public IdMaker(String zkServer,String root,String nodeName){

this.root = root;
this.server = zkServer;
this.nodeName = nodeName;

}

public void start() throws Exception {

if (running)
throw new Exception("server has stated...");
running = true;

init();

}

public void stop() throws Exception {

if (!running)
throw new Exception("server has stopped...");
running = false;

freeResource();

}

/**
* 初始化服务资源
*/
private void init(){

client = new ZkClient(server,5000,5000,new BytesPushThroughSerializer());
cleanExector = Executors.newFixedThreadPool(10);
try{
client.createPersistent(root,true);
}catch (ZkNodeExistsException e){
//ignore;
}

}

/**
* 释放服务资源
*/
private void freeResource(){

cleanExector.shutdown();
try{
cleanExector.awaitTermination(2, TimeUnit.SECONDS);

}catch(InterruptedException e){
e.printStackTrace();
}finally{
cleanExector = null;
}

if (client!=null){
client.close();
client=null;

}
}

/**
* 检测服务是否正在运行
* @throws Exception
*/
private void checkRunning() throws Exception {
if (!running)
throw new Exception("请先调用start");

}

private String ExtractId(String str){
int index = str.lastIndexOf(nodeName);
if (index >= 0){
index+=nodeName.length();
return index <= str.length()?str.substring(index):"";
}
return str;

}

/**
* 产生ID
* 核心函数
* @param removeMethod 删除的方法
* @return
* @throws Exception
*/
public String generateId(RemoveMethod removeMethod) throws Exception{
checkRunning();
final String fullNodePath = root.concat("/").concat(nodeName);
//返回创建的节点的名称
final String ourPath = client.createPersistentSequential(fullNodePath, null);

/**
* 在创建完节点后为了不
*/
if (removeMethod.equals(RemoveMethod.IMMEDIATELY)){
client.delete(ourPath);
}else if (removeMethod.equals(RemoveMethod.DELAY)){
cleanExector.execute(new Runnable() {

public void run() {
// TODO Auto-generated method stub
client.delete(ourPath);
}
});

}
//node-0000000000, node-0000000001，ExtractId提取ID
return ExtractId(ourPath);
}

}

测试节点ID生成

package com.jike.nameservice;

import com.jike.nameservice.IdMaker.RemoveMethod;

public class TestIdMaker {

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

IdMaker idMaker = new IdMaker("192.168.1.105:2181",
"/NameService/IdGen", "ID");
idMaker.start();

try {
for (int i = 0; i < 10; i++) {
String id = idMaker.generateId(RemoveMethod.DELAY);
System.out.println(id);

}
} finally {
idMaker.stop();

}
}

}

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航