com.netflix.curator.utils.ZookeeperFactory类的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 11:17:31 33 4

@Override
  public ZooKeeper newZooKeeper(String connectString, int sessionTimeout, Watcher watcher, boolean canBeReadOnly) throws Exception
  {
    ZooKeeper zooKeeper = actualZookeeperFactory.newZooKeeper(connectString, sessionTimeout, watcher, canBeReadOnly);
    AuthInfo auth = authInfo.get();
    if ( auth != null )
    {
      zooKeeper.addAuthInfo(auth.scheme, auth.auth);
    }
    return zooKeeper;
  }
};

@Override
public ZooKeeper getZooKeeper() throws Exception
{
  synchronized(this)
  {
    if ( zooKeeperHandle == null )
    {
      connectionString = ensembleProvider.getConnectionString();
      zooKeeperHandle = zookeeperFactory.newZooKeeper(connectionString, sessionTimeout, watcher, canBeReadOnly);
    }
    helper = new Helper()
    {
      @Override
      public ZooKeeper getZooKeeper() throws Exception
      {
        return zooKeeperHandle;
      }
      @Override
      public String getConnectionString()
      {
        return connectionString;
      }
    };
    return zooKeeperHandle;
  }
}

33 4 0

• apache-curator - 使用 Apache Curator 观察领导层的变化

  有没有一种方法可以让我使用 Curator 来观察领导层的变化？当领导者改变时，我需要所有的追随者都知道这已经发生了，这样他们才能发现新的领导者是谁。追随者想知道领导者是谁，这似乎是一种标准，但我无法

• apache-curator - Apache Curator "connection string"是什么样的？

  给CuratorFrameworkFactory#newClient的连接字符串如何看起来像？到目前为止，我还没有在网上找到任何信息，JavaDoc 也没有告诉我正确的格式。 最佳答案 根据 this

• org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths类的使用及代码示例

  本文整理了Java中org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths类的一些代码示例，展示了ZKPaths类的具体用法。

• org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.getNodeFromPath()方法的使用及代码示例

  本文整理了Java中org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.getNodeFromPath()方法的一些代码示

• org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.deleteChildren()方法的使用及代码示例

  本文整理了Java中org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.deleteChildren()方法的一些代码示例

• Elasticsearch : Curator does not work

  我正在尝试来自策展人的基本代码 http://curator.readthedocs.io/en/4.0/examples.html 我尝试 import elasticsearch import c

• java - Curator - 如何知道当前节点是否是领导者

  只是想知道是否有任何 API 可以使用 Curator Framework 中的 CuratorFramework 类来知道特定节点是领导者。我正在使用 LeaderLatch，但即使 Node 是领

• java - Curator 交易运行时构建

  Apache Curator library for ZooKeeper 使用了一个很好的“流畅”语法。例如，要修改事务中的多个节点，代码如下所示: client.inTransaction().

• elasticsearch - Elasticsearch Curator:不按时间字符串显示索引

  我正在尝试使用CLI探索Elasticsearch策展人 https://www.elastic.co/guide/en/elasticsearch/client/curator/current/in

• elasticsearch - Elasticsearch Curator-删除除最新索引以外的索引

  使用Elasticsearch策展人，如何删除与模式匹配的所有索引，但最新的除外？ 我尝试使用filtertype: age，但似乎无法满足我的需要。 最佳答案 您需要两个过滤器:pattern(以匹

• elasticsearch - 运行 curator 以删除旧索引时出错

  我想删除超过 7 天的 Elasticsearch 索引。所以我安装了curator 4.2，因为我的elasticsearch版本是5.0.0(4.x之前的curator版本与elasticsear

• java - 重新连接后 Curator 互斥锁失败

  场景: 使用Curator实现分布式互斥体。如果已经获取互斥量的客户端由于网络故障而与 zk 服务器断开连接，则 Curator 将尝试重新连接。假设最终重连成功，但是最后一个 session 已经过

• apache-zookeeper - Curator 中的超时配置

  我创建了一个 Curator 客户端，如下所示: RetryPolicy retryPolicy = new RetryNTimes(3, 1000); CuratorFramewor

• java - Netflix Curator 交易错误

  创建路径时，我在以下代码中收到 NodeExists 错误。 CuratorTransaction transaction = curatorFramework.inTransaction(); tr

• regex - 如何在 Curator 过滤器上使用贪婪的正则表达式？

  我已将 Curator 设置为通过此过滤器删除旧的 Elasticsearch 索引: (...) filters: - filtertype: pattern kind: regex val

• java - Apache Curator 锁定食谱撤销

  我正在尝试测试 Apache Curator 中的可撤销锁定。我有两个尝试获取锁的线程。如果第一个测试获取了锁，第二个线程可以要求第一个线程释放锁，以便第二个线程可以获取它 Retry

• java - Apache Curator 双重锁定问题与多个服务

  我目前正在使用 Apache Curator 来外部化共享资源(数据库中的一行)的锁定。总结一下这个问题，我正在运行一个服务的 2 个实例(使用 Spring Boot)，我们将其称为服务 A，并调用

• java - Apache Curator 分布式锁

  我知道 Apache Curator 可以实现基于 zookeeper 的分布式锁功能。根据 Apache Curator 官方网站上发布的文档，它看起来非常容易使用。例如: RetryPolicy

• org.apache.curator.utils.ZKPaths类的使用及代码示例

  本文整理了Java中org.apache.curator.utils.ZKPaths类的一些代码示例，展示了ZKPaths类的具体用法。这些代码示例主要来源于Github/Stackoverflow/

• com.bazaarvoice.curator.dropwizard.ZooKeeperConfiguration类的使用及代码示例

  本文整理了Java中com.bazaarvoice.curator.dropwizard.ZooKeeperConfiguration类的一些代码示例，展示了ZooKeeperConfiguratio