文档章节

分布式服务框架 Zookeeper之配置管理

醉饮黄龙
 醉饮黄龙
发布于 2015/01/23 15:12
字数 942
阅读 65
收藏 0

实现说明:

客户端实现zookeeper的watcher事件,监听节点的更新事件,zookeeper管理的节点配置有更新时,客户端会接收到更新事件,并作出相应的处理,本文代码只是一个简单的示例


服务端代码示例

/**
 * 包名:com.lencee.demo.zookeeper.config
 * 文件名:ConfigManager.java
 * 版本信息:
 * 日期:2015年1月23日-下午1:28:55
 * 
 */
package com.lencee.demo.zookeeper.config;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
/**
 * 
 * <p>配置管理类<p>
 * <p>维护分布式配置</p>
 * @version 2015年1月23日 下午1:28:55
 * 
 */
public class ConfigManager {
 
 private static ConfigManager configManager = null;
 
 //Zookeeper集群服务地址与端口
 private static String zkUrl = "192.168.0.101:11001";
 //配置结点根路径
 private final static String ROOT = "/myConf";
 //结点鉴权方式
 private final static String AUTH_TYPE = "digest";
 //结点鉴权密码
 private final static String AUTH_PWD = "password";
 
 private ZooKeeper zk = null;
 
 private ConfigManager(){}
 
 public synchronized static ConfigManager getInstance() throws Exception{
  if (configManager == null) {
   configManager = new ConfigManager();
   ZooKeeper zk = new ZooKeeper(zkUrl, 3000, new Watcher() {
    @Override
    public void process(WatchedEvent event) {
     System.out.println("事件类型:" + event.getType());
    }
   });
   while (zk.getState() != ZooKeeper.States.CONNECTED) {
    Thread.sleep(3000);
   }
   
   //给这个链接添加认证信息
   zk.addAuthInfo(AUTH_TYPE, AUTH_PWD.getBytes());
   
   configManager.setZk(zk);
   
   String rootValue = "测试环境配置";
   if(zk.exists(ROOT, true)==null){
    //结点不存在
    zk.create(ROOT , rootValue.getBytes(), Ids.CREATOR_ALL_ACL, CreateMode.PERSISTENT);
   }
  }
  return configManager;
 }
 
 public void addNode(String path,byte[] data,CreateMode createMode) throws Exception{
  if(!path.startsWith("/")){
   throw new Exception("传入的路径没有以'/'开始");
  }
  if(this.zk.exists(ROOT + path, true)==null){
   //结点不存在
   this.zk.create(ROOT + path, data, Ids.CREATOR_ALL_ACL, createMode);
  }
 }
 public void setDate(String path,byte[] data) throws Exception{
  if(this.zk.exists(ROOT + path, true)==null){
   addNode(path, data, CreateMode.PERSISTENT);
  }else{
   zk.setData(ROOT + path, data, -1);
  }
  
 }
 /**
  * zk
  *
  * @return  the zk
  * @since   1.0.0
  */
 public ZooKeeper getZk() {
  return zk;
 }
 /**
  * @param zk the zk to set
  */
 public void setZk(ZooKeeper zk) {
  this.zk = zk;
 }
 
 public static void main(String[] args) throws Exception {
  ConfigManager cfm = ConfigManager.getInstance();
  
  //添加数据库配置节点
  String path = "/mysql";
  String value = "测试环境Mysql配置";
  cfm.setDate(path, value.getBytes());
  
  //添加项目配置节点
  String octopusPath = "/mysql/octopus";
  String octopusValue = "资源系统";
  cfm.setDate(octopusPath, octopusValue.getBytes());
  
  //添加连接URL的配置
  String urlPath = "/mysql/octopus/url";
  String urlValue = "jdbc:mysql://test.xxx.com:3306/octopus?useUnicode=true&characterEncoding=UTF8&zeroDateTimeBehavior=convertToNull&autoReconnect=true&failOverReadOnly=false&maxReconnects=10";
  cfm.setDate(urlPath, urlValue.getBytes());
  //添加连接数据库的用户名配置
  String userPath = "/mysql/octopus/username";
  String userValue = "octopus";
  cfm.setDate(userPath, userValue.getBytes());
  //添加连接数据库的密码配置
  String pwdPath = "/mysql/octopus/pwd";
  String pwdValue = "octopus111";
  cfm.setDate(pwdPath, pwdValue.getBytes());
 }
}

