【问题标题】:How to create a znode asynchronously in Apache Curator如何在 Apache Curator 中异步创建 znode
【发布时间】:2017-05-19 05:58:47
【问题描述】:

使用 Curator 的 Fluent API,我们可以通过调用类似的方法来同步创建一个 znode:

client.create().withMode(CreateMode.PERSISTENT).forPath("/mypath", new byte[0]);

我想知道我们如何在指定创建模式的同时异步执行相同的操作?

【问题讨论】:

    标签: apache apache-zookeeper apache-curator


    【解决方案1】:

    我们可以在指定创建模式的同时异步执行给定的创建操作,如下所示,

        client.create()
              .withMode(CreateMode.PERSISTENT)
              .inBackground()
              .forPath("/mypath", new byte[0]);
    

    【讨论】:

      【解决方案2】:

      如果您使用的是 Java 8 和 ZooKeeper 3.5.x,那么最新版本的 Curator(注意:我是主要作者)具有用于异步的新 DSL。你可以在这里阅读:http://curator.apache.org/curator-x-async/index.html

      例如

      AsyncCuratorFramework async = AsyncCuratorFramework.wrap(client);
      async.checkExists().forPath(somePath).thenAccept(stat -> mySuccessOperation(stat));
      

      【讨论】:

      • 就我而言,我使用的是 Zookeeper 3.4.10。和馆长2.9.X
      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2020-08-06
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2019-03-12
      • 1970-01-01
      相关资源
      最近更新 更多