From 2330ba1569a8996c4cc99b930181ad00993d5417 Mon Sep 17 00:00:00 2001 From: luoxiang <2806718453@qq.com> Date: Sat, 25 May 2019 19:46:26 +0800 Subject: [PATCH] =?UTF-8?q?zookeeper=E6=9D=83=E9=99=90=E6=8E=A7=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 13 +- .../java/com/heibaiying/AclOperation.java | 2 +- .../java/com/heibaiying/BasicOperation.java | 6 +- notes/Zookeeper_ACL权限控制.md | 264 +++++++++++++++ notes/Zookeeper_Java客户端Curator.md | 316 ++++++++++++++++++ notes/Zookeeper常用Shell命令.md | 154 +-------- pictures/curator-retry-policy.png | Bin 0 -> 12762 bytes 7 files changed, 594 insertions(+), 161 deletions(-) create mode 100644 notes/Zookeeper_ACL权限控制.md create mode 100644 notes/Zookeeper_Java客户端Curator.md create mode 100644 pictures/curator-retry-policy.png diff --git a/README.md b/README.md index 4d0718e..03dc266 100644 --- a/README.md +++ b/README.md @@ -151,11 +151,11 @@ TODO ## 十一、Zookeeper -1. Zookeeper 简介及核心概念 +1. [Zookeeper 简介及核心概念](https://github.com/heibaiying/BigData-Notes/blob/master/notes/Zookeeper简介及核心概念.md) 2. [Zookeeper单机环境和集群环境搭建](https://github.com/heibaiying/BigData-Notes/blob/master/notes/installation/Zookeeper单机环境和集群环境搭建.md) -3. Zookeeper分布式锁实现方案 -4. 集群升级、迁移深入分析 Zookeeper -5. Zab协议及选举机制 +3. [Zookeeper常用Shell命令](https://github.com/heibaiying/BigData-Notes/blob/master/notes/Zookeeper常用Shell命令.md) +4. [Zookeeper Java 客户端——Apache Curator](https://github.com/heibaiying/BigData-Notes/blob/master/notes/Zookeeper_Java客户端Curator.md) +5. [Zookeeper ACL权限控制](https://github.com/heibaiying/BigData-Notes/blob/master/notes/Zookeeper_ACL权限控制.md) ## 十二、Scala @@ -176,7 +176,6 @@ TODO -## 十三、公共基础知识 +## 十三、公共内容 -1. [大数据应用常用打包方式](https://github.com/heibaiying/BigData-Notes/blob/master/notes/大数据应用常用打包方式.md) -2. 大数据常用文件格式 \ No newline at end of file +1. [大数据应用常用打包方式](https://github.com/heibaiying/BigData-Notes/blob/master/notes/大数据应用常用打包方式.md) \ No newline at end of file diff --git a/code/Zookeeper/curator/src/main/java/com/heibaiying/AclOperation.java b/code/Zookeeper/curator/src/main/java/com/heibaiying/AclOperation.java index e4147d8..ddf4654 100644 --- a/code/Zookeeper/curator/src/main/java/com/heibaiying/AclOperation.java +++ b/code/Zookeeper/curator/src/main/java/com/heibaiying/AclOperation.java @@ -33,7 +33,7 @@ public class AclOperation { public void prepare() { RetryPolicy retryPolicy = new RetryNTimes(3, 5000); client = CuratorFrameworkFactory.builder() - .authorization("digest", "heibai:123456".getBytes()) + .authorization("digest", "heibai:123456".getBytes()) //等价于addauth命令 .connectString(zkServerPath) .sessionTimeoutMs(10000).retryPolicy(retryPolicy) .namespace("workspace").build(); diff --git a/code/Zookeeper/curator/src/main/java/com/heibaiying/BasicOperation.java b/code/Zookeeper/curator/src/main/java/com/heibaiying/BasicOperation.java index 57f0108..31581cd 100644 --- a/code/Zookeeper/curator/src/main/java/com/heibaiying/BasicOperation.java +++ b/code/Zookeeper/curator/src/main/java/com/heibaiying/BasicOperation.java @@ -113,7 +113,7 @@ public class BasicOperation { /** - * 判断子节点是否存在 + * 判断节点是否存在 */ @Test public void existNode() throws Exception { @@ -160,7 +160,7 @@ public class BasicOperation { /** - * 针对子节点注册监听 + * 监听子节点的操作 */ @Test public void permanentChildrenNodesWatch() throws Exception { @@ -181,7 +181,7 @@ public class BasicOperation { childrenCache.getListenable().addListener(new PathChildrenCacheListener() { - public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception { + public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) { switch (event.getType()) { case INITIALIZED: System.out.println("childrenCache初始化完成"); diff --git a/notes/Zookeeper_ACL权限控制.md b/notes/Zookeeper_ACL权限控制.md new file mode 100644 index 0000000..0f22718 --- /dev/null +++ b/notes/Zookeeper_ACL权限控制.md @@ -0,0 +1,264 @@ +# Zookeeper ACL + +## 一、前言 + +为了避免存储在Zookeeper上的数据被其他程序或者人为误修改，Zookeeper提供了ACL(Access Control)进行权限控制。只有拥有对应权限的用户才可以对节点进行增删改查等操作。下文分别介绍使用原生的Shell命令和Apache Curator客户端进行权限设置。 + +## 二、使用Shell进行权限管理 + +### 2.1 设置与查看权限 + +想要给某个节点设置权限(ACL)，有以下两个可选的命令： + +```shell + # 1.给已有节点赋予权限 + setAcl path acl + + # 2.在创建节点时候指定权限 + create [-s] [-e] path data acl +``` + +查看指定节点的权限命令如下： + +```shell +getAcl path +``` + +### 2.2 权限组成 + +Zookeeper的权限由[scheme : id :permissions]三部分组成，其中Schemes和Permissions内置的可选项分别如下： + +Permissions可选项： + +- CREATE：允许创建子节点； +- READ：允许从节点获取数据并列出其子节点； +- WRITE：允许为节点设置数据； +- DELETE：允许删除子节点； +- ADMIN：允许为节点设置权限。 + +Schemes可选项： + +- world：默认模式, 所有客户端都拥有指定权限。world下只有一个id选项，就是anyone，通常组合写法为`world:anyone:[permissons]`； +- auth：只有经过认证的用户, 才拥有指定的权限。通常组合写法为`auth:user:password:[permissons]`，使用这种模式时，你需要先进行登录，之后采用auth模式时，user和password都将使用登录的用户名和密码； +- digest：只有经过认证的用户, 才拥有指定的权限。通常组合写法为`auth:user:BASE64(SHA1(password)):[permissons]`,这种形式下的密码必须通过SHA1和BASE64进行双重加密； +- ip：限制只有特定IP的客户端才拥有指定的权限。通常组成写法为`ip:182.168.0.168:[permissions]`； +- super：代表超级管理员，拥有所有的权限，需要修改Zookeeper启动脚本进行配置。 + + + +### 2.3 添加认证信息 + +可以使用如下所示的命令为当前Session添加用户认证信息，等价于登录操作。 + +```shell +# 格式 +addauth scheme auth + +#示例：添加用户名为heibai,密码为root的用户认证信息 +addauth digest heibai:root +``` + + + +### 2.4 权限设置示例 + +#### 1. world模式 + +world是一种默认的模式，即创建时如果不指定权限，则默认的权限就是world。 + +```shell +[zk: localhost:2181(CONNECTED) 32] create /hadoop 123 +Created /hadoop +[zk: localhost:2181(CONNECTED) 33] getAcl /hadoop +'world,'anyone #默认的权限 +: cdrwa +[zk: localhost:2181(CONNECTED) 34] setAcl /hadoop world:anyone:cwda # 修改节点，不允许所有客户端读 +.... +[zk: localhost:2181(CONNECTED) 35] get /hadoop +Authentication is not valid : /hadoop # 权限不足 + +``` + +#### 2. auth模式 + +```shell +[zk: localhost:2181(CONNECTED) 36] addauth digest heibai:heibai # 登录 +[zk: localhost:2181(CONNECTED) 37] setAcl /hadoop auth::cdrwa # 设置权限 +[zk: localhost:2181(CONNECTED) 38] getAcl /hadoop # 获取权限 +'digest,'heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s= #用户名和密码(密码经过加密处理)，注意返回的权限类型是digest +: cdrwa + +#用户名和密码都是使用登录的用户名和密码，即使你在创建权限时候进行指定也是无效的 +[zk: localhost:2181(CONNECTED) 39] setAcl /hadoop auth:root:root:cdrwa #指定用户名和密码为root +[zk: localhost:2181(CONNECTED) 40] getAcl /hadoop +'digest,'heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s= #无效，使用的用户名和密码依然还是heibai +: cdrwa + +``` + +#### 3. digest模式 + +```shell +[zk:44] create /spark "spark" digest:heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s=:cdrwa #指定用户名和加密后的密码 +[zk:45] getAcl /spark #获取权限 +'digest,'heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s= # 返回的权限类型是digest +: cdrwa +``` + +到这里你可以发现使用auth模式设置的权限和使用digest模式设置的权限，在最终结果上，得到的权限模式都是`digest`。某种程度上，你可以把auth模式理解成是digest模式的一种简便实现。因为在digest模式下，每次设置都需要书写用户名和加密后的密码，这是比较繁琐的，采用auth模式，则可以在登录一次后就可以不用重复书写了。 + +#### 4. ip模式 + +限定只有特定的ip才能访问。 + +```shell +[zk: localhost:2181(CONNECTED) 46] create /hive "hive" ip:192.168.0.108:cdrwa +[zk: localhost:2181(CONNECTED) 47] get /hive +Authentication is not valid : /hive # 当前主机已经不能访问 +``` + +这里可以使用限定IP的主机客户端进行访问，也可以使用下面的super模式配置超级管理员进行访问。 + +#### 5. super模式 + +需要修改启动脚本`zkServer.sh`,在指定位置添加管理员账户和密码信息： + +```shell +"-Dzookeeper.DigestAuthenticationProvider.superDigest=heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s=" +``` + +![zookeeper-super](D:\BigData-Notes\pictures\zookeeper-super.png) + +修改完成后需要使用`zkServer.sh restart`重启服务，此时再次访问限制IP的节点： + +```shell +[zk: localhost:2181(CONNECTED) 0] get /hive #访问受限 +Authentication is not valid : /hive +[zk: localhost:2181(CONNECTED) 1] addauth digest heibai:heibai # 登录(添加认证信息) +[zk: localhost:2181(CONNECTED) 2] get /hive #成功访问 +hive +cZxid = 0x158 +ctime = Sat May 25 09:11:29 CST 2019 +mZxid = 0x158 +mtime = Sat May 25 09:11:29 CST 2019 +pZxid = 0x158 +cversion = 0 +dataVersion = 0 +aclVersion = 0 +ephemeralOwner = 0x0 +dataLength = 4 +numChildren = 0 +``` + +## 三、使用Java客户端进行权限管理 + +### 3.1 主要依赖 + +使用前需要导入curator相关Jar包，完整依赖如下： + +```xml + + + org.apache.curator + curator-framework + 4.0.0 + + + org.apache.curator + curator-recipes + 4.0.0 + + + org.apache.zookeeper + zookeeper + 3.4.13 + + + + junit + junit + 4.12 + + +``` + +### 3.2 权限管理API + + Curator权限设置、修改和查看的API调用示例如下： + +```java +public class AclOperation { + + private CuratorFramework client = null; + private static final String zkServerPath = "192.168.0.226:2181"; + private static final String nodePath = "/hadoop/hdfs"; + + @Before + public void prepare() { + RetryPolicy retryPolicy = new RetryNTimes(3, 5000); + client = CuratorFrameworkFactory.builder() + .authorization("digest", "heibai:123456".getBytes()) //等价于addauth命令 + .connectString(zkServerPath) + .sessionTimeoutMs(10000).retryPolicy(retryPolicy) + .namespace("workspace").build(); + client.start(); + } + + /** + * 新建节点并赋予权限 + */ + @Test + public void createNodesWithAcl() throws Exception { + List aclList = new ArrayList<>(); + // 对密码进行加密 + String digest1 = DigestAuthenticationProvider.generateDigest("heibai:123456"); + String digest2 = DigestAuthenticationProvider.generateDigest("ying:123456"); + Id user01 = new Id("digest", digest1); + Id user02 = new Id("digest", digest2); + // 指定所有权限 + aclList.add(new ACL(Perms.ALL, user01)); + // 如果想要指定权限的组合，中间需要使用 | ,这里的|代表的是位运算中的 按位或 + aclList.add(new ACL(Perms.DELETE | Perms.CREATE, user02)); + + // 创建节点 + byte[] data = "abc".getBytes(); + client.create().creatingParentsIfNeeded() + .withMode(CreateMode.PERSISTENT) + .withACL(aclList, true) + .forPath(nodePath, data); + } + + + /** + * 给已有节点设置权限,注意这会删除所有原来节点上已有的权限设置 + */ + @Test + public void SetAcl() throws Exception { + String digest = DigestAuthenticationProvider.generateDigest("admin:admin"); + Id user = new Id("digest", digest); + client.setACL() + .withACL(Collections.singletonList(new ACL(Perms.READ | Perms.DELETE, user))) + .forPath(nodePath); + } + + /** + * 获取权限 + */ + @Test + public void getAcl() throws Exception { + List aclList = client.getACL().forPath(nodePath); + ACL acl = aclList.get(0); + System.out.println(acl.getId().getId() + + "是否有删读权限:" + (acl.getPerms() == (Perms.READ | Perms.DELETE))); + } + + @After + public void destroy() { + if (client != null) { + client.close(); + } + } +} +``` + +> 完整源码见本仓库： https://github.com/heibaiying/BigData-Notes/tree/master/code/Zookeeper/curator \ No newline at end of file diff --git a/notes/Zookeeper_Java客户端Curator.md b/notes/Zookeeper_Java客户端Curator.md new file mode 100644 index 0000000..cdf9fef --- /dev/null +++ b/notes/Zookeeper_Java客户端Curator.md @@ -0,0 +1,316 @@ +# Zookeeper Java 客户端 ——Apache Curator + +## 一、基本依赖 + +Curator是Netflix公司开源的一个Zookeeper客户端，目前由Apache进行维护。与Zookeeper原生客户端相比，Curator的抽象层次更高，功能也更加丰富，是Zookeeper使用范围最广的Java客户端。本片文章主要讲解其基本使用，以下项目采用Maven构建，以单元测试的方法进行讲解，相关依赖如下： + +```xml + + + org.apache.curator + curator-framework + 4.0.0 + + + org.apache.curator + curator-recipes + 4.0.0 + + + org.apache.zookeeper + zookeeper + 3.4.13 + + + + junit + junit + 4.12 + + +``` + +> 完整源码见本仓库： https://github.com/heibaiying/BigData-Notes/tree/master/code/Zookeeper/curator + + + +## 二、客户端相关操作 + +### 2.1 创建客户端实例 + +这里使用`@Before`在单元测试执行前创建客户端实例，并使用`@After`在单元测试后关闭客户端连接。 + +```java +public class BasicOperation { + + private CuratorFramework client = null; + private static final String zkServerPath = "192.168.0.226:2181"; + private static final String nodePath = "/hadoop/yarn"; + + @Before + public void prepare() { + // 重试策略 + RetryPolicy retryPolicy = new RetryNTimes(3, 5000); + client = CuratorFrameworkFactory.builder() + .connectString(zkServerPath) + .sessionTimeoutMs(10000).retryPolicy(retryPolicy) + .namespace("workspace").build(); //指定命名空间后，client的所有路径操作都会以/workspace开头 + client.start(); + } + + @After + public void destroy() { + if (client != null) { + client.close(); + } + } +} +``` + +### 2.2 重试策略 + +在连接Zookeeper服务时候，Curator提供了多种重试策略以满足各种需求，所有重试策略继承自`RetryPolicy`接口，如下图： + +![curator-retry-policy](D:\BigData-Notes\pictures\curator-retry-policy.png) + +而这些重试策略类又分为两大类别： + ++ RetryForever ：代表一直重试，直到连接成功； ++ SleepingRetry ： 基于一定间隔时间的重试，这里以其子类`ExponentialBackoffRetry`为例说明，其构造器如下： + +```java +/** + * @param baseSleepTimeMs 重试之间等待的初始时间 + * @param maxRetries 最大重试次数 + * @param maxSleepMs 每次重试间隔的最长睡眠时间（毫秒） + */ +ExponentialBackoffRetry(int baseSleepTimeMs, int maxRetries, int maxSleepMs) +``` +### 2.3 判断服务状态 + +```scala +@Test +public void getStatus() { + CuratorFrameworkState state = client.getState(); + System.out.println("服务是否已经启动:" + (state == CuratorFrameworkState.STARTED)); +} +``` + + + +## 三、节点增删改查 + +### 3.1 创建节点 + +```java +@Test +public void createNodes() throws Exception { + byte[] data = "abc".getBytes(); + client.create().creatingParentsIfNeeded() + .withMode(CreateMode.PERSISTENT) //节点类型 + .withACL(ZooDefs.Ids.OPEN_ACL_UNSAFE) + .forPath(nodePath, data); +} +``` + +创建时可以指定节点类型，这里的节点类型和Zookeeper原生的一致，全部定义在枚举类`CreateMode`中： + +```java +public enum CreateMode { + // 永久节点 + PERSISTENT (0, false, false), + //永久有序节点 + PERSISTENT_SEQUENTIAL (2, false, true), + // 临时节点 + EPHEMERAL (1, true, false), + // 临时有序节点 + EPHEMERAL_SEQUENTIAL (3, true, true); + .... +} +``` + +### 2.2 获取节点信息 + +```scala +@Test +public void getNode() throws Exception { + Stat stat = new Stat(); + byte[] data = client.getData().storingStatIn(stat).forPath(nodePath); + System.out.println("节点数据:" + new String(data)); + System.out.println("节点信息:" + stat.toString()); +} +``` + +如上所示，节点信息被封装在`Stat`类中，其主要属性如下： + +```java +public class Stat implements Record { + private long czxid; + private long mzxid; + private long ctime; + private long mtime; + private int version; + private int cversion; + private int aversion; + private long ephemeralOwner; + private int dataLength; + private int numChildren; + private long pzxid; + ... +} +``` + +每个属性的含义如下： + +| **状态属性** | **说明** | +| -------------- | ------------------------------------------------------------ | +| czxid | 数据节点创建时的事务ID | +| ctime | 数据节点创建时的时间 | +| mzxid | 数据节点最后一次更新时的事务ID | +| mtime | 数据节点最后一次更新时的时间 | +| pzxid | 数据节点的子节点最后一次被修改时的事务ID | +| cversion | 子节点的更改次数 | +| version | 节点数据的更改次数 | +| aversion | 节点的ACL的更改次数 | +| ephemeralOwner | 如果节点是临时节点，则表示创建该节点的会话的SessionID；如果节点是持久节点，则该属性值为0 | +| dataLength | 数据内容的长度 | +| numChildren | 数据节点当前的子节点个数 | + +### 2.3 获取子节点列表 + +```java +@Test +public void getChildrenNodes() throws Exception { + List childNodes = client.getChildren().forPath("/hadoop"); + for (String s : childNodes) { + System.out.println(s); + } +} +``` + +### 2.4 更新节点 + +更新时可以传入版本号也可以不传入，如果传入则类似于乐观锁机制，只有在版本号正确的时候才会被更新。 + +```scala +@Test +public void updateNode() throws Exception { + byte[] newData = "defg".getBytes(); + client.setData().withVersion(0) // 传入版本号，如果版本号错误则拒绝更新操作,并抛出BadVersion异常 + .forPath(nodePath, newData); +} +``` + +### 2.5 删除节点 + +```java +@Test +public void deleteNodes() throws Exception { + client.delete() + .guaranteed() // 如果删除失败，那么在会继续执行，直到成功 + .deletingChildrenIfNeeded() // 如果有子节点，则递归删除 + .withVersion(0) // 传入版本号，如果版本号错误则拒绝删除操作,并抛出BadVersion异常 + .forPath(nodePath); +} +``` + +### 2.6 判断节点是否存在 + +```java +@Test +public void existNode() throws Exception { + // 如果节点存在则返回其状态信息如果不存在则为null + Stat stat = client.checkExists().forPath(nodePath + "aa/bb/cc"); + System.out.println("节点是否存在:" + !(stat == null)); +} +``` + + + +## 三、监听事件 + +### 3.1 创建一次性监听 + +和Zookeeper原生监听一样，使用`usingWatcher`注册的监听是一次性的，即监听只会触发一次，触发后就销毁。示例如下： + +```java +@Test +public void DisposableWatch() throws Exception { + client.getData().usingWatcher(new CuratorWatcher() { + public void process(WatchedEvent event) { + System.out.println("节点" + event.getPath() + "发生了事件:" + event.getType()); + } + }).forPath(nodePath); + Thread.sleep(1000 * 1000); //休眠以观察测试效果 +} +``` + +### 3.2 创建永久监听 + +Curator还提供了创建永久监听的API，其使用方式如下： + +```java +@Test +public void permanentWatch() throws Exception { + // 使用NodeCache包装节点，对其注册的监听作用于节点，且是永久性的 + NodeCache nodeCache = new NodeCache(client, nodePath); + // 通常设置为true, 代表创建nodeCache时,就去获取对应节点的值并缓存 + nodeCache.start(true); + nodeCache.getListenable().addListener(new NodeCacheListener() { + public void nodeChanged() { + ChildData currentData = nodeCache.getCurrentData(); + if (currentData != null) { + System.out.println("节点路径：" + currentData.getPath() + + "数据：" + new String(currentData.getData())); + } + } + }); + Thread.sleep(1000 * 1000); //休眠以观察测试效果 +} +``` + +### 3.3 监听子节点 + +这里以监听`/hadoop`下所有子节点为例，实现方式如下： + +```scala +@Test +public void permanentChildrenNodesWatch() throws Exception { + + // 第三个参数代表除了节点状态外，是否还缓存节点内容 + PathChildrenCache childrenCache = new PathChildrenCache(client, "/hadoop", true); + /* + * StartMode代表初始化方式: + * NORMAL: 异步初始化 + * BUILD_INITIAL_CACHE: 同步初始化 + * POST_INITIALIZED_EVENT: 异步并通知,初始化之后会触发INITIALIZED事件 + */ + childrenCache.start(StartMode.POST_INITIALIZED_EVENT); + + List childDataList = childrenCache.getCurrentData(); + System.out.println("当前数据节点的子节点列表："); + childDataList.forEach(x -> System.out.println(x.getPath())); + + childrenCache.getListenable().addListener(new PathChildrenCacheListener() { + public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) { + switch (event.getType()) { + case INITIALIZED: + System.out.println("childrenCache初始化完成"); + break; + case CHILD_ADDED: + // 需要注意的是: 即使是之前已经存在的子节点，也会触发该监听，因为会把该子节点加入childrenCache缓存中 + System.out.println("增加子节点:" + event.getData().getPath()); + break; + case CHILD_REMOVED: + System.out.println("删除子节点:" + event.getData().getPath()); + break; + case CHILD_UPDATED: + System.out.println("被修改的子节点的路径:" + event.getData().getPath()); + System.out.println("修改后的数据:" + new String(event.getData().getData())); + break; + } + } + }); + Thread.sleep(1000 * 1000); //休眠以观察测试效果 +} +``` \ No newline at end of file diff --git a/notes/Zookeeper常用Shell命令.md b/notes/Zookeeper常用Shell命令.md index 57da0f9..48e7644 100644 --- a/notes/Zookeeper常用Shell命令.md +++ b/notes/Zookeeper常用Shell命令.md @@ -102,9 +102,9 @@ numChildren = 0 | mZxid | 数据节点最后一次更新时的事务ID | | mtime | 数据节点最后一次更新时的时间 | | pZxid | 数据节点的子节点最后一次被修改时的事务ID | -| cversion | 子节点的版本号 | -| dataVersion | 数据节点的版本号 | -| aclVersion | 数据节点的ACL版本号 | +| cversion | 子节点的更改次数 | +| dataVersion | 节点数据的更改次数 | +| aclVersion | 节点的ACL的更改次数 | | ephemeralOwner | 如果节点是临时节点，则表示创建该节点的会话的SessionID；如果节点是持久节点，则该属性值为0 | | dataLength | 数据内容的长度 | | numChildren | 数据节点当前的子节点个数 | @@ -211,153 +211,7 @@ WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/hadoop -## 三、权限管理 - -### 3.1 设置与查看权限 - -想要给某个节点设置权限(ACL)，有以下两个可选的命令： - -```shell - # 1.给已有节点赋予权限 - setAcl path acl - - # 2.在创建节点时候指定权限 - create [-s] [-e] path data acl -``` - -查看指定节点的权限命令如下： - -```shell -getAcl path -``` - -### 3.2 权限组成 - -Zookeeper的权限由[scheme : id :permissions]三部分组成，其中Schemes和Permissions内置的可选项分别如下： - -Permissions可选项： - -- CREATE：允许创建子节点； -- READ：允许从节点获取数据并列出其子节点； -- WRITE：允许为节点设置数据； -- DELETE：允许删除子节点； -- ADMIN：允许为节点设置权限。 - -Schemes可选项： - -- world：默认模式, 所有客户端都拥有指定权限。world下只有一个id选项，就是anyone，通常组合写法为`world:anyone:[permissons]`； -- auth：只有经过认证的用户, 才拥有指定的权限。通常组合写法为`auth:user:password:[permissons]`，使用这种模式时，你需要先进行登录，之后采用auth模式时，user和password都将使用登录的用户名和密码； -- digest：只有经过认证的用户, 才拥有指定的权限。通常组合写法为`auth:user:BASE64(SHA1(password)):[permissons]`,这种形式下的密码必须通过SHA1和BASE64进行双重加密； -- ip：限制只有特定IP的客户端才拥有指定的权限。通常组成写法为`ip:182.168.0.168:[permissions]`； -- super：代表超级管理员，拥有所有的权限，需要修改Zookeeper启动脚本进行配置。 - - - -### 3.3 添加认证信息 - -可以使用如下所示的命令为当前Session添加用户认证信息，等价于登录操作。 - -```shell -# 格式 -addauth scheme auth - -#示例：添加用户名为heibai,密码为root的用户认证信息 -addauth digest heibai:root -``` - - - -### 3.4 权限设置示例 - -#### 1. world模式 - -world是一种默认的模式，即创建时如果不指定权限，则默认的权限就是world。 - -```shell -[zk: localhost:2181(CONNECTED) 32] create /hadoop 123 -Created /hadoop -[zk: localhost:2181(CONNECTED) 33] getAcl /hadoop -'world,'anyone #默认的权限 -: cdrwa -[zk: localhost:2181(CONNECTED) 34] setAcl /hadoop world:anyone:cwda # 修改节点，不允许所有客户端读 -.... -[zk: localhost:2181(CONNECTED) 35] get /hadoop -Authentication is not valid : /hadoop # 权限不足 - -``` - -#### 2. auth模式 - -```shell -[zk: localhost:2181(CONNECTED) 36] addauth digest heibai:heibai # 登录 -[zk: localhost:2181(CONNECTED) 37] setAcl /hadoop auth::cdrwa # 设置权限 -[zk: localhost:2181(CONNECTED) 38] getAcl /hadoop # 获取权限 -'digest,'heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s= #用户名和密码(密码经过加密处理)，注意返回的权限类型是digest -: cdrwa - -#用户名和密码都是使用登录的用户名和密码，即使你在创建权限时候进行指定也是无效的 -[zk: localhost:2181(CONNECTED) 39] setAcl /hadoop auth:root:root:cdrwa #指定用户名和密码为root -[zk: localhost:2181(CONNECTED) 40] getAcl /hadoop -'digest,'heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s= #无效，使用的用户名和密码依然还是heibai -: cdrwa - -``` - -#### 3. digest模式 - -```shell -[zk:44] create /spark "spark" digest:heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s=:cdrwa #指定用户名和加密后的密码 -[zk:45] getAcl /spark #获取权限 -'digest,'heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s= # 返回的权限类型是digest -: cdrwa -``` - -到这里你可以发现使用auth模式设置的权限和使用digest模式设置的权限，在最终结果上，得到的权限模式都是`digest`。某种程度上，你可以把auth模式理解成是digest模式的一种简便实现。因为在digest模式下，每次设置都需要书写用户名和加密后的密码，这是比较繁琐的，采用auth模式，则可以在登录一次后就可以不用重复书写了。 - -#### 4. ip模式 - -限定只有特定的ip才能访问。 - -```shell -[zk: localhost:2181(CONNECTED) 46] create /hive "hive" ip:192.168.0.108:cdrwa -[zk: localhost:2181(CONNECTED) 47] get /hive -Authentication is not valid : /hive # 当前主机已经不能访问 -``` - -这里可以使用限定IP的主机客户端进行访问，也可以使用下面的super模式配置超级管理员进行访问。 - -#### 5. super模式 - -需要修改启动脚本`zkServer.sh`,在指定位置添加管理员账户和密码信息： - -```shell -"-Dzookeeper.DigestAuthenticationProvider.superDigest=heibai:sCxtVJ1gPG8UW/jzFHR0A1ZKY5s=" -``` - -![zookeeper-super](D:\BigData-Notes\pictures\zookeeper-super.png) - -修改完成后需要使用`zkServer.sh restart`重启服务，此时再次访问限制IP的节点： - -```shell -[zk: localhost:2181(CONNECTED) 0] get /hive #访问受限 -Authentication is not valid : /hive -[zk: localhost:2181(CONNECTED) 1] addauth digest heibai:heibai # 登录(添加认证信息) -[zk: localhost:2181(CONNECTED) 2] get /hive #成功访问 -hive -cZxid = 0x158 -ctime = Sat May 25 09:11:29 CST 2019 -mZxid = 0x158 -mtime = Sat May 25 09:11:29 CST 2019 -pZxid = 0x158 -cversion = 0 -dataVersion = 0 -aclVersion = 0 -ephemeralOwner = 0x0 -dataLength = 4 -numChildren = 0 -``` - -## 四、 zookeeper 四字命令 +## 三、 zookeeper 四字命令 | 命令 | 功能描述 | | ---- | ------------------------------------------------------------ | diff --git a/pictures/curator-retry-policy.png b/pictures/curator-retry-policy.png new file mode 100644 index 0000000000000000000000000000000000000000..a5fb06ceb9c256c66ca9ce45ff862785fbb54219 GIT binary patch literal 12762 zcmd6ucUY54yRU;NHWV8Q(sa>9I?^H_qV(Q-Kzi>WAOstzH0izfuAxaslomPxA_Ryc zp@qOAkU&C!^Wt)SeRK}GqIE(mmD z5CozUIYR@)Y~+P+0FSet$|gP_(8aIEKU7J47ny*_%f63|ef2!-eFLn$?Ld0&PM+32 zzIGNjhUY+_TOgH3^7>CRadXi3%$ShnEiLNLT_?5_#2<;<*MGp^aq5?^SY(>(cUQma z)Px%dzi#$3!kmb^D(mAv9T4948miG4%>oWs2EBbt_bK!C^G9>!UW1dhS5oQe_n++% zH=c~FOF6!>H>Z)(tRsJ}xo6+F8B3Z(h;9$AZw&4Xt{jxF&19{HW*_?RBDA2(tMev& zv|qG=MuXC&`BsmgVe*Pyw7`?$y%06I4GN<=D+)ZU9{dk{w9LT*0_CvO)#WD5oJqxb?U^2sHSvJDd|UF)bQ}@`Jh!y%Gx}%_tfU-*KVUVoJWXR%?pLeX_eEU+{j-gq+VU> zI0`f*y}pq?9K4FTK^PwpbYAb`+YywoKtz5IA8o`KYr!vWCS~pG6(O{o9f%&7;we+X zv!X((d&qAfA^l`C%_Ho$Bc0G6Zwf~x>9yzyyK+ZyAFC%dMg}xG%#!KT#&>y<1VSC8 z=Blr00}QgzQR8<)NcC6sckg8#uGZ&NJS{Kv@AtNY3o?(%wGp?A{baJC4`XfFCfTQz z2u}~+CSzS?RT^^i7?Qc5_>n|^>9U_}i^XVmZsY#ue8ek}X?#%ak>&RA>BS{!UL%#n zl)?!dJRBXLVd_Rp*r)1T`3{T^!=0gokCe9scQ`}u(K%!%a%4fbq}#lo=rlgv^x)Yh zHi{os;9hs1YV&xO!Qr&DBFc}PE){{9n$0(OynlhYxaN2l)ucSmr&1QnV}lkHd}`^w zR-Tk}DvXQ4nkFo7oN_rV#ZtC-j|a~`zt8cSeB;R3hp@Y%e+NMkemyYdF=2<5aK^;) zJhHie7YWXtSbVzJ#way434`m+$e4$2Dh5jNdR8YVwL_#>k~7*(HMK2eLmFk%tM5Xp z`92l2x;|^$LK3ibmEdb)!5r)X9pir63m-$3s)cD-`$3BI?1R8`m`1+}=bx_`bh+1I z5>j*-*}JW!c8;JtRWsaVJNKB}`PHwd`NZ-~lla1l#QtI4jPk)?)fhq;SFO)Ey?Eb8 z?qn{hGAUA?pajlQR+JkpFm#^d)NmBVQ?s4p)OlDdBW4y_l2~|4k_Ws^Uj!d8Y~%l6)m&(o69`RwG8}e$A355(YSpldo|Fip9oC1EH_&Aj}fqT1{E<1kQ z%+>_>j%m#l%K=x;l)AQ73l3DbIzYI=yNNGm;|ryVV}#}_a1 zD9;s#Y%H115n1hYwRq1gsCe7vi19f@J$Fcbu5)Y*6pH2=Wh%v-+%3_hGoxy_qbT#`nY@2Z(XV%Tsi0-^(|5Ob++XM%E-J?#qK|kI zp*1;>J2vFvh;eUph?l0EBvD~9y7Q)Ds!L5tQhyZRpRC%NYVk7s;NADFeG=9uhfCAJ+ax})2H`wDgW- zF?eW}=-+dVj9PT?FpzGmr$p7-?vKEc@r8W0o6JTt(|7p%Dqz#A;mxY_8;16HQ>pF7 zI~nh4YD~=a@CsTngxe;Tm^L^3mpROGjM@G8yfWiT)MA9ClO=)y6eYq(tAK#K15ELQ zkH(1{(b4p#0^7TCa`}|5NR~+nuYNGWC8c2>UjO-;Bm&RXVG^2XBV@yKU7|vp$I;oj zyvB=aTmpwH=R438R)Y)QQ9iwkV87(hF0e;Mg}|G`M>fc`epQU9>q zw}A->We0xU*5SFP&tsnM%dnz+8`!CQFCQ25{NqPq`g5m-hKIRW&KZUs?VOIHIlLzh z%3WJrP?4d0i6Fe)4gF(PJ7{5kd1I2_2%R4}Ws&I10}Agm0n9vzfq7Rppk`K~T2mlf zT{^KE-1Jm;Rr*VFBza@I?#QchJOEHX;6Ep2I&fgh>}rBD@M(-9SMRfI$O+I>Uf5 z0D**nRvl*oHaOrx4J@?>SvrT+3p(@SptdiKwm>9^2AF@)S`6&~P^_a4>- zh_KDyAt1@W)ctSG`j>=z$;V}Nh5;>Kx!taC!{ss4iTK_#fWvVKoflc3e}Sss=D+FA z?;?ZVY>sxDj)jLUZt)-YJB$h##ZiT45du^1#7}a>{+E*f5AM}JEB$FE0+a=M=@Wku z)VacUJrZz^R3e_sW~8UDskGIVj7?SeQ&*k>stT$$zN;GF(<7iNd1XiK<5S(&5A(SD z>2OZI1lSzN{pooCE%V{km0BWBENja_<*gR?J{MxVtm$1jf5akP*`akzRv2LRcXakoI-tjDIq!waJUjGtYG%*+>bB=G@G(1)WuC9asG{$n zY7Ke>c7E1 z#F8>oUov~viI`gd4#za{Q;4S*`W|)RgZFXg9m`hhJn{GFAwf-)W{a-Y!UZ)!mmiBR z{8+QOomb3QIpt7I>r_34P_=}4?rV-JMdt&*VF=yDzn!c##gKT5xtL5!zntDoVE#+* zqgxUOtWxp;PgdHNu!pM^1MsZ(GmS;#Vgcr4Af$l}x_|VFwO_Ve2^PDy^^AMp^HPk$ zLC}|VoGJl^^Y=SJb2Zi$v{JBi<7-aq&O7I`PNfnzZrodzD}Mb@KHhh@*{?ZtvxMF6 z6}exnW+gt-G{E{iH+uA~o`-V0KnP0O;zPSeKnl2$G=ZCOFnYqAl5wDgAw0giByYr6 zRMG8>l2HB(o9RUx`+v9>>$9=f^iDS1+FdJ2#9Bk(7V>t2UIk2WfCMe?Ta;%W3LAv7xA+@r`cY5W@&Z0Yqzi3M529 zZg1=bUM}!4DW^4m^I#J?HBi$&<{ju{qH0mrKbtdfK7A-wPC%Hwx7pM%P_-ojoEl*4 zPIi`(KcKAHur=)`HEd{WSN&9M+F)U+ENC?+ANINJuC&Yk_8v1B)UZ3=y5G$$ss*q6 zkljPXSRy&!)U@O@PGztSP*&kS1DMOUHo6T4Mt$9$1Bt-Yf z*xGVjmCAnQ)a2csao8APd6o&4C|vbYNknMx*9xvceW>r{FVsH&x*+`%(KIVyjOO0_ z!&pJIz6bbz1F=u^i&xHUM=@iW(g%lm zX_v2sxBG8&ls(&@6{`_jxFIPD`+|Q4jX1G9%oQ7QS55j4k5DD2ru7I;kD6I?I~FJp zDanr#S9fI9r0y$&?1NRu+2N9iL%djb_p3+#q`Vq+RoH>l>uD6caf@BpL9VFA!JnrQ zs@Q~Ye(^nbeb7zAowTdaLex(m#PQBIq)*lt_HLi%cpb!nH7XeoUg|v`FLiN@U|CSN z-+BjUFZ(kEDN!;?hnc7+tVp}-mD@#SV5X{$0#EJ7CL%jt_}t3SZ=o`bIW_`*$wDcq z@#*86HG+q*$013JK2pTsjAd?|ARldxp7{0)W|zpj%MU8sIe8^>A1EyrHTJ<8`e4j~ zQckh~-|pAk53=8fBwJXZe>#(k}R$$;Ipxxa+9UC!2hZx-+SK;ARUwPpHnJ!1IEQoLrigL@@*Y3DQn z&Lrq!z4hn|zG&C9`~8GhDa3<8)<|`H0A~-mXC2$v!G#s-X0U*6gRZFC zpG5&{P&&zv6cUk};LPYvgc9G2$3$aWBL!S_m7GZ1Q}=4N7tW8wUAuFXfUMZGAU8mS zD?2RVA?kVib<9`+sn5F@)EH_uUN<;#XhY{qW5=oRz@WVLm}ayKYT_xlV|qk88g=C$ zOxtXV*ul}#%#w6rU94wMOJ$~5eMug74i9^In*Q67Vd#^_aa4WD6`x>d$S4Vr+mXL_#-~hun=H`OH@->fA*Fv> zFxN2mst#S27)GALn$p1hxoY9 z%4?e`4If0c&Jz3jtb7wCqq@hP4+5L!5#`ajy-M7_{dk@^+09!$dwurLAVup=PDcuO zVg%f_*lZmU>KJ;LTf8-IMfpRMOj5BfqryIq;O^Xw<(-!{a{3{`t}|rf?7EbeddgHMB%#NN2_%~keu^wWGiFDZ|^m;C;24Srsn^kbvX=j)btG4U?%y`n7g`M`wi zt~D|$hnk~@LGk!>WxpF_MfmGRkHB z;FNoRfZBIBUYsvuZf;ThsmICTy4HS=9Q}UOrzrw+N)P^OQy12oM`$jQ$V#rOZ2Gy(=<*G=<)`5hR5aj4=JCgjN zJSy0|5KIQVN}SWg&OcnICmghMkN)8uojm<70jP19d%g_S3LW6vhJ1Z=~VCSYE9ML{m@ChCB(8kz3WC!M8dj^_yq-GPoVAJJhU<=H>h2){t^Y zny?>UhR5e+s;#6YnC$+vNeH0=ttOq=VDAv=J*SYK#m~i}Y6dx2+ufNS8D1NbAT6B* zy#Z)TNS`%iM+v@sV<*~UaMeLBm~+)L>i(wo+=x7(Hm5D$niSpt&kxB$Lh#EML z>l}T$J!Cf*vWr%UzkUPFyrQ!-J^jSbR*JlTi@avkQPSNl!Ko5}J_v{sp?*Mn7U+f! zqeV5tqR!G@DLyww#7HrPkHL;6Oc8Lo!XNtjHa*c+O3R4mp_Mdf7+LXr zRZ8Kb@k(r(bj0UIi}V7a<7`1dHX6&?G0Z!8COh$H4!Rj0A0Tv2F^wuW9B5vr%e`iE zVda8BoMPN*J0SOp_o;$GkTyUKR=H_F-84XC!sSJIMj*Fe44cG?@io1Zm|`e9v_D-L_UlkEKz+eCy-0 zxApw=%7x#g_D|^gH}C<7;=f~}|GOXUBw;l%9De79Vihl7P?)JIRRjnQj?`Ju#^=Es|D&Jqu18NprVcdv7**x20QWIj6z?p{!# zKleJ@TwgL`l)p}|Qc)0f;Zi_Pj1clJCkseuQ8Ge^*0BU+82c(s^O`aH@NHV^8Q!o- zcIzo`;4M*z@j3G)%>SGfK{=Jt4>a}WpTX5f&+jcTcM0WYoiLWUV(*Tia``It%K8EL z)CXYMu|!Ezb_|?0J{3_`$-CU*%4Xu>&Cfz&A5u@Pugg}x^f}}57~Ji=Q!oeOq`0{9 zGnP!-~H)du( z8v{6ucRsM^FR-zzbn!!Mdm}cJ?H-rJ@~x1A$T9}RIe7B<%x~?==#ts=pF)jPh(sT` z+a7q<*FR!0s4b*M%v}0Ui=hd+Dx}=|Wo<~z7XYfz2^o=XIW1bN232xF0*{~)gv(jk z4hQM#TRYUaIzmuJ-Q@S5lMFY>^YF#{dA2CVQMvo^V+(p~T9Eoguvde#O49VKm(!Ck zFaZeq6Xhp~5jfa<&tU=EcoJf@5W@Fvi0FgI5ryfhTW5DRU1as@?_Et^5Pbd7(jtDMn1Sk$|c zary^R-)xe=LR{|jWVd$riXUN-Ga9?NGt~Wfh!pFTr~RHItJXcM8oj@2oL1{gB1_y{ zGc`6J-S25siMNlDMR;dLOSgTx*gWa3RC_)Y_W~>xm?YMbeBM)n=<)0z2^sB&B3{rP zRcZa=KO2E%UK{apOsX^__L@$yRJ9;5H1c*F-XE^m&y;cOv%{ZCIHv@+!8QyqfkQFK z+m(QV1(7^<+29%OOo*M}U5YXZsx|%P^$q-WdkK^^m>h#`J zACE-4Ih~OE?7(q4W>8rgSY!2>R*Erx^_BR=lVf|oB(N+#{87qP-DbFKQI}_Jc`#94%_);DXd%Sf zPo6B>$tK0#JU;I?4D`0=;OE7V@wk`x+2x||no`?rhEr%(UQu>%rXIsE?@j=Z=f>Tm ztq}m(=A7*x~yQvz0=Q&kI1_;UZHBOad7*$l#w)>sU$c)9+FYs?_EE9-NLnZ;W z&IKH5x}GJKJMuVy5O*3I=d>E+xY5bFj1cQR`VfBNjJu?Na8bw@pQI@RS^O4AxiFUZ`gsb4lPiwmjA9%8j7jvFwice*jAXvb|e1U|AXsv?0^ zQP&=!_HvZSnCrL_y9~8_z{CLt(LbMaN$!l(aAYoDg@#oNs_;sbaewyL?yoyc}rKRcm|74h3I8#fU|b{pl;PR3+;u*EGu7D#p5 zweyAE0~aIvhh>UxHFB(mz4$IY?eB}C5xmT+LS$Y;dpRZ>e?=WSkEA_)FBxY?CT#hD zYshj9Rzji(l`M>Qk4DEk8!5)+3{3&{kJ~IMHceIh@N;oO5IfMaGR5zZNE+b>83ss?LiW=Q8D)G_70dezj;jeL8-gJ(v{-OGQq^}OK3dI&V%1NwRLv)tjk1s2D$ zs8xigQ`2UGf3!5zk!!w2S2x1K*M0N8 zg(gq>WEnm<=~Iqj?vQHH%mm`nu6&bw`^}UrlA2vDVkYMhH?zwPyrUWmWx*`yB_}(P zpXXZfUd}CoKldv>vK0Oc&H6r5F9Gfe*c{&lFsn-lWhnM3h4fmh6Nk5yEsFe?CAIkK zeWbl59O;*%yqfkJ0)ny`$x*Y^-Y>_+o2EN-xd<S8Yp(3 zY#;peB6oW0U89K}%5{6D?(g;V!%W09)7MPAy_m9kVG_Aq85|jkUCOXgdws!9oqLND zEAD8$rN7>G{(_zA=ILQWlgZtlq<-1T#DJXNVYf4NQlzTRcBw+mCtKt`g_m;J<^xnqE-i02TN=*eg zZ`!dMPPILZ?pLLh{K#~|%fn3AeiY~Tzg?y9Opd`ulyQb|)SZE{^;=qbbJcRG@tYnA z2GK69zGk7&1JW#{4$?=-y>wrFh45RSXSB-8yw zCtgh4(6MQ7{UaeA++JNkZg4f9*eNz@xjb_dz}x^ASy3U2ThV9FoCe!g5y;qbFlj7Op|3tu5hTE5^qjG1z z;9v0Cbp`NF|CDiF9zAzq(95_=v}hzZ>tX=-RQ%(v+2Wt6^S-KAnJf{rTa9<1WPZPG zE^*4k<8?5AJc6ZARclkOGbrkOpS{KX-u37Kfp0xt)OlHZnFcFaIh8i;)csq zSb6u*!=)rErt~2ILbTpJT!S_?Hh?6Oo|UB`eJyu6Xe;Lf00V9S4A2~{(j9pA9J;vf zpx0ejArqQfu>duIqPRwa4bukeRU)XOn6KFH3^lmLD#vFBE-k%crwSVr1)EI(F)L{f z?)FwER$#S&@Zt~-knP+_(2BqaSbz8GgWdN+1%ml3l37w9Un5_k7thb;?klH``D_hm z3^Rk8`D8DB?mRha!7;efWX~dToJy%y{tOLQ*v22$idyw+b*qC^xnR=^4}^rMeCf`L z2Eiw+5oy$&GpRIe45^@IfUac_)wRWwCK3S$8ZOVgBgmi7S|XKB)~947;m z5ScM2ZViWvpbErl7&Z0P&Y3u&0&c@``Qy^ym9`(AKR;`Q11_el@C}gjyZ-b6It^lf zD|`KyKnzgVu^jjR2O0i9X~vjQH8{!l3`hvJV)K0d!*6T{G(>&ilG20OJcWq(i&UL= zG&F>pU)$10J_hKr@XLdTD=$a+s3p3dt&HB*(6C7GWdIohhb~7I)6*t)B58#RpBXFv zMSC;*rM*2bWRwy1WFO>I`z1R&n=65iry68+(u;*^RE9cTNRS)27iCrYcTf}%`i#$4 zv;UfYkkE@yF`$)fDvi{pB%0sx4iBy_5!tEbLJZQu?!3_E!-KaM#*?G-0H`V$1%VX8 zuzhLE>xI;vXP8Ez(QUSw_OY*L0`%cI7da=jNQk09t#*cnDu4aUT^{5n?28Cy zLuV$aW7fRIjxEI|L|uO53F+hPj)C`!`lQB6RhBK}OA)GPzy{V+Zo+>09X1wxdM&%lSx{U6mTWlp>-^fS{ql#c&1FayBN z=EK9?#ic1r4+XSIS|)d01C~DIQoMwItS!LbYE4%iDw4xe0V$75{4N$xh#rv3&Kc`k zIIA+wi4~YS%{AYce@5@$(GhCrS7}kSZ8F4-b)41>M2++}77Wm$xQYJ-JnvT2$vF@B z?d}P5hgJ_#o>`XlZ#k35$mrhc?WZ>T=NWikK4Ve&v-N^3?|@Xkx_F6eImL1Vt6G9C zAcebh!oP)9w;DMt8UwOUO_|{wz?8k6RyWIE1s=<5{@xw}0?xxw_4BV^aI9wfVSNwg zwR+*1MFYr=F>Pem!i#x{c8z#3pPe+|s#jHVsivkS=TMEfmqjF;n>fiem;_7GTKX~{ zSLF}Bd39-n745!`-XrtXFku^TOoh1#Pn9sAsE26rejH`n#4u(D#fBq=rZQ#Hgi<15 z8KG|ecK;D6b^mvye48)KYWU&kjcc&d?;Bg?2$uR@ zCU1Zc@dN;ujupB|nA5H&HYkhw<2USbO{MGhLAH-aWu)A{B4}>ACAaa0t6Zh0naj3m z5?|XUM*p2~NQbw^u3xS3&&G2oW^^(kb-~ak(4iO?dM>j9b5eJhk0nB@$MUqsf?pdo z=CY%nx(3mRl3KhurG)tS^UAD_Wil#{!S{$RoxUmHR{j%d&X`!+gEjr25lX}+;Cta0$<2H>h2uLt5D#@1bh7n$P0mbfe{cq#y%cJu*uNK{T^ zoSwwZ=5?02I&klQuB)nQC^Bfm;T0fhiMIPb=V}{y4H`XiQn36k5QOp1-mkvTGzenu zK2vk%ReGlJFTi$1bj}X`nt2^X^*`3rM`MR zg$!2R|Km;d<_PbYblz^bw6%cn(U@XI%*Jo|EhR@T(l0lXn^rhc6RyAHaV>l# zsd(^mQB_+}0$4KlmR|mKVP7}#(V0sZbIrptfG0Dy1m(|pL2_UF?<_Nn7Y!) zIZgDdhkd3xCH;qB+vDW=$H|z!0hR5hFSvnZxir+FPrVzyaWa{3q@0k=J`gCM77`3+ z@huum8Bj5E1*0}1#8ETOX6l%7cG@8#&c5l8wZC4?Pg<+Hp+nZ%J@9zoP)m;HpDj%^ zdE_WqJZ@BzsE7GO`{+k8vH9>DiFi5Ca`EAuKSXiYsMaPZYkgMloVQy1MV>R&32sV_ z(UJ5tleZvB@zNd|{m?RxtW0yYBUjbb40G%qV61bU`CbfpJ;G{`Xx!;kf@mg{X$h zR+nf;{0cpmtJ*C5H{=856P~^}jluLJsaDlP-3{6iE_2SvJKuCA$ewVql6kh?A7T>6Sk?!x?et^=~M~PT;GW9RV_cv4e zP1NA0wD^$Tg`)Uo^BN--zrg`Qc6Ild5LD&)_Ud@4V+(9DrkF&e8FmoMA@SLX=CxYT zC3a=bHHG8e3}!&(nNlV{!trZv%Z+-ilFPIwNrw`tIXv3%i4`hqS7+3<- z9fXOoR}Ee1|G2Onkm4>=oPiKp~ z$Hz>g%I4tVHr|z0F!=V+zDhkz1Jb+uGSR!B*D1pq(nB=zZ_caMech6jcDM1RzALNH z2O5%e{A^%`H=Cj3(eB#4Qd{%1_1ZX(VPm(WN@WsRwtg!v%CW5&nN>-*A_Hg%9}b=z z`22Fy>a*p7UE7voYOtl%{7g6QwXIGHJPr@~t#;yB+8x3=(~>1fLw)SB(HB|b?HvG3 z&6a$F;ga5862t4{flOXxoaQh}NB1vyOXPhEGIT0cOyzV6LO7`mq=Q4VKZf%&L689Z zH8bCEzNw@vl~D&X>$-^pWWp#~{lLS6>V zi30JBaiHJvw2obaeSjy*f9!Fx0zlAtWS0lFkAE?x|LK0Q5Ms38AvPYb&8`uRR^86E(OTT=gz{>cDP f?f?zx^U>+q(uhm6GT;k95Tx>0^HKFfs~7(Zm8aqu literal 0 HcmV?d00001