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

ZooKeeperClient.shouldRetry介绍

[英]Checks to see if the client might reasonably re-try an operation given the exception thrown while attempting it. If the ZooKeeper session should be expired to enable the re-try to succeed this method will expire it as a side-effect.
[中]检查客户端是否可以合理地重新尝试某个操作，前提是在尝试该操作时引发了异常。如果ZooKeeper会话应该过期以启用重试成功，此方法将作为副作用而过期。

代码示例

代码示例来源：origin: com.twitter/finagle-serversets_2.11

@Override public Boolean get() throws InterruptedException {
  try {
   watchGroup();
   return true;
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error re-watching group: " + path, e);
    return false;
   } else {
    throw new IllegalStateException("Permanent problem re-watching group: " + path, e);
   }
  }
 }
};

代码示例来源：origin: com.twitter/finagle-serversets

@Override public Boolean get() throws InterruptedException {
  try {
   watchGroup();
   return true;
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error re-watching group: " + path, e);
    return false;
   } else {
    throw new IllegalStateException("Permanent problem re-watching group: " + path, e);
   }
  }
 }
};

代码示例来源：origin: com.twitter/finagle-serversets_2.11

@Override public Boolean get() throws InterruptedException {
  try {
   join();
   return true;
  } catch (CancelledException e) {
   // Lost a cancel race - that's ok.
   return true;
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error re-joining group: " + path, e);
    return false;
   } else {
    throw new IllegalStateException("Permanent problem re-joining group: " + path, e);
   }
  }
 }
};

代码示例来源：origin: com.twitter/finagle-serversets

@Override public Boolean get() throws InterruptedException {
  try {
   join();
   return true;
  } catch (CancelledException e) {
   // Lost a cancel race - that's ok.
   return true;
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error re-joining group: " + path, e);
    return false;
   } else {
    throw new IllegalStateException("Permanent problem re-joining group: " + path, e);
   }
  }
 }
};

代码示例来源：origin: com.twitter/finagle-serversets

