文档章节

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

醉饮黄龙
 醉饮黄龙
发布于 2015/01/23 15:12
字数 942
阅读 61
收藏 0
点赞 0
评论 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
博文 15
码字总数 16194
作品 0
江北
ZooKeeper可以用来做什么(转)

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

easonjim ⋅ 2017/09/05 ⋅ 0

linux下zookeeper的集群搭建

第一次写博客 写的不好不要骂┗|`O′|┛ 嗷~~ 首先说一下Zookeeper的概念: Zookeeper是一个分布式协调服务;就是为用户的分布式应用程序提供协调服务 A、zookeeper是为别的分布式程序服务的...

zhaobocan ⋅ 05/06 ⋅ 0

高性能 RPC 框架 Dubbo 从入门到深入-服务注册中心搭建(详细)

一、前言 整体来说,一个公司业务系统的演进流程基本都是从单体应用到多应用。在单体应用时,不同业务模块相互调用直接在本地 JVM 进程内就可以完成,而变为多个应用时,相互之间进行通信的方...

加多 ⋅ 01/26 ⋅ 0

ZooKeeper进阶(一):Zookeeper简介

ZooKeeper进阶(一):Zookeeper简介 1、zookeeper配置文件简介 ZooKeeper 的功能特性通过 ZooKeeper 配置文件来进行控制管理( zoo.cfg 配置文件)。ZooKeeper 这样的设计其实是有它自身的原...

sunhuaqiang1 ⋅ 04/22 ⋅ 0

Zookeeper完全分布式集群的搭建

Zookeeper完全分布式集群的搭建 一、集群模式 1、单机模式 在zoo.cfg中只配置一个server.id就是单机模式了。 这种模式下,如果当前主机宕机,那么所有依赖于当前zookeeper服务工作的其他服务...

星汉 ⋅ 04/27 ⋅ 0

ZooKeeper是什么(转)

ZooKeeper是什么? ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,...

easonjim ⋅ 2017/09/05 ⋅ 0

ZooKeeper 3.4.12 发布,分布式服务框架

ZooKeeper 3.4.12 已发布,此版本修复了 22 个 issue,包括导致 dataDir 和 dataLogDir 出现问题的错误修复。有关详细信息,请参阅 ZooKeeper 3.4.12 发布说明。 3.4.12 还新增了以下两项特性...

淡漠悠然 ⋅ 05/16 ⋅ 0

阿里大数据攻城师教你怎样理解ZooKeeper(六)

Zookeeper是什么 是一个针对大型分布式系统的可靠协调系统; 提供的功能包括:配置维护、名字服务、分布式同步、组服务等; 目标就是封装好复杂易出错的关键服务,将简单易用的接口和性能高效...

JAVA丶学习 ⋅ 04/13 ⋅ 0

ZooKeeper学习笔记三 ZooKeeper与Paxos

本文学习内容来自: 《从Paxos到ZooKeeper分布式一致性原理与实践》 电子工业出版社 Apache ZooKeeper是由Apache Hadoop的子项目发展而来,于2010年11月正式成为了Apache的顶级项目。ZooKeep...

xundh ⋅ 04/27 ⋅ 0

《Zookeeper--Windows单机安装》

《Zookeeper--Windows单机安装》 Zookeeper作为Dubbo服务的注册中心,Zookeeper一个分布式的服务框架,是树型的目录服务的数据存储,能做到集群管理数据 ,这里能很好的作为Dubbo服务的注册中...

爱笑的我们 ⋅ 05/09 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

ARMS: 原来实时计算可以这么简单!

摘要: 业务实时监控服务( ARMS)是一款阿里云应用性能管理(APM)类监控产品。借助本产品,您可以基于前端、应用、业务自定义等服务,迅速便捷地为企业构建秒级响应的业务监控能力。 业务实...

阿里云云栖社区 ⋅ 4分钟前 ⋅ 0

Monkey入门_琉璃

先下载android sdk安装配置好路径,然后adb shell 如果给你显示这个,说明目前没有有效的移动设备链接,可以开个安卓模拟器或者使用真机,usb或wifi链接到电脑都可以,打开usb调试模式;然后...

EvanDev ⋅ 5分钟前 ⋅ 0

Idea类注释模板

一、设置类注释模板 1.选择File–>Settings–>Editor–>File and Code Templates–>Includes–>File Header. 2.设置完成后,创建类时自动生成注释,效果如下。...

Clarence_D ⋅ 7分钟前 ⋅ 0

vuejs题

1、active-class是哪个组件的属性?嵌套路由怎么定义? 答:vue-router模块的router-link组件。 2、怎么定义vue-router的动态路由?怎么获取传过来的动态参数? 答:在router目录下的index.j...

自由小鸟 ⋅ 7分钟前 ⋅ 0

2018年社交系统ThinkSNS年中大促

致各大商企事业单位及粉丝用户: 为感谢大家对ThinkSNS品牌的关注与支持,2018年6月18日官方诚推出:年中大促,限时抢购活动! “ThinkSNS 年中大促,¥6.18超值特惠 名额有限,预购从速! ...

ThinkSNS账号 ⋅ 13分钟前 ⋅ 0

MYSQL主从复制搭建及切换操作(GTID与传统)

如下: MYSQL主从复制方式有默认的复制方式异步复制,5.5版本之后半同步复制,5.6版本之后新增GTID复制,包括5.7版本的多源复制。 MYSQL版本:5.7.20 操作系统版本:linux 6.7 64bit 1、异步...

rootliu ⋅ 13分钟前 ⋅ 0

Java强软弱虚引用Reference

Java强软弱虚引用Reference 本文目的:深入理解Reference 本文定位:学习笔记 学习过程记录,加深理解,提升文字组合表达能力。也希望能给学习Reference的同学一些灵感 源码说明 源码基于jdk...

lichuangnk ⋅ 16分钟前 ⋅ 0

plsql 表中字段及注释时为乱码

在windows中创 建一个名为“NLS_LANG”的系统环境变量,设置其值为“SIMPLIFIED CHINESE_CHINA.ZHS16GBK”, 然后重新启动 pl/sql developer,这样检索出来的中文内容就不会是乱码了。如...

江戸川 ⋅ 19分钟前 ⋅ 0

Docker创建JIRA 7.2.7中文破解版

1、介绍 1.1、什么是JIRA?   关于JIRA网上的介绍有很多,以下摘自百度百科:   JIRA是Atlassian公司出品的项目与事务跟踪工具,被广泛应用于缺陷跟踪、客户服务、需求收集、流程审批、任...

谢思华 ⋅ 23分钟前 ⋅ 0

Java Class 类使用

Java Class 类使用 我们可以通过已知的包名来获取到 Class 对象,从而可以通过反射动态的来操作对象。 获取Class有三种方式 //通过对象.class直接获取Class integerClass = Integer.class;...

gaob2001 ⋅ 27分钟前 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部