Apache Curator

Apache Curator 4.3.0 发布了。Apache Curator 是用于 Apache ZooKeeper 的 Java / JVM 客户端库，是一个分布式协调服务。 Apache Curator 内置高级 API 框架和实用程序，可使 Apache ZooKeeper 更易于使用和可靠。它还包含常用的配方案例和扩展，如服务发现和 Java 8 异步 DSL。 4.3.0 版本主要进行了一些 bug 修复： [CURATOR-530] - 关于 InterProcessSemaphoreMutex 的文档具有误导性 [CURATOR-541] - BaseClassForTests 中...

Apache Curator 是用于 Apache ZooKeeper 的 Java / JVM 客户端库，是一个分布式协调服务。 Apache Curator 内置高级 API 框架和实用程序，可使 Apache ZooKeeper 更易于使用和可靠。它还包含常用的配方案例和扩展，如服务发现和 Java 8 异步 DSL。 全新的 4.0.0 版本包含重要的 Bug 修复和新特性： 支持 TTL Nodes 新的强类型，modeled DSL 数据迁移 统一对 ZooKeeper 3.4.x 和 3.5.x 的支持 更多可查阅发行说明 下载地址： ht...

Apache Curator 今天发布两个新版本，分别是 2.10.0 和 3.1.0 。 其中 2.10.0 改进内容： Bug [CURATOR-208] - InterProcessSemaphoreV2 swallows InterruptedException [CURATOR-209] - Background retry falls into infinite loop of reconnection after connection loss [CURATOR-233] - Bug in double barrier [CURATOR-244] - Creating parents with ACLProvider puts wrong ACLs on znodes [CURATOR-278] - In transacti...

Apache Curator 3.0.0 发布，该版本带来的对 ZooKeeper 的新的动态配置 APIs 的兼容，更新内容如下： 子任务 [CURATOR-160] - Support Dynamic Reconfig [CURATOR-161] - Support Watcher Removal [CURATOR-162] - Support Local Sessions [CURATOR-214] - Support new create() APIs [CURATOR-215] - Support async multi/transaction APIs [CURATOR-217] - Use new Watcher Removal APIs in Curator Recipes [CURATOR-247] -...

Apache Curator 2.9 发布，此版本改进了 Java 库，使得 Apache ZooKeeper 使用更简单更可靠。 更新内容： Bug 修复 [CURATOR-167] - All registered watchers should be cleared on close [CURATOR-218] - Race condition in client.blockUntilConnected() [CURATOR-224] - Locking Not Working with DistributedIdQueue [CURATOR-228] - A serious death cycle error(一个严重的死循环错误) [CURATOR-231] - TestDistributedQu...

Apache Curator 2.8.0 发布，此版本的 Apache Curator Java 库让 Apache Zookeeper 使用起来更方便，详细更新信息如下： Bug 修复： [CURATOR-154] - PersistentEphemeralNode May Fail to Apply Updated Data [CURATOR-164] - curator-x-discovery: unregisterService is not guaranteed to remove the service, due to reconnectListener concurrency issue [CURATOR-168] - Background protected mode incorrectly sets Eve...

Apache Curator 2.7.1 发布了，zookeeper 的客户端调用过于复杂，Apache Curator 就是为了简化zookeeper客户端调用而生，利用它，可以更好的使用zookeeper。 改进记录： Bug [CURATOR-175] - If zookeeper is down when discovery is started, it fails to register when the zookeeper comes up for the first time. [CURATOR-179] - Sequential path creation of /somepath/N throws exception [CURATOR-181] - discovery: r...

Apache Curator 2.7.0 发布，此版本现已提供下载，二进制包提供在 Maven 库。更新内容请看这里： Bug 修复 [CURATOR-42] - Background guaranteed delete considers NoNode to be a failed delete, and retries it [CURATOR-67] - Issue with default JSONInstanceSerializer for discovery service builder [CURATOR-71] - Error message in StandardLockInternalsDriver for retryable lock acquire error [CURATOR-79] - In...

Apache Curator 2.6.0 发布，此版本包括了一些新特性（curator RPC）和 bug 修复： Bug 修复： [CURATOR-110] - LeaderLatch does not complete if it is started without a connection to ZooKeeper [CURATOR-116] - Ordering of delayed distributed queue is inconsistent 改进： [CURATOR-93] - Have TransactionCreateBuilder implement Compressible [CURATOR-114] - TestingServer should expose restart() method. 新特...

Apache Curator 就是为了简化 zookeeper客户端调用而生，利用它，可以更好的使用zookeeper。 Apache Curator 2.4.2 发布了，改进内容包括： Bug [CURATOR-74] - Documentation on InterProcessMutex is misleading [CURATOR-95] - TestQueueSharder test fails [CURATOR-97] - Adding back ConnectionStateListener to PersistentEphemeralNode recipe [CURATOR-98] - Avoid erroneous 'Could not cancel' warning produced by ...