客户端代码

/**
 * 包名:com.lencee.demo.zookeeper.config
 * 文件名:ConfigClient.java
 * 版本信息:
 * 日期:2015年1月23日-下午2:15:49
 * 
 */
package com.lencee.demo.zookeeper.config;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.ZooKeeper;
/**
 * 
 * <p>配置应用端<p>
 * <p>读取分布式配置</p>
 * @version 2015年1月23日 下午2:15:49
 * 
 */
public class ConfigClient implements Watcher{
 
 // Zookeeper集群服务地址与端口
 private static String zkUrl = "192.168.0.101:11001";
 // 配置结点根路径
 private final static String ROOT = "/myConf";
 // 结点鉴权方式
 private final static String AUTH_TYPE = "digest";
 // 结点鉴权密码
 private final static String AUTH_PWD = "password";
 private ZooKeeper zk = null;
 
 private String url;
 private String username;
 private String pwd;
 
 public ConfigClient() {
  try {
   ZooKeeper zk = new ZooKeeper(zkUrl, 3000,this);
   while (zk.getState() != ZooKeeper.States.CONNECTED) {
    Thread.sleep(3000);
    System.out.println();
   }
   
   //给这个链接添加认证信息
   zk.addAuthInfo(AUTH_TYPE, AUTH_PWD.getBytes());
   this.zk = zk;
   //读取服务端的配置
   reflushValue();
  } catch (Exception e) {
   e.printStackTrace();
  } 
 }
 /**
  * 
  * reflushValue:<p>将配置服务设置的配置更新到对象中</p> 
  * @since  1.0.0
  */
 public void reflushValue() {
  try {
   this.url = new String(this.zk.getData(ROOT + "/mysql/octopus/url", true, null));
   this.username = new String(this.zk.getData(ROOT + "/mysql/octopus/username", true, null));
   this.pwd = new String(this.zk.getData(ROOT + "/mysql/octopus/pwd", true, null));
  } catch (Exception e) {
   e.printStackTrace();
  } 
 }
 
 public void printValues(){
  System.out.println("----------------当前配置---------------");
  System.out.println("mysql.url:"+this.url);
  System.out.println("mysql.username:"+this.username);
  System.out.println("mysql.pwd:"+this.pwd);
 }
 
 @Override
 public void process(WatchedEvent event) {
  EventType eventType = event.getType();
  if(Watcher.Event.EventType.None==eventType){
   System.out.println("事件:连接服务成功");
  }else if(Watcher.Event.EventType.NodeCreated==eventType){
   System.out.println("事件:节点创建成功");
  }else if(Watcher.Event.EventType.NodeChildrenChanged==eventType){
   System.out.println("事件:子节点更新成功");
   reflushValue();
   printValues();
  }else if(Watcher.Event.EventType.NodeDataChanged==eventType){
   System.out.println("事件:节点更新成功");
   reflushValue();
   printValues();
  }else if(Watcher.Event.EventType.NodeDeleted==eventType){
   System.out.println("事件:节点删除成功");
  }
  
 }
 /**
  * url
  *
  * @return  the url
  * @since   1.0.0
  */
 public String getUrl() {
  return url;
 }
 /**
  * username
  *
  * @return  the username
  * @since   1.0.0
  */
 public String getUsername() {
  return username;
 }
 /**
  * pwd
  *
  * @return  the pwd
  * @since   1.0.0
  */
 public String getPwd() {
  return pwd;
 }
 public static void main(String[] args) throws Exception {
  ConfigClient cc = new ConfigClient();
  System.out.println("客户端开始运行"+cc);
  while(true){
   Thread.sleep(3000);
  }
 }
}

