ZooKeeper（三）ZooKeeper客户端命令和Java原生API

  • 常用客户端命令
    1. 服务端常用命令
      1> 启动ZK服务：sh bin/zkServer.sh start
      2> 查看ZK服务状态：sh bin/zkServer.sh status
      3> 停止ZK服务：sh bin/zkServer.sh stop
      4> 重启ZK服务：sh bin/zkServer.sh restart
    2. 客户端常用命令
      1> 使用./zkCli.sh -server 127.0.0.1:2181连接到ZooKeeper服务，连接成功后，系统输出ZooKeeper的相关环境以及配置信息。命令行如下： 
      a, 显示根目录下文件：ls / 使用ls命令来查看当前ZooKeeper中所包含的内容
b, 显示根目录下文件：ls2 / 查看当前节点数据并能看到更新次数等数据
c, 创建文件并设置初始内容：create /zk "value" 创建一个新的znode节点"zk"以及与它关联的字符串。create -e 是临时节点，create -s 顺序节点
d, 获取文件内容：get /zk 确认znode是否包含我们所创建的字符串
e, 修改文件内容：set /zk "newValue" 对zk所关联的字符串进行设置
f, 删除文件：delete /zk 将刚创建的znode删除，如果存在子节点删除失败
g, 递归删除：rmr /zk 将刚才创建的znode删除，子节点同时删除
h, 退出客户端：quit
i, 帮助命令：help
    3. ACL命令常用命令
      1> getAcl 获取指定节点的ACL信息
      2> setAcl 设置指定节点的ACL信息
      3> addauth 注册会话授权信息
    4. 四字命令
      1> ZooKeeper支持某些特定的四字命令字母语气的交互。用来获取ZooKeeper服务的当前状态及相关信息。可通过telnet或nc向ZooKeeper提交相应的命令 
       a, echo stat|nc 127.0.0.1 2181 来查看哪个节点被选择作为follower或者leader
 b, echo ruok|nc 127.0.0.1 2181 测试是否启动了该Sever,若回复imok表示已经启动
 c, echo dump|nc 127.0.0.1 2181 列出未经处理的会话和临时节点
 d, echo kill|nc 127.0.0.1 2181 关掉server
 e, echo conf|nc 127.0.0.1 2181 输出相关服务配置的详细信息
 f, echo cons|nc 127.0.0.1 2181 列出所有连接到服务器的客户端的完全的连接/会话的详细信息
 g, echo envi|nc 127.0.0.1 2181 输出关于服务环境详细信息（区别于conf命令）
 h, echo reqs|nc 127.0.0.1 2181 列出未经处理的请求
 i, echo wchs|nc 127.0.0.1 2181 列出服务器watch详细信息
 j, echo wchc|nc 127.0.0.1 2181 通过session列出服务器watch的详细信息，它的输出是一个与watch相关的会话的列表
 k, echo wchp|nc 127.0.0.1 2181 通过路径列出服务器watch的详细信息。它输出一个与session相关的路径
      2>tips：如果linux上没有nc命令需要手动安装，yum install -y nc
    5. 日志可视化
      1> 事务日志可视化（LogFormatter）：java -cp ../../zookeeper-3.4.5.jar;../../slf4j-api-1.6.1.jar org.apache.zookeeper.server.LogFormatter log.xxx
      2> 数据快照可视化（SnapshotFormatter）: java -cp ../../zookeeper-3.4.5.jar;../../slf4j-api-1.6.1.jar org.apache.zookeeper.server.SnapshotFormatter snapshot.xxx
  • Java客户端
    1. zookeeper原生客户端：zookeeper官方提供的java客户端API
      1> 创建会话
      2> 创建节点
      3> 读取数据
      4> 更新数据
      5> 检测节点是否存在
      6> 权限控制
      7> watch：org.apache.zookeper.Watcher（KeeperState,EventType） 
      a, 没有专门的API去注册watcher,依附于增删改查API
b, watch是一次性产品
c, watch的process方法中，可对不同事件进行处理
      8> 原生Api的缺点： 
      a, 会话连接是异步的
b, Watch需要重复注册
c, Session重连机制
d, 开发复杂性较高
      9> 演示代码连接ZK 
      import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
/**
 * @Description: 连接zk
 * @Author: Jason.zhu
 * @Create: 2019/05/16 16:27
 */
public class ZKConnect implements Watcher {
  static org.slf4j.Logger logger = LoggerFactory.getLogger(ZKConnect.class);

  // 连接超时时间
  private static Integer timeout;

  // 连接地址
  private static String zkServerIp;

