如上图，ES的集群分为：Master Node,Coordinate Node,Ingest Node,Data Node
Curator 是 Elastic 官方发布的一个管理 Elasticsearch 索引的工具，可以完成许多索引生命周期的管理工作，例如清理创建时间超过7天的索引、每天定时备份指定的索引、定时将索引从热节点迁移至冷节点等等。那么今天我们就来讲讲Curator的入门、操作、使用.
随着时间的推移，Elasticsearch中的数据量可能会迅速增长，这可能会导致存储空间的不足和查询性能的下降。为了解决这个问题，我们需要定期删除旧的、不再需要的数据。而Apache Curator是一个强大的工具，可以帮助我们轻松地管理Elasticsearch索引和快照，从而实现旧数据的自动删除。
common-base中的pom文件引入id-generator和id-generator-core的maven依赖
使用Curator也可以简化Ephemeral Node (临时节点)的操作。Curator也提供ZK Recipe的分布式队列实现。 利用ZK的 PERSISTENTSEQUENTIAL节点， 可以保证放入到队列中的项目是按照顺序排队的。 如果单一的消费者从队列中取数据， 那么它是先入先出的，这也是队列的特点。 如果你严格要求顺序，你就的使用单一的消费者，可以使用leader选举只让leader作为唯一的消费者。 但是， 根据Netflix的Curator作者所说， ZooKeeper真心不适合做Queu
如果没有基于时间创建索引，单一索引借助delete_by_query结合时间戳，会越删磁盘空间越紧张，以至于对自己都产生了怀疑？
在项目初期,基于quartz我们做了一个原始的job调度服务,用以执行我们的定时任务,但是随着业务的扩充,对性能及稳定性有了更高的要求.
Curator-Framework是ZooKeeper Client更高的抽象API，最佳核心的功能就是自动连接管理:
PS：只是个工具，apache的顶级项目，可以通过源码来学习。在文章上边提供了源码。
Apache Curator是一个比较完善的ZooKeeper客户端框架，通过封装的一套高级API 简化了ZooKeeper的操作。通过查看官方文档，可以发现Curator主要解决了三类问题：
Apache Curator是用于Apache ZooKeeper（一种分布式协调服务）的Java / JVM客户端库。
Curator是一个用来管理Elasticsearch索引的工具，使用它可以管理需要删除或保留的索引数据。
10 扩展ELK ---- Elasticsearch插件和工具 用于索引管理的Curator Curator是一个有助于管理es索引的重要工具。随着数据的增加，它变得非常重要，可以管理各种需要保留的数据和删除的数据。Curator可以用来删除旧的索引并优化系统 删除索引和快照 关闭索引 打开已关闭的索引 显示索引和快照 从别名中添加或删除索引 索引优化 更改索引分片的副本数量 Curator命令 curator [FLAGS] COMMAND [FLAGS] SUBCOMMAND [FLAGS] 删除
原因: Elastic-Job项目基于开源产品Quartz和Zookeeper及其客户端Curator进行二次开发，如果与新版的Spring Boot一起使用，会出现Curator的版本冲突。
本文介绍了如何使用Curator实现分布式协调，包括Leader选举、分布式锁和分布式队列。首先介绍了Leader选举的原理和常用算法，然后通过实例展示了如何使用Curator实现分布式协调。最后，总结了Curator在分布式协调中的应用场景和注意事项。
client端会对某个znode 注册一个watcher事件，当该znode发生变化时，这些client会收到ZooKeeper的通知，然后client可以根据znode变化来做出业务上的改变等。
所以需要在maven的pom.xml文件添加上相应的maven依赖就可以啦，此处添加curator-framework和curator-recipes
https://curator.apache.org/getting-started.html
Watcher 监听机制是 Zookeeper 中非常重要的特性，我们基于 zookeeper 上创建的节点，可以对这些节点绑定监听 事件，比如可以监听节点数据变更、节点删除、子节点状态变更等事件，通过这个事件机制，可以基于 zookeeper 实现分布式锁、集群管理等功能 watcher 特性：当数据发生变化的时候， zookeeper 会产生一个 watcher 事件，并且会发送到客户端。但是客户端 只会收到一次通知。如果后续这个节点再次发生变化，那么之前设置 watcher 的客户端不会再次收到消息。（watcher 是一次性的操作）。 可以通过循环监听去达到永久监听效果
这一篇文章我们将学习使用Curator来实现计数器。 顾名思义，计数器是用来计数的, 利用ZooKeeper可以实现一个集群共享的计数器。 只要使用相同的path就可以得到最新的计数器值， 这是由ZooKeeper的一致性保证的。Curator有两个计数器， 一个是用int来计数，一个用long来计数。 SharedCount 这个类使用int类型来计数。 主要涉及三个类。 SharedCount SharedCountReader SharedCountListener SharedCount代表计数器，
Apache Curator is a Java client for Apache Zookeeper, the popular coordination service for distributed applications.
本篇博客是分布式利器Zookeeper系列的最后一篇，涉及的话题是：Zookeeper分布式锁的代码实现、zkclient的使用、Curator框架介绍等。
Curator Framework是一个针对zookeeper做的搞层次的API，极大地简化了zookeeper的使用。它基于zookeeper构建了很多功能，处理复杂的链接管理，重试操作。下面是它的一些特点：
Curator是netflix公司开源的一套zookeeper客户端，目前是Apache的顶级项目。与Zookeeper提供的原生客户端相比，Curator的抽象层次更高，简化了Zookeeper客户端的开发量。Curator解决了很多zookeeper客户端非常底层的细节开发工作，包括连接重连、反复注册watcher和NodeExistsException 异常等，对于我们日常 ZooKeeper 服务开发进行了详细的封装，例如 Leader 选举、分布式计数器、分布式锁。这就减少了技术人员在使用 ZooKeeper 时的大部分底层细节开发工作。
Curator是netflix公司开源的一套zookeeper客户端，Apache的顶级项目
Dubbo 支持 zkclient 和 curator 两种 Zookeeper 客户端实现：
这里操作Zookeeper的JavaAPI使用的是一套zookeeper客户端框架 Curator ，解决了很多Zookeeper客户端非常底层的细节开发工作 。
想到删除，基础认知是delete，细分为删除文档（document）和删除索引；要删除历史数据，基础认知是：删除了给定条件的数据，用delete_by_query。 实际操作发现：
使用Curator也可以简化Ephemeral Node (临时节点)的操作。 临时节点驻存在ZooKeeper中，当连接和session断掉时被删除。 比如通过ZooKeeper发布服务，服务启动时将自己的信息注册为临时节点，当服务断掉时ZooKeeper将此临时节点删除，这样client就不会得到服务的信息了。 PersistentEphemeralNode类代表临时节点。 通过下面的构造函数创建： public PersistentEphemeralNode(CuratorFramework clie
一，基本介绍 Curator Framework是一个针对zookeeper做的搞层次的API，极大地简化了zookeeper的使用。它基于zookeeper构建了很多功能，处理复杂的链接管理，重试操作。下面是它的一些特点： 1，自动连接管理。 A),存在的潜在错误情况,需要ZooKeeper客户端创建连接和/或重试操作。Curator 自动和透明（主要）处理这些情况。 B),监视NodeDataChanged事件，并根据需要调用updateServerList（）。 C),Watches 会被Curato
过去几年，创作经济呈爆炸式增长，正如很多像我这样的人目前正在创作这篇文章。我们每一个人都可以归类到知识经济的创作者或者消费者群体中，这已经成为很多人的常识。但Brian Solis在2011年的文章《Curation经济和信息商务的3C模型》中揭露了真相：在创作者和消费者之间存在强大的Curators（3C之一）。
Leader Election Barriers Queues Locks Two-phased Commit 其它应用如Name Service, Configuration, Group Membership 在实际使用ZooKeeper开发中，我们最常用的是Apache Curator。 它由Netflix公司贡献给Apache，目前版本2.7.0。 相信你在使用ZK API开发时会遇到让人头疼的几个问题，ZK连接管理、SESSION失效等一些异常问题的处理，Curator替我们解决了这些问题，通过对
前面介绍了 Zookeeper 集群 ZAB 协议、配置中心、注册中心、数据与存储、会话与事务管理、分布式锁等相关的知识点，今天我将详细的为大家介绍 zookeeper 开源客户端相关知识，希望大家能够从中收获多多！如有帮助，请点在看、转发支持一波！！！
这里就体现了用Cutaotr的好处了,不需要先创建父才创建子,可以设置检测需要父时候却没有的请看下自动创建
Curator是netflix公司开源的一套zookeeper客户端，目前是Apache的顶级项目。和ZK的原生客户端相比，Curator的抽象层次要更高，同时简化了ZK的常用功能开发量，比如Curator自带连接重试、反复注册Watcher、NodeExistsException 异常处理等等。
由于公司zabbix的历史数据存储在elasticsearch中，有个需求是尽可能地把监控的历史数 据存储的长一点，最好是一年，目前的情况是三台ES节点，每天监控历史数据量有5G，目前最多可存储一个月的数据，超过30天的会被定时删除，每台内存分了8G，且全部使用机械硬盘，主分片为5，副本分片为1，查询需求一般只获取一周的历史数据，偶尔会有查一 个月到两个月历史数据的需求。
“分布式锁”是用来解决分布式应用中“并发冲突”的一种常用手段，实现方式一般有基于zookeeper及基于redis二种
本文用Java api开发一些基本的程序，从而搞清楚zk的一些基本用法。 zk客户端在连接 zk 服务器需要实例化一个org.apache.zookeeper.ZooKeeper对象，然后调用该类提供的接口与Zookeeper服务器进行交互。如果不指明，该类的所有方法均是线程安全的。一旦 zk客户端与服务器建立连接，客户端就会被分配一个会话ID(session ID)，客户端会定期向服务器端发送心跳以保持该会话有效。只要客户端会话有效，应用程序可以调用zk客户端的接口与服务器端进行交互。
Curator是netflix公司开源的一套zookeeper客户端，目前是Apache的顶级项目。与Zookeeper提供的原生客户端相比，Curator的抽象层次更高，简化了Zookeeper客户端的开发量。Curator解决了很多zookeeper客户端非常底层的细节开发工作，包括连接重连、反复注册wathcer和NodeExistsException 异常等。
本文将向您介绍，如何在腾讯云的无服务器函数（scf）中，使用curator工具，创建ES过期索引的自动删除定时任务。
锁 分布式的锁全局同步， 这意味着任何一个时间点不会有两个客户端都拥有相同的锁。 可重入锁Shared Reentrant Lock 首先我们先看一个全局可重入的锁。 Shared意味着锁是全局可见的， 客户端都可以请求锁。 Reentrant和JDK的ReentrantLock类似， 意味着同一个客户端在拥有锁的同时，可以多次获取，不会被阻塞。 它是由类InterProcessMutex来实现。 它的构造函数为： public InterProcessMutex(CuratorFramework clie
CuratorFramework是Netflix公司开源的一套Zookeeper客户端框架，它作为一款优秀的ZooKeeper客户端开源工具，主要提供了对客户端到服务的连接管理和连接重试机制，以及一些扩展功能，它解决了很多ZooKeeper客户端非常底层的细节开发工作。
之前写过一遍但由于排版的问题将那边文章重新排版编排了一下，后续再研究下zookeeper的监听图片复制
分布式开源协调系统，数据模型简单，可以实现同步，配置管理，分组管理，分命名空间管理等。
Wanger，Zabbix运维工程师，熟悉Zabbix开源监控系统的架构，乐于分享Zabbix运维经验，个人公众号“没有故事的陈师傅”
官方文档：https://www.elastic.co/guide/en/elasticsearch/client/curator/current/actions.html
1.ExponentialBackoffRetry:重试指定的次数, 且每一次重试之间停顿的时间逐渐增加.2.RetryNTimes:指定最大重试次数的重试策略3.RetryOneTime:仅重试一次4.RetryUntilElapsed:一直重试直到达到规定的时间
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