© 著作权归作者所有

共有 人打赏支持
醉饮黄龙
粉丝 1
博文 17
码字总数 16194
作品 0
江北
私信 提问
分布式网站架构后续:zookeeper技术浅析

 Zookeeper是hadoop的一个子项目,虽然源自hadoop,但是我发现zookeeper脱离hadoop的范畴开发分布式框架的运用越来越多。今天我想谈谈zookeeper,本文不谈如何使用zookeeper,而是zookeeper...

蓝狐乐队
2014/04/21
0
0
ZooKeeper可以用来做什么(转)

在ZooKeeper的官网上有这么一句话:ZooKeeper is a centralized service for maintaining configuration information, naming, providing distributed synchronization, and providing grou......

easonjim
2017/09/05
0
0
Apache Zookeeper 3.4.6 发布

经过将近一年半的开发之后,Apahce Zookeeper 团队在 2014年3月10号 发布新版本 Zookeeper-3.4.6,Zookeeper的上一个版本 3.4.5 于2012年11月18号 发布。 Zookeeper 分布式服务框架是 Apache...

大卷卷
2014/03/14
5.9K
3
Yum安装mesos+zookeeper+marathon管理docker集群

Yum安装mesos+zookeeper+marathon管理docker集群 Apache-Mesos简介 Apache-Mesos是一款基于多资源(内存、CPU、磁盘、端口等)调度的开源集群管理套件,能使容错和分布式系统更加容易使用。官方...

漂移的兔子
08/21
0
0
ZooKeeper学习第五期--ZooKeeper管理分布式环境中的数据

引言 本节本来是要介绍ZooKeeper的实现原理,但是ZooKeeper的原理比较复杂,它涉及到了paxos算法、Zab协议、通信协议等相关知 识,理解起来比较抽象所以还需要借助一些应用场景,来帮我们理解...

卯金刀GG
2017/10/25
0
0

没有更多内容

加载失败,请刷新页面

加载更多

基础编程题目集-7-13 日K蜡烛图

股票价格涨跌趋势,常用蜡烛图技术中的K线图来表示,分为按日的日K线、按周的周K线、按月的月K线等。以日K线为例,每天股票价格从开盘到收盘走完一天,对应一根蜡烛小图,要表示四个价格:开...

niithub
14分钟前
0
0
Jenkins window 下的安装使用

1.下载:https://jenkins.io/download/ 双击安装完毕,将自动打开浏览器: http://localhost:8080 打开对应位置的文件,将初始密钥粘贴至输入框。 第一个是 安装默认的软件;第二个是 自定义...

狼王黄师傅
16分钟前
1
0
深入解析react关于事件绑定this的四种方式

这篇文章主要介绍了详解react关于事件绑定this的四种方式,写的十分的全面细致,具有一定的参考价值,对此有需要的朋友可以参考学习下。如有不足之处,欢迎批评指正。 在react组件中,每个方...

前端攻城小牛
24分钟前
1
0
JS正则表达式

url的正则表达式:包括IP,域名(domain),ftp,二级域名,域名中的文件,域名加上端口!用户名等等信息 `function` `IsURL(str_url) {``var` `strRegex =``"^((https|http|ftp|rtsp|mm...

前端小攻略
29分钟前
1
0
shell习题_2

find /root/ceshi1/ -type f -name "*.txt"|xargs -i mv {} {}.bak find /root/ceshi1/ -type f -name "*.txt" -exec mv {} {}.bak \; 1、批量修改文件名: n1=`echo $f|sed '#.bak##'` [ro......

芬野de博客
30分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部