  static {
      Properties zkProperties = new Properties();
      InputStream is = ZKConnect.class.getResourceAsStream("/zk.properties");
      try {
          zkProperties.load(is);
      } catch (Exception e) {
          e.printStackTrace();
      }finally {
          try {
              if (is != null) {
                  is.close();
              }
          } catch (IOException e) {
              logger.error("关闭流失败", e);
          }
      }
      timeout = Integer.valueOf(zkProperties.getProperty("zk.timeout"));
      zkServerIp = zkProperties.getProperty("zk.zkServerIps");
  }

  @Override
  public void process(WatchedEvent watchedEvent) {
      logger.warn("触发了[" + watchedEvent.getType().name()+"]事件");
  }

  public static ZooKeeper getZooKeeper(){
      try {
          ZooKeeper zooKeeper = new ZooKeeper(zkServerIp, timeout, new ZKConnect());
          return zooKeeper;
      } catch (Exception e) {
          e.printStackTrace();
      }
      return null;
  }
}
      10> 演示代码-客户端连接后操作ZK 
      import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Id;
import org.apache.zookeeper.server.auth.DigestAuthenticationProvider;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.List;

/**
 * @Description:
 * @Author: Jason.zhu
 * @Create: 2019/05/16 16:19
 */
public class ProtoClientACL {
  static Logger logger = LoggerFactory.getLogger(ProtoClientACL.class);

  public static void main(String[] args) throws Exception{
      ZooKeeper zooKeeper = ZKConnect.getZooKeeper();

      String scheme = "digest";
      String  auth = DigestAuthenticationProvider.generateDigest("jason:jason123");
      System.out.println("auth" + auth);

      List<ACL> aclList = new ArrayList<>();
      Id user1 = new Id(scheme, auth);
      aclList.add(new ACL(ZooDefs.Perms.ALL, user1));
      String result = zooKeeper.create("/aclNode","acl data".getBytes(), aclList, CreateMode.PERSISTENT);
      if(null != result){
          System.out.println("节点:"+result+"创建成功");
      }

      /*List<ACL> acls = zooKeeper.getACL("/aclNode",null);
      for(ACL acl : acls){
          System.out.println();
          System.out.println("权限scheme id：" + acl.getId());
          System.out.println("权限位：" + acl.getPerms());
      }*/

      zooKeeper.addAuthInfo(scheme,"jason:jason123".getBytes());
      System.out.println(new String(zooKeeper.getData("/aclNode",true, null)));

      zooKeeper.delete("/aclNode", -1);

      zooKeeper.close();

  }
}
      11> 演示代码-客户端连接后操作ZK ACL 
      package net.lc7.proto;
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Id;
import org.apache.zookeeper.server.auth.DigestAuthenticationProvider;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.List;

/**
 * @Description:
 * @Author: Jason.zhu
 * @Create: 2019/05/16 16:19
 */
public class ProtoClientACL {
  static Logger logger = LoggerFactory.getLogger(ProtoClientACL.class);

  public static void main(String[] args) throws Exception{
      ZooKeeper zooKeeper = ZKConnect.getZooKeeper();

      String scheme = "digest";
      String  auth = DigestAuthenticationProvider.generateDigest("jason:jason123");
      System.out.println("auth" + auth);

      List<ACL> aclList = new ArrayList<>();
      Id user1 = new Id(scheme, auth);
      aclList.add(new ACL(ZooDefs.Perms.ALL, user1));
      String result = zooKeeper.create("/aclNode","acl data".getBytes(), aclList, CreateMode.PERSISTENT);
      if(null != result){
          System.out.println("节点:"+result+"创建成功");
      }

      /*List<ACL> acls = zooKeeper.getACL("/aclNode",null);
      for(ACL acl : acls){
          System.out.println();
          System.out.println("权限scheme id：" + acl.getId());
          System.out.println("权限位：" + acl.getPerms());
      }*/

      zooKeeper.addAuthInfo(scheme,"jason:jason123".getBytes());
      System.out.println(new String(zooKeeper.getData("/aclNode",true, null)));

      zooKeeper.delete("/aclNode", -1);

      zooKeeper.close();

  }
}
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 216,919评论 6赞 502
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 92,567评论 3赞 392
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 163,316评论 0赞 353
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 58,294评论 1赞 292
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 67,318评论 6赞 390
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 51,245评论 1赞 299
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 40,120评论 3赞 418
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,964评论 0赞 275
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,376评论 1赞 313
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,592评论 2赞 333
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,764评论 1赞 348
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,460评论 5赞 344
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 41,070评论 3赞 327
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,697评论 0赞 22
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,846评论 1赞 269
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,819评论 2赞 370
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,665评论 2赞 354