Curator连接与重试机制的分析
发布时间
阅读量：
阅读量
源码分析
实现连接断开的处理机制。
该系统采用类ConnectionState来管理客户端与ZooKeeper集群之间的连接状态。
该系统使用原子布尔型变量作为标志位来判断当前客户端与ZooKeeper集群之间的连接是否已建立。
private final AtomicBoolean isConnected=new AtomicBoolean(false);在事件处理函数体中(ConnectionState实现了Watcher接口)，重置isConnected字段的值：
@Override
public void process(WatchedEvent event)
{
//逐个调用parentWatchers容器中的Watcher的process函数
for ( Watcher parentWatcher :parentWatchers )
{
TimeTrace timeTrace = new TimeTrace("connection-state-parent-process",tracer.get());
parentWatcher.process(event);全部评论 (0)
还没有任何评论哟~