Apache Curator 2.4.0 发布，该版本主要是 bug 修复，包括： [CURATOR-53] - PersistentEphemeralNode does not work when ZK server are not available when the node is started [CURATOR-58] - ACLs support for ZKPaths.mkdirs() [CURATOR-72] - Background operations don't wait for connection timeout [CURATOR-75] - InterProcessSemaphoreV2 does not register changes to SharedCountReader while blocking [CURATOR...

Apache Curator 2.3.0 发布了，Apache Curator 就是为了简化zookeeper客户端调用而生，利用它，可以更好的使用zookeeper。 改进记录： Bug [CURATOR-8] - Possible mishandling of connection timeouts on large/shooty clusters [CURATOR-9] - DefaultTracerDriver should call log.isTraceEnabled() [CURATOR-19] - InterProcessSemaphoreV2.getParticipantNodes throws NoNodeException [CURATOR-27] - PathChildrenCache c...

这个比较好理解，分布式数字，类似AtomicInteger系列，Curator有2个实现： 第一个： package curator.counters; import org.apache.curator.RetryPolicy; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFrameworkFactory; import org.apache.curator.framework.recipes.shared.SharedCount; import org.apache.curator.framework.recipes.shared.SharedCountList...

#### Curator包含了几个包 - curator-framework：对zookeeper的底层api的一些封装 - curator-client：提供一些客户端的操作，例如重试策略等 - curator-recipes：封装了一些高级特性，如：Cache事件监听、选举、分布式锁、分布式计数器、分布式Barrier等 ### CuratorFramework API > CuratorFramework使用Fluent风格的界面。使用CuratorFramework实例返回的构建器构造操作。当串联在一起时，这些方法形成了类似句子的陈述。 ##...

Curator uses Fluent Style. If you haven’t used this before, it might seem odd so it’s suggested that you familiarize yourself with the style. CuratorFramework are allocated from theCuratorFrameworkFactory. You only need one CuratorFramework object for each ZooKeeper cluster you are connecting to: RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3); CuratorFramework client =...

代码：：https://gitee.com/jly521/ZooKeeper-book.git 开源的ZooKeeper 客户端 封装了很多底层细节 Apache 顶级项目 还提供了ZooKeeper各种应用场景： Recipe共享锁服务 Master选举机制 分布式计数器 等等 创建会话 public static void main(String[] args) throws Exception{ RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3); CuratorFramework client = CuratorFrameworkFa...

Curator 提供的分布式锁用法，很简单： package curator.lock; import org.apache.curator.RetryPolicy; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFrameworkFactory; import org.apache.curator.framework.recipes.locks.InterProcessMutex; import org.apache.curator.retry.ExponentialBackoffRetry; public class InterProcessMutexDemo {   public ...

zookeeper最经典的用法，选举。Curator的实现有2个种： LeaderLatch： 这种是有阻塞的，就是大家一起上，谁先上了，就一直阻塞着，直到方法执行完成。如果执行结束，那么其他的兄弟就选一个出来。我觉得这种适合主备，比如开2 个 job，一个挂了另一个就上。 代码，这种代码最好是开2个eclipse看效果，顺序打开，看效果，再领悟： package curator.selector; import org.apache.curator.RetryPolicy; import org.apache.cura...

Service Discovery 服务发现，我以前不是很明白zookeeper怎么做集群，只知道注册啥的，突然有一天悟了，不得不佩服一套文件系统可以变化出很多伟大的应用。说说思路。 场景：提供一个分布式Restful 服务让客户端去调用，支持动态加减机器。 分析： server端并不复杂，启动webserver后，暴露http://url:8088/rs/xx 出去即可，那么会有如下几个： server1: http://192.168.50.11:8088/rs/xx server2: http://192.168.50.12:8088/...

Framework 比较简单，就是一些CRUD，Watch ： package curator.framework; import java.util.List; import org.apache.curator.RetryPolicy; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFrameworkFactory; import org.apache.curator.retry.ExponentialBackoffRetry; import org.apache.zookeeper.CreateMode; public class FrameworkDemo {   public s...

Service Discovery 服务发现，我以前不是很明白zookeeper怎么做集群，只知道注册啥的，突然有一天悟了，不得不佩服一套文件系统可以变化出很多伟大的应用。说说思路。 场景：提供一个分布式Restful 服务让客户端去调用，支持动态加减机器。 分析： server端并不复杂，启动webserver后，暴露http://url:8088/rs/xx 出去即可，那么会有如下几个： server1: http://192.168.50.11:8088/rs/xx server2: http://192.168.50.12:8088/...

#Guava#居然没有向后兼容，由其第三库再依赖guava后，极易再项目里造成jar冲突，真实头疼，请教各位大佬有没有好的处理方式

我用curator监听一个节点（不包括子节点）的变化 代码如下： public class Test {   static void watch(CuratorFramework cf, String path)throws Exception   {     NodeCache cn = new NodeCache(cf, path);     cn.getListenable().addListener(new NodeCacheListener()     {       public void nodeChanged() throws Exception       {         System.out.println("===============");       }     });     cn.start(true);   }   public static voi...

运行选举程序，报错。哪位大神帮忙看下。