本文整理了Java中com.twitter.finagle.common.zookeeper.ZooKeeperClient
类的一些代码示例,展示了ZooKeeperClient
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperClient
类的具体详情如下:
包路径:com.twitter.finagle.common.zookeeper.ZooKeeperClient
类名称:ZooKeeperClient
[英]Manages a connection to a ZooKeeper cluster.
[中]管理与ZooKeeper群集的连接。
代码示例来源:origin: com.twitter/finagle-serversets
/**
* 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.
*
* @param e the exception to test
* @return true if a retry can be attempted
*/
public boolean shouldRetry(KeeperException e) {
if (e instanceof SessionExpiredException) {
close();
}
return ZooKeeperUtils.isRetryable(e);
}
代码示例来源:origin: com.twitter/finagle-serversets_2.11
/**
* Creates an unconnected client that will lazily attempt to connect on the first call to
* {@link #get()}.
*
* @param sessionTimeout the ZK session timeout
* @param zooKeeperServer the first, required ZK server
* @param zooKeeperServers any additional servers forming the ZK cluster
*/
public ZooKeeperClient(Duration sessionTimeout, InetSocketAddress zooKeeperServer,
InetSocketAddress... zooKeeperServers) {
this(sessionTimeout, combine(zooKeeperServer, zooKeeperServers));
}
代码示例来源:origin: com.twitter/finagle-serversets
private void watchGroup()
throws ZooKeeperConnectionException, InterruptedException, KeeperException {
if (stopped) {
return;
}
List<String> children = zkClient.get().getChildren(path, groupWatcher);
setMembers(children.stream()
.filter(nodeNameFilter)
.collect(Collectors.toList())
);
}
代码示例来源:origin: com.twitter/finagle-serversets_2.11
public Runnable watch() throws WatchException, InterruptedException {
Watcher onExpirationWatcher = zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
// Servers may have changed Status while we were disconnected from ZooKeeper, check and
// re-register our node watches.
rebuildServerSet();
}
});
try {
return group.watch(new GroupChangeListener() {
@Override public void onGroupChange(Iterable<String> memberIds) {
notifyGroupChange(memberIds);
}
});
} catch (WatchException e) {
zkClient.unregister(onExpirationWatcher);
throw e;
} catch (InterruptedException e) {
zkClient.unregister(onExpirationWatcher);
throw 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_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_2.11
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryJoin();
? CreateMode.EPHEMERAL_SEQUENTIAL
: CreateMode.EPHEMERAL;
nodePath = zkClient.get().create(
path + "/" + nodeName, updatedMembershipData, acl, createMode);
memberId = Group.this.getMemberId(nodePath);
zkClient.get().exists(nodePath, new Watcher() {
@Override public void process(WatchedEvent event) {
if (event.getType() == EventType.NodeDeleted) {
代码示例来源:origin: com.twitter/finagle-serversets
/**
* Creates a set of credentials for the zoo keeper digest authentication mechanism.
*
* @param username the username to authenticate with
* @param password the password to authenticate with
* @return a set of credentials that can be used to authenticate the zoo keeper client
*/
public static Credentials digestCredentials(String username, String password) {
MorePreconditions.checkNotBlank(username);
Objects.requireNonNull(password);
// TODO(John Sirois): DigestAuthenticationProvider is broken - uses platform default charset
// (on server) and so we just have to hope here that clients are deployed in compatible jvms.
// Consider writing and installing a version of DigestAuthenticationProvider that controls its
// Charset explicitly.
return credentials("digest", (username + ":" + password).getBytes());
}
代码示例来源:origin: com.twitter/finagle-serversets
/**
* Clients that need to re-establish state after session expiration can register an
* {@code onExpired} command to execute.
*
* @param onExpired the {@code Runnable} to register
* @return the new {@link Watcher} which can later be passed to {@link #unregister} for
* removal.
*/
public Watcher registerExpirationHandler(final Runnable onExpired) {
Watcher watcher = new Watcher() {
@Override public void process(WatchedEvent event) {
if (event.getType() == EventType.None && event.getState() == KeeperState.Expired) {
onExpired.run();
}
}
};
register(watcher);
return watcher;
}
代码示例来源:origin: com.twitter/finagle-serversets
synchronized void setMembers(Iterable<String> members) {
if (stopped) {
LOG.info("Suppressing membership update, no longer watching " + this);
return;
}
if (this.members == null) {
// Reset our watch on the group if session expires - only needs to be registered once.
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryWatchGroup();
}
});
}
Set<String> membership = new HashSet<>();
members.iterator().forEachRemaining(membership::add);
if (!membership.equals(this.members)) {
groupChangeListener.onGroupChange(members);
this.members = Collections.unmodifiableSet(membership);
}
}
}
代码示例来源: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
@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
public Runnable watch() throws WatchException, InterruptedException {
Watcher onExpirationWatcher = zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
// Servers may have changed Status while we were disconnected from ZooKeeper, check and
// re-register our node watches.
rebuildServerSet();
}
});
try {
return group.watch(new GroupChangeListener() {
@Override public void onGroupChange(Iterable<String> memberIds) {
notifyGroupChange(memberIds);
}
});
} catch (WatchException e) {
zkClient.unregister(onExpirationWatcher);
throw e;
} catch (InterruptedException e) {
zkClient.unregister(onExpirationWatcher);
throw e;
}
}
代码示例来源:origin: com.twitter/finagle-serversets
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryJoin();
? CreateMode.EPHEMERAL_SEQUENTIAL
: CreateMode.EPHEMERAL;
nodePath = zkClient.get().create(
path + "/" + nodeName, updatedMembershipData, acl, createMode);
memberId = Group.this.getMemberId(nodePath);
zkClient.get().exists(nodePath, new Watcher() {
@Override public void process(WatchedEvent event) {
if (event.getType() == EventType.NodeDeleted) {
代码示例来源:origin: com.twitter/finagle-serversets_2.11
/**
* Creates a set of credentials for the zoo keeper digest authentication mechanism.
*
* @param username the username to authenticate with
* @param password the password to authenticate with
* @return a set of credentials that can be used to authenticate the zoo keeper client
*/
public static Credentials digestCredentials(String username, String password) {
MorePreconditions.checkNotBlank(username);
Objects.requireNonNull(password);
// TODO(John Sirois): DigestAuthenticationProvider is broken - uses platform default charset
// (on server) and so we just have to hope here that clients are deployed in compatible jvms.
// Consider writing and installing a version of DigestAuthenticationProvider that controls its
// Charset explicitly.
return credentials("digest", (username + ":" + password).getBytes());
}
代码示例来源:origin: com.twitter/finagle-serversets_2.11
/**
* Clients that need to re-establish state after session expiration can register an
* {@code onExpired} command to execute.
*
* @param onExpired the {@code Runnable} to register
* @return the new {@link Watcher} which can later be passed to {@link #unregister} for
* removal.
*/
public Watcher registerExpirationHandler(final Runnable onExpired) {
Watcher watcher = new Watcher() {
@Override public void process(WatchedEvent event) {
if (event.getType() == EventType.None && event.getState() == KeeperState.Expired) {
onExpired.run();
}
}
};
register(watcher);
return watcher;
}
代码示例来源:origin: com.twitter/finagle-serversets_2.11
synchronized void setMembers(Iterable<String> members) {
if (stopped) {
LOG.info("Suppressing membership update, no longer watching " + this);
return;
}
if (this.members == null) {
// Reset our watch on the group if session expires - only needs to be registered once.
zkClient.registerExpirationHandler(new Runnable() {
@Override public void run() {
tryWatchGroup();
}
});
}
Set<String> membership = new HashSet<>();
members.iterator().forEachRemaining(membership::add);
if (!membership.equals(this.members)) {
groupChangeListener.onGroupChange(members);
this.members = Collections.unmodifiableSet(membership);
}
}
}
代码示例来源: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_2.11
private void watchGroup()
throws ZooKeeperConnectionException, InterruptedException, KeeperException {
if (stopped) {
return;
}
List<String> children = zkClient.get().getChildren(path, groupWatcher);
setMembers(children.stream()
.filter(nodeNameFilter)
.collect(Collectors.toList())
);
}
代码示例来源: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);
}
}
}
};
内容来源于网络,如有侵权,请联系作者删除!