org.jumbune.remoting.common.ZKUtils类的使用及代码示例-6ren

gpt4 book

didi

org.jumbune.remoting.common.ZKUtils类的使用及代码示例

转载作者：知者更新时间：2024-03-13 09:32:22

29

4

gpt4 key购买

nike

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

ZKUtils介绍

[英]This class ZKUtils contains utility methods to communicate with zookeeper.
[中]此类ZKUtils包含与zookeeper通信的实用方法。

代码示例

代码示例来源：origin: Impetus/jumbune

/**
 * Sets the agent node data on znode.
 *
 * @param nodePath the node path
 * @param agent the Agent
 */
public static void setAgentData(String nodePath, AgentNode agent) {
  try {
    String hosts = null;
    CuratorConnector connector = CuratorConnector.getInstance(hosts);
    String json = convertAgentToGson(agent);
    connector.setData(nodePath, json.getBytes(Charset.forName("UTF-8")));
  } catch (Exception e) {
    LOGGER.error(e.getMessage(), e);        
  }
}

代码示例来源：origin: Impetus/jumbune

/**
 * Gets the leader name node from zookeeper.
 * @param zkHosts 
 *
 * @return the leader name node from zookeeper
 */
public static byte[] getLeaderNameNodeFromZK(String[] zkHosts) {
  final int retryTimes = 10;
  byte[] nameHostName = null;
  int retryCount = 1;
  do {
    List<String> nameNodeNameList = getNodeChildrenList(zkHosts, ZKConstants.HADOOP_NODE_PATH);
    for (String nameNodeName : nameNodeNameList) {
      nameHostName = getActiveNameNode(zkHosts,
          ZKConstants.HADOOP_NODE_PATH + File.separator + nameNodeName + ZKConstants.ACTIVE_BREAD_CRUMB);
    }
    if (nameHostName == null) {
      try {
        LOGGER.warn("found active NN null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100 * retryCount);
      } catch (InterruptedException e) {
      }
    }
    retryCount++;
  } while (nameHostName == null && retryCount <= retryTimes);
  return nameHostName;
}

代码示例来源：origin: Impetus/jumbune

public static String getActiveNNHost(String[] zkHosts){
  byte[] activeHost = null;
  String activeNameNode = null ;
  activeHost = ZKUtils.getLeaderNameNodeFromZK(zkHosts);
  try {
    ActiveNodeInfo activeNodeInfo = PARSER.parsePartialFrom(activeHost);
    activeNameNode = activeNodeInfo.getHostname();
  } catch (InvalidProtocolBufferException e) {
    LOGGER.error(e);            
  }
  return activeNameNode;
}

代码示例来源：origin: Impetus/jumbune

/**
 * Checks if is leader agent on nn.
 *
 * @return true, if is leader agent on nn
 */
private boolean isLeaderAgentOnNN() {
  AgentNode agent = null;
  try {
    agent = ZKUtils.getLeaderAgentfromZK(zkHosts, haConf);
    if(agent == null) {
      return false;
    }
  } catch (ConnectException e) {
    logger.error(e.getMessage(), e); 
  }
  return agent.getHost().equals(ZKUtils.getActiveNNHost(zkHosts));
}

代码示例来源：origin: Impetus/jumbune

leaderAgentNode = getAgentData(zkHosts, ZKConstants.AGENT_LEADER_PATH);
boolean connectionFlag = true;
Socket socket = null;
  LOGGER.warn("connection failed for - " + leaderAgentNode.getHost()+":"+leaderAgentNode.getPort());
  connectionFlag = retryConnection(zkHosts, leaderAgentNode, haConf);		
} catch (IOException e) {
} finally {

代码示例来源：origin: Impetus/jumbune

/**
 * Gets the agent data from znode.
 * @param zkHosts 
 *
 * @param nodePath the node path
 * @return the agent node data
 */
public static AgentNode getAgentData(String[] zkHosts, String nodePath){		
  CuratorConnector connector = CuratorConnector.getInstance(zkHosts);
  byte data[] = null;
  final int retryTimes = 10;
  int retryCount = 1;
  AgentNode agent = null;
  try {
    do {
      data = connector.getDataBytes(nodePath);        
      if(data == null) {
        LOGGER.warn("found active Agent null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100*retryCount);
      }
    retryCount++;
    } while(data == null && retryCount <= retryTimes);
    agent = convertGsonToAgent(new String(data, Charset.defaultCharset()));
  } catch (Exception e) {
    LOGGER.error(e.getMessage(), e);
  }
  return agent;
}

代码示例来源：origin: Impetus/jumbune

private static boolean retryConnection(String[] zkHosts, AgentNode leaderAgentNode, HAConfiguration haConf) {
  boolean connectionFlag = false; 
  Socket socket = null;
  int numRetries = haConf.getNumRetriesAgentConn();
  int reconnectMillis = haConf.getAgentConnMillis();
  for(int i = 1; i < numRetries && !connectionFlag; i++) {
    connectionFlag = true;
    leaderAgentNode = getAgentData(zkHosts, ZKConstants.AGENT_LEADER_PATH);
    try {
      socket = new Socket(leaderAgentNode.getHost(), leaderAgentNode.getPort());
    } catch (ConnectException e){
      connectionFlag = false;
      LOGGER.warn("connection failed for - " + leaderAgentNode.getHost()+":"+leaderAgentNode.getPort()+ " retrying in " + (i*reconnectMillis) +" millis");
    } catch (IOException e) {			
    } finally {
      if (socket != null && !socket.isClosed()) {
        try {
          socket.close();
        } catch (IOException e) {
        }
      }
    }
    try {
      Thread.sleep(i*reconnectMillis*1000);
    } catch (InterruptedException e) {		
    }
  }
  return connectionFlag;
}

代码示例来源：origin: Impetus/jumbune

/**
 * Update leader agent info.
 */
private void updateLeaderAgentInfo() {
  AgentNode agentNode = null;
  try {
    agentNode = ZKUtils.getLeaderAgentfromZK(zkHosts, haConf);
  } catch (ConnectException e1) {
  logger.error("Unable to find active agent(leader) from zk, queried on ensembles - " + Arrays.toString(zkHosts));
  }
  jac = new JumbuneAgentCommunicator(agentNode.getHost(), agentNode.getPort());
}

代码示例来源：origin: Impetus/jumbune

/**
 * Checks if is NN changed.
 *
 * @return true, if is NN changed
 */
private boolean isNNChanged() {
  return !HAUtil.getActiveNNHost(this.clusterName).equals(ZKUtils.getActiveNNHost(zkHosts));
}

代码示例来源：origin: Impetus/jumbune

@Override
public void run() {
  try {
    long startTimeInMilis = Calendar.getInstance().getTimeInMillis();
    LOGGER.info("Started rsync execution at "
        + Calendar.getInstance().getTime());
    // get agents node information from zookeeper
    List<AgentNode> agentNodes = ZKUtils.getAgents(new String[] {this.zkConnectionString});
    // iterate over agent list and run rsync command
    for (AgentNode agent : agentNodes) {
      LOGGER.debug("Agent Object :" + agent.toString());
      if (agent.getStatus().equals(AgentNodeStatus.LEADER)) {
        LOGGER.debug("Skipping rsync execution for Leader Agent Object :");
        continue;
      }
      if (agent.getPrivateKey() != null
          && !agent.getPrivateKey().trim().equals("")) {
        rsyncWithPasswordlessSSH(agent);
      }
    }
    LOGGER.info("Total rsync execution time : "+ (Calendar.getInstance().getTimeInMillis() - startTimeInMilis)+ "ms.");
  } catch (Exception e) {
    LOGGER.error("Rsync execution failed.", e);
  }
}

代码示例来源：origin: Impetus/jumbune

leaderAgentNode = getAgentData(zkHosts, ZKConstants.AGENT_LEADER_PATH);
boolean connectionFlag = true;
Socket socket = null;
  LOGGER.warn("connection failed for - " + leaderAgentNode.getHost()+":"+leaderAgentNode.getPort());
  connectionFlag = retryConnection(zkHosts, leaderAgentNode, haConf);		
} catch (IOException e) {
} finally {

代码示例来源：origin: Impetus/jumbune

/**
 * Update global state.
 */
private void updateGlobalState() {
  AgentNode agent = null;
  try {
    agent = ZKUtils.getLeaderAgentfromZK(zkHosts, haConf);
  } catch (ConnectException e) {
   logger.error(e.getMessage(), e); 
  }
  HAUtil.setActiveAgentHost(this.clusterName, agent.getHost());
  HAUtil.setActiveAgentPort(this.clusterName, agent.getPort());
  HAUtil.setActiveNNHost(this.clusterName, ZKUtils.getActiveNNHost(zkHosts));
}

代码示例来源：origin: Impetus/jumbune

/**
 * Gets the agent data from znode.
 * @param zkHosts 
 *
 * @param nodePath the node path
 * @return the agent node data
 */
public static AgentNode getAgentData(String[] zkHosts, String nodePath){		
  CuratorConnector connector = CuratorConnector.getInstance(zkHosts);
  byte data[] = null;
  final int retryTimes = 10;
  int retryCount = 1;
  AgentNode agent = null;
  try {
    do {
      data = connector.getDataBytes(nodePath);        
      if(data == null) {
        LOGGER.warn("found active Agent null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100*retryCount);
      }
    retryCount++;
    } while(data == null && retryCount <= retryTimes);
    agent = convertGsonToAgent(new String(data, Charset.defaultCharset()));
  } catch (Exception e) {
    LOGGER.error(e.getMessage(), e);
  }
  return agent;
}

代码示例来源：origin: Impetus/jumbune

private static boolean retryConnection(String[] zkHosts, AgentNode leaderAgentNode, HAConfiguration haConf) {
  boolean connectionFlag = false; 
  Socket socket = null;
  int numRetries = haConf.getNumRetriesAgentConn();
  int reconnectMillis = haConf.getAgentConnMillis();
  for(int i = 1; i < numRetries && !connectionFlag; i++) {
    connectionFlag = true;
    leaderAgentNode = getAgentData(zkHosts, ZKConstants.AGENT_LEADER_PATH);
    try {
      socket = new Socket(leaderAgentNode.getHost(), leaderAgentNode.getPort());
    } catch (ConnectException e){
      connectionFlag = false;
      LOGGER.warn("connection failed for - " + leaderAgentNode.getHost()+":"+leaderAgentNode.getPort()+ " retrying in " + (i*reconnectMillis) +" millis");
    } catch (IOException e) {			
    } finally {
      if (socket != null && !socket.isClosed()) {
        try {
          socket.close();
        } catch (IOException e) {
        }
      }
    }
    try {
      Thread.sleep(i*reconnectMillis*1000);
    } catch (InterruptedException e) {		
    }
  }
  return connectionFlag;
}

代码示例来源：origin: Impetus/jumbune

private void updateLeaderAgentInfo() {
  AgentNode agentNode = null;
  try {
    agentNode = ZKUtils.getLeaderAgentfromZK(zkHosts, haConf);
  } catch (ConnectException e1) {
  logger.error("unable to find active agent(leader) from zk, queried on ensembles - " + Arrays.toString(zkHosts));
  }
  jac = new JumbuneAgentCommunicator(agentNode.getHost(), agentNode.getPort());
}

代码示例来源：origin: Impetus/jumbune

@Override
public void run() {
  String currentlyActiveNN = HAUtil.getActiveNNHost(this.clusterName);
  int failCount = 0;
  while (!stop) {
    if (!ZKUtils.getActiveNNHost(zkHosts).equals(currentlyActiveNN)) {
      failCount++;
    }
    try {
      Thread.sleep(5 * 1000);
    } catch (InterruptedException e) {
      logger.error("Thread interrupted while monitoring Namenode state");
    }
    if (failCount == nnZnodeRetries) {
      logger.warn("namenode dead !!! Applying recovery...");
      nnFailed = true;
      barrier.reset();
      break;
    }
  }
}

代码示例来源：origin: Impetus/jumbune

/**
 * Gets the leader name node from zookeeper.
 * @param zkHosts 
 *
 * @return the leader name node from zookeeper
 */
public static byte[] getLeaderNameNodeFromZK(String[] zkHosts) {
  final int retryTimes = 10;
  byte[] nameHostName = null;
  int retryCount = 1;
  do {
    List<String> nameNodeNameList = getNodeChildrenList(zkHosts, ZKConstants.HADOOP_NODE_PATH);
    for (String nameNodeName : nameNodeNameList) {
      nameHostName = getActiveNameNode(zkHosts,
          ZKConstants.HADOOP_NODE_PATH + File.separator + nameNodeName + ZKConstants.ACTIVE_BREAD_CRUMB);
    }
    if (nameHostName == null) {
      try {
        LOGGER.warn("found active NN null from ZK, retrying after " + 100 * retryCount + " millisecs");
        Thread.sleep(100 * retryCount);
      } catch (InterruptedException e) {
      }
    }
    retryCount++;
  } while (nameHostName == null && retryCount <= retryTimes);
  return nameHostName;
}

代码示例来源：origin: Impetus/jumbune

public static String getActiveNNHost(String[] zkHosts){
  byte[] activeHost = null;
  String activeNameNode = null ;
  activeHost = ZKUtils.getLeaderNameNodeFromZK(zkHosts);
  try {
    ActiveNodeInfo activeNodeInfo = PARSER.parsePartialFrom(activeHost);
    activeNameNode = activeNodeInfo.getHostname();
  } catch (InvalidProtocolBufferException e) {
    LOGGER.error(e);            
  }
  return activeNameNode;
}

代码示例来源：origin: Impetus/jumbune

/**
 * Sets the agent node data on znode.
 *
 * @param nodePath the node path
 * @param agent the Agent
 */
public static void setAgentData(String nodePath, AgentNode agent) {
  try {
    String hosts = null;
    CuratorConnector connector = CuratorConnector.getInstance(hosts);
    String json = convertAgentToGson(agent);
    connector.setData(nodePath, json.getBytes(Charset.forName("UTF-8")));
  } catch (Exception e) {
    LOGGER.error(e.getMessage(), e);        
  }
}

代码示例来源：origin: Impetus/jumbune

/**
 * Force agent election.
 *
 * @return the agent node
 */
private AgentNode forceAgentElection() {
  AgentNode agent = null;
  try {
    agent = ZKUtils.getLeaderAgentfromZK(zkHosts, haConf);
    // send self destruct command to currently active agent so that it
    // relinquishes leadership
    shutdownAgent();
    while (agent != null && HAUtil.compareAgent(this.clusterName, agent.getHost(), agent.getPort())) {
      logger.debug("Blocking till a new leader agent is elected...");
      agent = ZKUtils.getLeaderAgentfromZK(zkHosts, haConf);
      Thread.sleep(1 * 1000);
    }
  } catch (InterruptedException e) {
  } catch (ConnectException e) {
    logger.error("forceAgentElection - ", e);
  }
  return agent;
}

29

4

0

文章推荐： org.jvnet.solaris.libzfs.jna.zfs_prop_t类的使用及代码示例

文章推荐： org.jvnet.solaris.libzfs.ZFSObject类的使用及代码示例

文章推荐： org.apache.poi.xwpf.converter.core.openxmlformats.ZipArchive类的使用及代码示例

文章推荐： org.apache.poi.openxml4j.util.ZipArchiveFakeEntry类的使用及代码示例

common-lisp - 为什么没有用 Common Lisp 编写的 Common Lisp 实现？
最近，我开始学习 cuis-smalltalk，我没有意识到与 CLOS 相比，Smalltalk 的 OOP 有多么深刻和深入(我使用的是 Ruby)。我了解到 Smalltalk 是一个自己实现的
maven - Maven依赖项org.apache.commons:commons-io和commons-io:commons-io有什么区别？
Maven存储库包含以下两个依赖项：org.apache.commons:commons-io:1.3.2和commons-io:commons-io:1.3.2。有什么区别，我应该在pom.xml中
java - 在 Maven 中，它的 "org.apache.commons.collections:commons-collections"与 "commons-collections:commons-collections"相同吗？
我刚刚在我的 pom 文件中看到 Apache commons-collections 有两个不同的组 ID: commons-collections commons-collect
common-lisp - common lisp中的串口通信
Windows 上的 Common Lisp 中是否有用于串行端口通信的库？最佳答案下面是一些使用 SBCL 外部函数 POSIX 调用实现串行通信的函数。它不如完整的库好，但我解决了根据此协议(
common-lisp - common-lisp中有关可选参数的错误
SBCL 64位，1.1.7 如果我想创建一个包并使用package:CL中的一些符号，我将创建一个像这样的包: (defpackage :foo (:import-from :cl
common-lisp - Common Lisp的静态代码分析工具？
我正在忙着学习Common Lisp，并且正在寻找一种静态代码分析工具，该工具将帮助我开发更好的样式并避免陷入常见的陷阱。我找到了Lisp Critic，看起来不错，但我希望有人可以推荐其他一些工具
common-lisp - Common Lisp共享结构困惑
我正在阅读《Practical Common Lisp》一书，在第 22 章第 284 页的脚注 5 中，我看到一段让我感到困惑的代码片段。我知道变量list和tail有一个共同的列表结构，但我很困
common-lisp - Common Lisp 的复制树 : Which objects will be referenced in common by the original and the copy?
我正在阅读 Practical Common Lisp ，并且对 Lisp 的 COPY-TREE 函数有疑问。书中给出了调用的例子 (copy-tree '( '(1 2) '(3 4) '(5
groovy - geb 使用葡萄 - 下载失败 : commons-codec#commons-codec;1. 6!commons-codec.jar
我正在尝试使用 user guide 中的抓取示例运行 geb用于引入依赖项: $ cat my.groovy @Grapes([ @Grab("org.gebish:geb-core:0.9
common-lisp - Common Lisp 中的重复案例陈述
这里一定有更好的方法，对吧？ (format t "Enter your age: ~%") (defun age-case (age) (case age (1 (format t "Y
common-lisp - Common Lisp中do循环中的多值绑定(bind)
如何在 do 循环中绑定(bind)从函数返回的多个值？以下显然是非常错误的，但是这样的事情可能吗？ (do (((x y z) (3-val-fn) (3-val-fn))) ((equa
common-lisp - Common Lisp 中分数的相等性检查
所以我正在学习 Lisp 做分数，这很棒。但是为什么这个相等性检查返回 NIL: * (= 0.2 1/5) NIL ...如果转换为 float 则返回 True第一的: * (=
common-lisp - Common Lisp - 如何判断一个路径名是指向一个普通文件还是一个目录？
是否可以“统计”一个文件并找到它的文件类型 - 常规或目录？最佳答案阅读关于 portable pathname library 的章节来自 Peter Seibel 的 Practical Co
common-lisp - Common Lisp 源代码组织
我是 CL 的新手，正在使用 AllegroCL。我试图弄清楚如何组织我的源代码以满足以下要求: 我想阻止 src 代码包含我的测试套件。我想以可移植的方式声明项目依赖项(src 和 test de
common-lisp - Common Lisp 的最新标准
谁能告诉我最新的标准化 Common Lisp 的文档是什么(应该遵循各种实现的文档)？我问是因为我可以在网上找到很多关于 CL 的书都来自 90 年代，所以我想知道它们是否是最新的。我也来自于在 R
common-lisp - Common Lisp 中函数的作用域
假设我必须定义一个名为foo 的函数。假设，为了定义它，我使用了一些辅助函数 foo1, foo2, foo3, ... 当我加载包含这些函数的文件时，我可以从顶层使用所有这些函数。相反，我只想从顶层
common-lisp - Common Lisp 循环工具中的语法错误
这拒绝编译。注释掉 (setf roll行让它编译。然而，(setf roll...本身在 REPL 中正确评估。程序: ;; loop n times ; sum up number of hit
common-lisp - Common Lisp 嵌套结构变化
我目前正在学习 Common Lisp，并尝试将一些 JSON 发送到网络服务。我要发送的 JSON 以类似于以下的结构表示: ((:ITEMS ((:KEY . "value1") (:IGNO
common-lisp - 使用波浪号将文件名扩展到其完整路径(Common Lisp)
我有一个带波浪号的目录名(作为字符串):~/projects . 我想得到它的完整路径:/home/user/projects .我怎么做？目标是将它传递给 uiop:run-program ，这
common-lisp - Common Lisp 中格式指令的安全解析
我想从输入文件中读取一个字符串(用户可能修改也可能没有修改)。我想将此字符串视为使用固定数量的参数调用的格式指令。但是，我知道某些格式指令(特别是我想到的 ~/)可能会用于注入(inject)函数调用

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

滴滴打车优惠券

全站热门文章

Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com