怎么才能让自己做的网站上传到百度搜关键字可以搜到,网页版微信二维码不出来,自适应网站举例,什么是网页ui设计欢迎来到我的博客#xff0c;代码的世界里#xff0c;每一行都是一个故事 ZooKeeper初探#xff1a;分布式世界的守护者 前言Zookeeper的概述分布式系统中的角色和作用#xff1a; Zookeeper的数据模型Znode的概念和层次结构#xff1a;Znode的类型和应用场景#xff1a;… 欢迎来到我的博客代码的世界里每一行都是一个故事 ZooKeeper初探分布式世界的守护者 前言Zookeeper的概述分布式系统中的角色和作用 Zookeeper的数据模型Znode的概念和层次结构Znode的类型和应用场景应用场景 Zookeeper的基本原理ZooKeeper的基本原理 Zookeeper的基础操作监听器的使用和事件通知 前言 在分布式系统的大舞台上ZooKeeper如同一位悠扬的钢琴师在这场音乐中谱写着各个节点的和谐旋律。本篇文章将带你进入这个神奇的音乐厅解析ZooKeeper的基础知识让你更加熟悉这位分布式系统的基石。 Zookeeper的概述 ZooKeeper 是一个开源的分布式协调服务提供了一个高度可靠且高性能的协调基础用于构建分布式系统。它是一个分布式的、开放源代码的分布式应用程序协调服务是 Apache Hadoop 和 Apache HBase 等分布式系统的关键组件之一。 ZooKeeper 的设计目标主要包括 一致性 ZooKeeper 提供的服务应该在所有节点上保持一致即对于所有客户端来说ZooKeeper 提供的数据应该是一致的。 可靠性 ZooKeeper 应该是高可用、高性能且可靠的能够应对网络分区、节点故障等情况。 实时性 ZooKeeper 能够在一定时间内通常是毫秒级别完成客户端的请求保证及时响应。 简单性 ZooKeeper 提供简单的 API易于使用和理解。 分布式系统中的角色和作用 在分布式系统中ZooKeeper 扮演了关键的角色主要有以下作用 协调服务 ZooKeeper 提供了一致性和可靠性的协调服务用于管理和协调分布式系统中的各个节点确保它们能够同步工作。 配置管理 分布式系统中的配置信息可以存储在 ZooKeeper 中各个节点通过监听配置节点的变化来动态调整自己的配置。 命名服务 ZooKeeper 提供了一个命名空间可以用于存储节点的名称和相关的信息实现分布式系统中的命名服务。 分布式锁 ZooKeeper 提供了分布式锁的实现通过在 ZooKeeper 中创建临时节点可以实现分布式环境下的协同工作例如实现互斥访问共享资源。 分布式队列 ZooKeeper 的有序节点可以用来构建分布式队列实现任务的有序执行。 分布式通知 ZooKeeper 提供了监视节点的功能当节点的状态发生变化时可以通知相关的节点。 总体而言ZooKeeper在分布式系统中起到了保障一致性、提供可靠性、管理配置、实现协调和解决分布式系统中常见问题的作用是许多分布式系统的基础组件之一。 Zookeeper的数据模型 在ZooKeeper中数据被组织成一个树状结构类似于文件系统的目录结构。ZooKeeper的基本数据单元是Znode每个Znode都可以存储数据同时可以有子节点。 Znode的概念和层次结构 ZnodeZooKeeper节点 是ZooKeeper中的基本数据单元。每个Znode都有一个唯一的路径类似于文件系统中的路径路径的形式类似于/path/to/znode。 层次结构 ZooKeeper的Znodes形成了一个层次结构类似于文件系统的目录结构。根节点是一个特殊的Znode其路径为/。每个Znode可以有多个子节点形成树状结构。 Znode的类型和应用场景 Znode可以有不同的类型这些类型决定了Znode的特性和用途。主要的Znode类型包括 持久节点Persistent Znode 持久节点一旦创建将一直存在直到显式删除。这种节点常用于存储配置信息、静态数据等。 /path/to/persistentZnode临时节点Ephemeral Znode 临时节点的生命周期与创建它的客户端会话相关。如果客户端会话结束临时节点将被自动删除。这种节点通常用于表示临时状态或临时任务。 /path/to/ephemeralZnode有序节点Sequential Znode 有序节点在节点名称后会追加一个递增的序号。这种节点类型常用于实现分布式队列或确保全局顺序。 /path/to/sequentialZnode0001 /path/to/sequentialZnode0002有序临时节点Sequential Ephemeral Znode 结合了有序节点和临时节点的特性适用于需要临时性和有序性的场景。 /path/to/sequentialEphemeralZnode0001 /path/to/sequentialEphemeralZnode0002应用场景 配置管理 持久节点用于存储静态配置信息而临时节点可以用于动态配置信息。 命名服务 Znode的路径可以被视为唯一标识用于实现分布式系统中的命名服务。 分布式锁 通过创建有序临时节点可以实现分布式锁的机制确保全局顺序和避免死锁。 任务分配 可以使用有序节点来实现分布式系统中任务的有序分配。 Leader选举 通过ZooKeeper的特性可以实现分布式系统中的Leader选举。 总体而言ZooKeeper的数据模型提供了灵活而强大的工具适用于各种分布式系统场景。 Zookeeper的基本原理 ZooKeeper的基本原理 事务日志和快照 事务日志Transaction Log ZooKeeper使用事务日志来记录所有的更新操作。每个客户端的请求都会被转化为一个事务并将该事务写入事务日志以确保数据的持久性。 快照Snapshot 为了提高读取性能ZooKeeper定期生成快照该快照包含了当前数据的一个快照。当事务日志变得太大时ZooKeeper会截断日志将截断点之前的事务应用到快照中然后继续记录后续的事务。这样新的客户端可以从最近的快照开始然后应用在快照之后的事务以恢复到当前状态。 ZAB协议ZooKeeper Atomic Broadcast ZooKeeper使用ZAB协议来保证分布式系统中的数据的原子广播确保所有节点看到的顺序相同。ZAB协议主要分为两个阶段Leader选举和事务广播。 Leader选举 在ZooKeeper集群中有一个节点被选为Leader负责协调和处理客户端的请求。Leader选举过程是ZAB协议的第一个阶段它确保只有一个节点成为Leader。Leader负责向其他节点广播事务保持一致性。 事务广播 一旦Leader选举完成Leader开始接收客户端的写请求并通过ZAB协议将这些写请求广播给所有节点。每个节点按照相同的顺序应用这些事务确保在整个集群中数据的一致性。 原子性 ZAB协议保证了事务的原子性。所有节点按照相同的顺序接收和应用事务确保在整个集群中对数据的修改是原子的。 持久性 通过事务日志和快照ZAB协议保证了数据的持久性。事务日志记录了每个事务的详细信息而快照则提供了一种快速恢复到当前状态的机制。 ZooKeeper的基本原理和ZAB协议确保了ZooKeeper在分布式系统中提供了高可用、一致性和持久性的服务使其成为分布式系统中常用的协调服务。 Zookeeper的基础操作 创建Znode 使用ZooKeeper客户端API调用create方法可以创建一个Znode。 示例 String znodePath /myZnode; byte[] data Hello, ZooKeeper!.getBytes(); zooKeeper.create(znodePath, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);读取Znode 使用ZooKeeper客户端API调用getData方法可以读取一个Znode的数据。 示例 String znodePath /myZnode; Stat stat new Stat(); byte[] data zooKeeper.getData(znodePath, false, stat); String dataString new String(data); System.out.println(Data: dataString);更新Znode 使用ZooKeeper客户端API调用setData方法可以更新一个Znode的数据。 示例 String znodePath /myZnode; byte[] newData Updated data.getBytes(); int version zooKeeper.exists(znodePath, true).getVersion(); zooKeeper.setData(znodePath, newData, version);删除Znode 使用ZooKeeper客户端API调用delete方法可以删除一个Znode。 示例 String znodePath /myZnode; int version zooKeeper.exists(znodePath, true).getVersion(); zooKeeper.delete(znodePath, version);监听器的使用和事件通知 ZooKeeper提供了监听机制允许客户端在Znode发生变化时得到通知。可以使用Watcher接口实现监听器并注册到ZooKeeper客户端。 设置监听器 使用getData、exists等方法时可以通过在方法调用中传递Watcher对象来设置监听器。 示例 String znodePath /myZnode; Stat stat new Stat(); Watcher watcher new MyWatcher(); // 自定义的Watcher实现 byte[] data zooKeeper.getData(znodePath, watcher, stat);Watcher接口的实现 实现Watcher接口并覆盖process方法以定义监听事件发生时的处理逻辑。 示例 public class MyWatcher implements Watcher {Overridepublic void process(WatchedEvent event) {System.out.println(Event type: event.getType());System.out.println(Znode path: event.getPath());// 处理事件的逻辑} }事件通知 当Znode发生变化时注册的监听器将接收到通知然后可以在process方法中执行相应的逻辑。事件类型包括NodeCreated、NodeDeleted、NodeDataChanged等。 这样通过监听器和事件通知机制ZooKeeper客户端可以实时感知Znode的变化从而在分布式环境中进行协同工作和协调操作。