@Override public Boolean get() throws WatchException {
  try {
   groupMonitor.watchGroup();
   return true;
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new WatchException("Interrupted trying to watch group at path: " + path, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Temporary error trying to watch group at path: " + path, e);
   return null;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error trying to watch group at path: " + path, e);
    return null;
   } else {
    throw new WatchException("Problem trying to watch group at path: " + path, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets_2.11

@Override public Boolean get() throws WatchException {
  try {
   groupMonitor.watchGroup();
   return true;
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new WatchException("Interrupted trying to watch group at path: " + path, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Temporary error trying to watch group at path: " + path, e);
   return null;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error trying to watch group at path: " + path, e);
    return null;
   } else {
    throw new WatchException("Problem trying to watch group at path: " + path, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets

@Override public Membership get() throws JoinException {
  try {
   return groupJoiner.join();
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new JoinException("Interrupted trying to join group at path: " + path, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Temporary error trying to join group at path: " + path, e);
   return null;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error trying to join group at path: " + path, e);
    return null;
   } else {
    throw new JoinException("Problem joining partition group at path: " + path, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets_2.11

@Override public Membership get() throws JoinException {
  try {
   return groupJoiner.join();
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new JoinException("Interrupted trying to join group at path: " + path, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Temporary error trying to join group at path: " + path, e);
   return null;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error trying to join group at path: " + path, e);
    return null;
   } else {
    throw new JoinException("Problem joining partition group at path: " + path, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets_2.11

@Override public Boolean get() throws JoinException {
  try {
   ZooKeeperUtils.ensurePath(zkClient, acl, path);
   return true;
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new JoinException("Interrupted trying to ensure group at path: " + path, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error ensuring path: " + path, e);
    return false;
   } else {
    throw new JoinException("Problem ensuring group at path: " + path, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets

@Override public Boolean get() throws JoinException {
  try {
   ZooKeeperUtils.ensurePath(zkClient, acl, path);
   return true;
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new JoinException("Interrupted trying to ensure group at path: " + path, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error ensuring path: " + path, e);
    return false;
   } else {
    throw new JoinException("Problem ensuring group at path: " + path, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets_2.11

@Override public Boolean get() throws JoinException {
  try {
   zkClient.get().delete(nodePath, ZooKeeperUtils.ANY_VERSION);
   return true;
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new JoinException("Interrupted trying to cancel membership: " + nodePath, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (NoNodeException e) {
   LOG.info("Membership already cancelled, node at path: " + nodePath
        + " has been deleted");
   return true;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error cancelling membership: " + nodePath, e);
    return false;
   } else {
    throw new JoinException("Problem cancelling membership: " + nodePath, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets

@Override public Boolean get() throws JoinException {
  try {
   zkClient.get().delete(nodePath, ZooKeeperUtils.ANY_VERSION);
   return true;
  } catch (InterruptedException e) {
   Thread.currentThread().interrupt();
   throw new JoinException("Interrupted trying to cancel membership: " + nodePath, e);
  } catch (ZooKeeperConnectionException e) {
   LOG.log(Level.WARNING, "Problem connecting to ZooKeeper, retrying", e);
   return false;
  } catch (NoNodeException e) {
   LOG.info("Membership already cancelled, node at path: " + nodePath
        + " has been deleted");
   return true;
  } catch (KeeperException e) {
   if (zkClient.shouldRetry(e)) {
    LOG.log(Level.WARNING, "Temporary error cancelling membership: " + nodePath, e);
    return false;
   } else {
    throw new JoinException("Problem cancelling membership: " + nodePath, e);
   }
  }
 }
});

代码示例来源：origin: com.twitter/finagle-serversets_2.11

@Override public ServiceInstance get() {
   try {
    byte[] data = zkClient.get().getData(nodePath, false, null);
    return ServerSets.deserializeServiceInstance(data, codec);
   } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    throw new ServiceInstanceFetchException(
      "Interrupted updating service data for: " + nodePath, e);
   } catch (ZooKeeperConnectionException e) {
    LOG.log(Level.WARNING,
      "Temporary error trying to updating service data for: " + nodePath, e);
    return null;
   } catch (NoNodeException e) {
    invalidateNodePath(nodePath);
    throw new ServiceInstanceDeletedException(nodePath);
   } catch (KeeperException e) {
    if (zkClient.shouldRetry(e)) {
     LOG.log(Level.WARNING,
       "Temporary error trying to update service data for: " + nodePath, e);
     return null;
    } else {
     throw new ServiceInstanceFetchException(
       "Failed to update service data for: " + nodePath, e);
    }
   } catch (IOException e) {
    throw new ServiceInstanceFetchException(
      "Failed to deserialize the ServiceInstance data for: " + nodePath, e);
   }
  }
});

代码示例来源：origin: com.twitter/finagle-serversets

@Override public ServiceInstance get() {
   try {
    byte[] data = zkClient.get().getData(nodePath, false, null);
    return ServerSets.deserializeServiceInstance(data, codec);
   } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    throw new ServiceInstanceFetchException(
      "Interrupted updating service data for: " + nodePath, e);
   } catch (ZooKeeperConnectionException e) {
    LOG.log(Level.WARNING,
      "Temporary error trying to updating service data for: " + nodePath, e);
    return null;
   } catch (NoNodeException e) {
    invalidateNodePath(nodePath);
    throw new ServiceInstanceDeletedException(nodePath);
   } catch (KeeperException e) {
    if (zkClient.shouldRetry(e)) {
     LOG.log(Level.WARNING,
       "Temporary error trying to update service data for: " + nodePath, e);
     return null;
    } else {
     throw new ServiceInstanceFetchException(
       "Failed to update service data for: " + nodePath, e);
    }
   } catch (IOException e) {
    throw new ServiceInstanceFetchException(
      "Failed to deserialize the ServiceInstance data for: " + nodePath, e);
   }
  }
});