使用zookeeper实现静态数据中心化配置管理
使用zookeeper实现静态数据中心化配置管理
各个项目都会存在静态数据配置，这些数据平台变化很少，为提高性能一般采用缓存的方式缓存数据。如果采用分布式缓存，网络成本比较高不太适合
一般采用本地缓存，在单机环境下修改缓存数据方式比较简单，更新数据库的同时，也修改更新本地缓存，但在集群模式下可就没有这么简单，最简单直接
的方式就是一台台服务器等去修改，费时费力。或者通过jms消息同步的方式进行处理，具体不描述太多。这里介绍另外一种方式，即使用zookeeper实现
静态数据中心化配置管理。
先简单介绍一下zookeeper，ZooKeeper是近期比较热门的一个Paxos算法实现，也是Hadoop下的一个子项目，被认为是GoogleChubby的开源版，
主要用来在分布式环境下提供分布式锁、配置管理、名字服务、群组服务。它具有很高的可用性、稳定性、可靠性。它在分布式应用中像一把瑞士军刀，
很多地方都用得着。
为了缓存数据，需要一个HashMap对象，但JDK中的HashMap是不支持分布式环境同步数据的。为此需要结合zookeeper重新实现一个HashMap，
取名叫做ZKHashMap。连接到zookeeper服务器的任何一个客户端修改了ZKHashMap。能够通过zookeeper服务器主动同步到其它连接到zookeeper服务器的客户端。
搜索发现已经有这样的实现工具包：menagerie（https://github.com/openUtility/menagerie）。官网描述为：Menagerieisanimplementationofthe
JavaConcurrencyLibrariesbasedonthepopularApacheZooKeeper。主要功能有分布式集合、分布式队列、分布式锁的实现。有兴趣可以去学习一下源码
为了演示其效果，做个测试，代码如下，
public class TestZKHashMap {
private static final String hostString = "localhost:2181";
private static final String baseHashMapPath = "/test-maps";
private static final String baseLockPath = "/test-locks";
private static final String Init_Done = "/initData";
private static final int timeout = 2000;
private static ZooKeeper zk1, zk2;
private static ZkSessionManager zkSessionManager1, zkSessionManager2;
private static ZkHashMap<String,Person> testMap1, testMap2;
private static Serializer<Entry<String, Person>> serializer = new JavaSerializer<String, Person>();
public static void main(String[] args) throws Exception {
setup();
final CountDownLatch latch = new CountDownLatch(2);
Thread thread1 = new Thread() {
@Override
public void run() {
initData(zk1, zkSessionManager1);
String znode = "test1";
Person person = new Person("melin");
testMap1.put(znode, person);
latch.countDown();
}
};
Thread thread2 = new Thread() {
@Override
public void run() {
initData(zk2, zkSessionManager2);
String znode = "test2";
Person person = new Person("melin");
testMap2.put(znode, person);
latch.countDown();
}
};
thread1.start();
thread2.start();
latch.await();
Thread.sleep(100);
if(testMap1.containsKey("test2")) {
System.out.println("testMap1 包含 test2");
}
if(testMap2.containsKey("test1")) {
System.out.println("testMap2 包含 test1");
}
tearDown();
}
private static ZooKeeper newZooKeeper() throws IOException {
return new ZooKeeper(hostString, timeout,new Watcher() {
@Override
public void process(WatchedEvent event) {
System.out.println("+++++++++"+event);
}
});
}
public static void setup() throws Exception {
zk1 = newZooKeeper();
zk1.create(baseHashMapPath,new byte[]{}, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
zkSessionManager1 = new BaseZkSessionManager(zk1);
testMap1 = new ZkHashMap<String, Person>(baseHashMapPath, zkSessionManager1, serializer);
zk2 = newZooKeeper();
zkSessionManager2 = new BaseZkSessionManager(zk2);
testMap2 = new ZkHashMap<String, Person>(baseHashMapPath, zkSessionManager2, serializer);
}
public static void tearDown() throws Exception{
try{
ZkUtils.recursiveSafeDelete(zk1,baseHashMapPath,-1);
ZkUtils.recursiveSafeDelete(zk1,baseLockPath,-1);
ZkUtils.recursiveSafeDelete(zk1,Init_Done,-1);
}catch(KeeperException ke){
//suppress because who cares what went wrong after our tests did their thing?
}finally{
zk1.close();
zk2.close();
}
}
public static void initData(ZooKeeper zk, ZkSessionManager zkSessionManager) {
final Lock lock = new ReentrantZkLock(baseLockPath, zkSessionManager);
try {
if (null == zk.exists(Init_Done, true)) {
// if the init_done node not exists we try to init
lock.lock();
if(zk.exists(Init_Done, true) != null) {
System.out.println("已经初始化数据"+zk);
return;
}
System.out.println("初始化数据"+zk);
//创建初始化成功标识,注意这个标志是永久节点
zk.create(Init_Done, null, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
//工作完成,释放锁
lock.unlock();
} else {// if init_done exists we simply load data from gcih
System.out.println("已经初始化数据"+zk);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}感叹zookeeper用一个简单的树结构模型实现Paxos算法......
资料
1：Paxos算法之旅（一）追本溯源
http://rdc.taobao.com/team/jm/archives/397
2：Paxos算法中文翻译
http://wenku.baidu.com/view/87276e1dfad6195f312ba6d7.html