什么是ZooKeeperZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。 ZooKeeper的目标就是封装好复杂易出错的关键服务,将简单易用的接口和性能高效、功能稳定的系统提供给用户。 Rabbit ZooKeeper Extensions 该项目使用了 Apache ZooKeeper .NET async Client 组件,除提供了基本的zk操作,还额外封装了常用的功能以便让.net开发者更好的使用zookeeper。 提供的功能 session过期重连 永久watcher 递归删除节点 递归创建节点 跨平台(支持.net core) 使用说明 创建连接 IZookeeperClient client = new ZookeeperClient(new ZookeeperClientOptions         {             ConnectionString = "172.18.20.132:2181",             BasePath = "/", //default value             ConnectionTimeout = TimeSpan.FromSeconds(10), //default value             SessionTimeout = TimeSpan.FromSeconds(20), //default value             OperatingTimeout = TimeSpan.FromSeconds(60), //default value             ReadOnly = false, //default value             SessionId = 0, //default value             SessionPasswd = null //default value         }); 创建节点 var data = Encoding.UTF8.GetBytes("2016"); //快速创建临时节点 await client.CreateEphemeralAsync("/year", data); await client.CreateEphemeralAsync("/year", data, ZooDefs.Ids.OPEN_ACL_UNSAFE); //快速创建永久节点 await client.CreatePersistentAsync("/year", data); await client.CreatePersistentAsync("/year", data, ZooDefs.Ids.OPEN_ACL_UNSAFE); //完整调用 await client.CreateAsync("/year", data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL); //递归创建 await client.CreateRecursiveAsync("/microsoft/netcore/aspnet", data, CreateMode.PERSISTENT); 获取节点数据 IEnumerable data = await client.GetDataAsync("/year"); Encoding.UTF8.GetString(data.ToArray()); 获取子节点 IEnumerable children= await client.GetChildrenAsync("/microsoft"); 判断节点是否存在 bool exists = await client.ExistsAsync("/year"); 删除节点 await client.DeleteAsync("/year"); //递归删除 bool success = await client.DeleteRecursiveAsync("/microsoft"); 更新数据 Stat stat = await client.SetDataAsync("/year", Encoding.UTF8.GetBytes("2017")); 订阅数据变化 await client.SubscribeDataChange("/year", (ct, args) => {     IEnumerable currentData = args.CurrentData;     string path = args.Path;     Watcher.Event.EventType eventType = args.Type;     return Task.CompletedTask; }); 订阅子节点变化 await client.SubscribeChildrenChange("/microsoft", (ct, args) => {     IEnumerable currentChildrens = args.CurrentChildrens;     string path = args.Path;     Watcher.Event.EventType eventType = args.Type;     return Task.CompletedTask; }); FAQ 什么时候会触发 "SubscribeDataChange" 事件 ? 在以下情况下会触发通过 "SubscribeDataChange" 方法订阅的事件: 节点被创建 节点被删除 节点数据发生改变 zk连接重连成功 什么时候会触发 "SubscribeChildrenChange" 事件 ? 在以下情况下会触发通过 "SubscribeChildrenChange" 方法订阅的事件: 节点被创建 节点被删除 节点子节点发生改变 zk连接重连成功 如何在 "xxxxChange" 事件中区分节点的状态 ? 在事件触发参数会有个类型为 "EventType" 的属性 "Type",通过该属性可以清楚的区分出节点变更的原因。 为什么要写这个程序,它与 "ZooKeeperEx" 有什么区别 ? 官方提供的组件,只提供了基本的api,在正常的zk使用情景中需要做非常复杂的事情,滋生出很多额外的代码并且不能保证其执行的正确性。 在java语言中也有对官方zk进行封装的包 ZKClient,当前组件也是参考了这个项目。具体组件包提供了什么功能请参考 "提供的功能" 这一节。   更新介绍,详见作者博客:http://www.cnblogs.com/ants/p/6209773.html    标签:.net
2024-04-24 09:19:55 29KB 开源项目
1
linux操作系统的jdk8 .tar.gz包 jdk-8u321-linux-x64.tar
2024-04-12 18:45:34 139.35MB linux zookeeper 运维 分布式
1
该资源包包含了zookeeper,Kafka,gpmall-repo包以及搭建所需要的全部资源。单节点在线商城通常是指一个简单的、单一实例的在线商城系统,它运行在一个服务器节点上。这种系统通常用于小型的电子商务业务或者用于学习和测试的目的。要搭建一个单节点在线商城系统,你可以考虑以下步骤: 选择合适的电子商务平台:选择一个适合你需求的开源电子商务平台,比如 Magento、WooCommerce、OpenCart 等 准备服务器环境:在你的服务器上安装并配置合适的 web 服务器(比如 Nginx 或 Apache)、数据库(比如 MySQL 或 PostgreSQL)以及 PHP 或其他必要的后端语言环境。 安装和配置选定的电子商务平台 添加商品和设置商城参数:使用平台提供的管理界面,添加商品信息,设置商城的基本参数,比如配送方式、支付方式等 测试商城功能:在搭建完毕后,对商城进行功能测试,确保用户可以浏览商品、下订单并完成支付等基本操作。 部署安全策略
2024-04-11 17:10:23 573.07MB zookeeper kafka Linux docker
1
1.自动向zookeeper注册本机信息,同步负载状态 2.自动从zookeeper同步上游服务器信息 3.获取本机系统信息,cpu使用率,内存使用率,nginx连接数同步到zookeeper csdn:http://blog.csdn.net/rushroom
2024-01-17 22:57:24 20KB nginx zookeeper system info
1
自己开发的一个zookeeper可视化工具,用于zookeeper节点的增删查等功能
2024-01-10 21:54:29 8.88MB zookeeper 可是化工具 javaFx zktools
1
zookeeper-3.4.14.tar.zip zookeeper-3.4.14.tar.zip zookeeper-3.4.14.tar.zip zookeeper-3.4.14.tar.zip
2023-12-20 13:58:10 35.85MB zookeeper
1
前 言 大数据学习路线 大数据技术栈思维导图 大数据常用软件安装指南 一、Hadoop 分布式文件存储系统:HDFS 分布式计算框架:MapReduce 集群资源管理器:YARN 单机伪集群环境搭建 集群环境搭建 常用 Shell 命令 Java API 的使用 基于 Zookeeper 搭建 Hadoop 高可用集群 二、Hive 简介及核心概念 Linux 环境下 Hive 的安装部署 CLI 和 Beeline 命令行的基本使用 常用 DDL 操作 分区表和分桶表 视图和索引 常用 DML 操作 数据查询详解 三、Spark Spark Core Spark SQL Spark Streaming 五、Flink 核心概念综述 开发环境搭建 Data Source Data Transformation Data Sink 窗口模型 状态管理与检查点机制 Standalone 集群部署 六、HBase 简介 系统架构及数据结构 基本环境搭建 集群环境搭建 常用 Shell 命令 Java API 过滤器详解 可显示字数有限,详细内容请看资源。
2023-12-20 09:06:41 20.75MB kafka kafka zookeeper zookeeper
1
zookeeper的应用Linux安装包,直接解压安装成功
2023-06-25 10:40:10 20.81MB zookeeper
1
徐老师大数据培训Hadoop+HBase+ZooKeeper+Spark+Kafka+Scala+Ambari
2023-04-27 21:21:38 49B Hadoop
1
kafka2.4.0+zookeeper+kafka-connect集成安装包
2023-04-19 14:23:19 74.6MB zookeeper zookeeper kafka kafka
1