com.github.zkclient.ZkClient.createPersistent()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.0k)|赞(0)|评价(0)|浏览(141)

本文整理了Java中com.github.zkclient.ZkClient.createPersistent()方法的一些代码示例,展示了ZkClient.createPersistent()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.createPersistent()方法的具体详情如下:
包路径:com.github.zkclient.ZkClient
类名称:ZkClient
方法名:createPersistent

ZkClient.createPersistent介绍

暂无

代码示例

代码示例来源:origin: adyliu/jafka

  1. private static void createParentPath(ZkClient zkClient, String path) {
  2. String parentDir = path.substring(0, path.lastIndexOf('/'));
  3. if (parentDir.length() != 0) {
  4. zkClient.createPersistent(parentDir, true);
  5. }
  6. }

代码示例来源:origin: adyliu/jafka

  1. public static void makeSurePersistentPathExists(ZkClient zkClient, String path) {
  2. if (!zkClient.exists(path)) {
  3. zkClient.createPersistent(path, true);
  4. }
  5. }

代码示例来源:origin: adyliu/jafka

  1. public static void updatePersistentPath(ZkClient zkClient, String path, String data) {
  2. try {
  3. zkClient.writeData(path, Utils.getBytes(data));
  4. } catch (ZkNoNodeException e) {
  5. createParentPath(zkClient, path);
  6. try {
  7. zkClient.createPersistent(path, Utils.getBytes(data));
  8. } catch (ZkNodeExistsException e2) {
  9. zkClient.writeData(path, Utils.getBytes(data));
  10. }
  11. }
  12. }

代码示例来源:origin: adyliu/zkclient

  1. public void createPersistent(String path) {
  2. createPersistent(path, false);
  3. }

代码示例来源:origin: com.github.adyliu/zkclient

  1. public void createPersistent(String path) {
  2. createPersistent(path, false);
  3. }

代码示例来源:origin: com.github.adyliu/zkclient

  1. public void createPersistent(String path, boolean createParents) {
  2. try {
  3. create(path, null, CreateMode.PERSISTENT);
  4. } catch (ZkNodeExistsException e) {
  5. if (!createParents) {
  6. throw e;
  7. }
  8. } catch (ZkNoNodeException e) {
  9. if (!createParents) {
  10. throw e;
  11. }
  12. String parentDir = path.substring(0, path.lastIndexOf('/'));
  13. createPersistent(parentDir, createParents);
  14. createPersistent(path, createParents);
  15. }
  16. }

代码示例来源:origin: adyliu/zkclient

  1. public void createPersistent(String path, boolean createParents) {
  2. try {
  3. create(path, null, CreateMode.PERSISTENT);
  4. } catch (ZkNodeExistsException e) {
  5. if (!createParents) {
  6. throw e;
  7. }
  8. } catch (ZkNoNodeException e) {
  9. if (!createParents) {
  10. throw e;
  11. }
  12. String parentDir = path.substring(0, path.lastIndexOf('/'));
  13. createPersistent(parentDir, createParents);
  14. createPersistent(path, createParents);
  15. }
  16. }

相关文章