From 592f6297efdb9e0d057a6845daada7bd4ccd0139 Mon Sep 17 00:00:00 2001
From: quding <li.niu@duitang.com>
Date: Sat, 19 Aug 2017 18:22:15 +0800
Subject: [PATCH] add zkDemo

---
 README.MD                                     |  6 ++-
 ZkClient-Demo/pom.xml                         | 35 ++++++++++++++++
 .../cn/mrdear/zkclient/conf/ZkClientConf.java | 13 ++++++
 .../zkclient/tec101/ZkClientCrudExample.java  | 40 ++++++++++++++++++
 .../tec101/zkClientNameServiceExample.java    | 35 ++++++++++++++++
 ZkClient-Demo/src/main/resources/log4j.xml    | 42 +++++++++++++++++++
 6 files changed, 170 insertions(+), 1 deletion(-)
 create mode 100644 ZkClient-Demo/pom.xml
 create mode 100644 ZkClient-Demo/src/main/java/cn/mrdear/zkclient/conf/ZkClientConf.java
 create mode 100644 ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/ZkClientCrudExample.java
 create mode 100644 ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/zkClientNameServiceExample.java
 create mode 100644 ZkClient-Demo/src/main/resources/log4j.xml

diff --git a/README.MD b/README.MD
index 08ba771..f5f828e 100644
--- a/README.MD
+++ b/README.MD
@@ -67,5 +67,9 @@ SpringDataRedis学习的一个Demo,内容不多,配合博文:[redis学习记录(
 --------------
 增加Spring Security Demo,项目中使用了JWT Token验证机制,该项目可以很好的了解整个流程的作用,需要配合我博客中Spring Security相关博文食用.
 
-16.待添加
+16.ZkClient-Demo
+--------------
+对于zk的基本操作测试与分析,主要是了解zk的工作模式.
+
+17.待添加
 --------------
diff --git a/ZkClient-Demo/pom.xml b/ZkClient-Demo/pom.xml
new file mode 100644
index 0000000..c4b15c9
--- /dev/null
+++ b/ZkClient-Demo/pom.xml
@@ -0,0 +1,35 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>cn.mrdear.zkclient</groupId>
+    <artifactId>ZkClient-Demo</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <dependencies>
+
+        <!--zkclient第三方客户端-->
+        <!-- https://mvnrepository.com/artifact/com.101tec/zkclient -->
+        <dependency>
+            <groupId>com.101tec</groupId>
+            <artifactId>zkclient</artifactId>
+            <version>0.10</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+</project>
\ No newline at end of file
diff --git a/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/conf/ZkClientConf.java b/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/conf/ZkClientConf.java
new file mode 100644
index 0000000..d6bc763
--- /dev/null
+++ b/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/conf/ZkClientConf.java
@@ -0,0 +1,13 @@
+package cn.mrdear.zkclient.conf;
+
+/**
+ * @author Niu Li
+ * @since 2017/8/18
+ */
+public class ZkClientConf {
+
+  public static final String zkHost = "106.15.93.73:2181";
+
+  public static final Integer zkTimeOut = 2000;
+
+}
diff --git a/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/ZkClientCrudExample.java b/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/ZkClientCrudExample.java
new file mode 100644
index 0000000..d5b78ce
--- /dev/null
+++ b/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/ZkClientCrudExample.java
@@ -0,0 +1,40 @@
+package cn.mrdear.zkclient.tec101;
+
+import org.I0Itec.zkclient.ZkClient;
+
+import cn.mrdear.zkclient.conf.ZkClientConf;
+
+import java.util.List;
+
+/**
+ * 连接zk demo
+ * @author Quding Ding
+ * @since 2017/8/18
+ */
+public class ZkClientCrudExample {
+
+  private static final ZkClient ZK_CLIENT = new ZkClient(ZkClientConf.zkHost, ZkClientConf.zkTimeOut);
+
+  /**
+   * 创建节点,节点存在则抛异常,一次只能创建一个目录节点,否则报错
+   * @param path 路径
+   * @param value 节点携带的数据
+   */
+  public void createNode(String path, String value) {
+    ZK_CLIENT.createPersistent(path, value);
+  }
+
+  /**
+   * 得到子节点,节点不存在直接报错
+   * @param root 查找子节点
+   */
+  public List<String> children(String root) {
+    return ZK_CLIENT.getChildren(root);
+  }
+
+  public static void main(String[] args) {
+    ZkClientCrudExample example = new ZkClientCrudExample();
+    example.createNode("/quding/nameService","命名服务");
+  }
+
+}
diff --git a/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/zkClientNameServiceExample.java b/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/zkClientNameServiceExample.java
new file mode 100644
index 0000000..0a9f295
--- /dev/null
+++ b/ZkClient-Demo/src/main/java/cn/mrdear/zkclient/tec101/zkClientNameServiceExample.java
@@ -0,0 +1,35 @@
+package cn.mrdear.zkclient.tec101;
+
+import org.I0Itec.zkclient.ZkClient;
+
+import cn.mrdear.zkclient.conf.ZkClientConf;
+
+/**
+ * zk的命名服务,参考博文 http://www.hollischuang.com/archives/1595
+ * @author Quding Ding
+ * @since 2017/8/19
+ */
+public class zkClientNameServiceExample {
+
+  private static final ZkClient ZK_CLIENT = new ZkClient(ZkClientConf.zkHost, ZkClientConf.zkTimeOut);
+
+
+  private static final String nameServicePath = "/quding/nameService/name";
+
+  /**
+   * 每次拿到id都需要创建相应的节点,再删除,适合读多写少的环境下
+   * @return id
+   */
+  public Long getUUID() {
+    final String sequential = ZK_CLIENT.createPersistentSequential(nameServicePath, "id");
+    ZK_CLIENT.delete(sequential);
+    return Long.valueOf(sequential.substring(nameServicePath.length()));
+  }
+
+
+  public static void main(String[] args) {
+    zkClientNameServiceExample example = new zkClientNameServiceExample();
+    System.out.println(example.getUUID());
+  }
+
+}
diff --git a/ZkClient-Demo/src/main/resources/log4j.xml b/ZkClient-Demo/src/main/resources/log4j.xml
new file mode 100644
index 0000000..357f626
--- /dev/null
+++ b/ZkClient-Demo/src/main/resources/log4j.xml
@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
+
+<log4j:configuration>
+
+    <!-- 将日志信息输出到控制台 -->
+    <appender name="ConsoleAppender" class="org.apache.log4j.ConsoleAppender">
+        <!-- 设置日志输出的样式 -->
+        <layout class="org.apache.log4j.PatternLayout">
+            <!-- 设置日志输出的格式 -->
+            <param name="ConversionPattern" value="[%d{yyyy-MM-dd HH:mm:ss:SSS}] [%-5p] [method:%l]%n%m%n%n" />
+        </layout>
+        <!--过滤器设置输出的级别-->
+        <filter class="org.apache.log4j.varia.LevelRangeFilter">
+            <!-- 设置日志输出的最小级别 -->
+            <param name="levelMin" value="WARN" />
+            <!-- 设置日志输出的最大级别 -->
+            <param name="levelMax" value="ERROR" />
+            <!-- 设置日志输出的xxx，默认是false -->
+            <param name="AcceptOnMatch" value="true" />
+        </filter>
+    </appender>
+
+    <!--
+     注意：
+     1：当additivity="false"时，root中的配置就失灵了，不遵循缺省的继承机制
+     2：logger中的name非常重要，它代表记录器的包的形式，有一定的包含关系，试验表明
+        2-1：当定义的logger的name同名时，只有最后的那一个才能正确的打印日志
+        2-2：当对应的logger含有包含关系时，比如：name=test.log4j.test8 和 name=test.log4j.test8.UseLog4j，则2-1的情况是一样的
+        2-3：logger的name表示所有的包含在此名的所有记录器都遵循同样的配置，name的值中的包含关系是指记录器的名称哟！注意啦！
+     3：logger中定义的level和appender中的filter定义的level的区间取交集
+     4：如果appender中的filter定义的 levelMin > levelMax ，则打印不出日志信息
+     -->
+
+    <!-- 根logger的设置-->
+    <root>
+        <level value ="DEBUG"/>
+        <appender-ref ref="ConsoleAppender"/>
+        <!--<appender-ref ref="DailyRollingFileAppender"/>-->
+    </root>
+
+</log4j:configuration>
\ No newline at end of file