Apache Curator中的Connection Guarantees(连接保证)

傷城~ 2022-03-17 14:40 230阅读 0赞

Curator不断监控与ZooKeeper集合的连接。此外，每个操作都包含有重试机制。因此，可以做出以下保证：

*  每个Curator操作都会好好的等待，直到与ZooKeeper建立连接
 *  每个Curator操作（create，getData等）都保证按照当前设置的重试策略管理连接丢失和会话过期
 *  如果连接暂时丢失，Curator将尝试重试该操作，直到按照当前设置的重试策略成功
 *  所有Curator都试图以适当的方式处理连接问题

### **通知** ###

Curator为客户端公开了几个可监听的接口，以监控ZooKeeper连接的状态。

连接中断时调用ConnectionStateListener。客户可以监控这些变化并采取适当的措施。这些是可能的状态变化：

<table> 
 <tbody> 
  <tr> 
   <td style="text-align:left;vertical-align:top;">CONNECTED</td> 
   <td style="text-align:left;vertical-align:top;">发送第一次成功连接到服务器。注意：您只能为任何CuratorFramework实例获取这些消息之一。</td> 
  </tr> 
  <tr> 
   <td style="text-align:left;vertical-align:top;">READONLY</td> 
   <td style="text-align:left;vertical-align:top;">连接已进入只读模式。只有在CuratorFrameworkFactory.Builder.canBeReadOnly()传递true时才会发生这种情况。有关只读连接，请参阅ZooKeeper文档：<a href="https://wiki.apache.org/hadoop/ZooKeeper/GSoCReadOnlyMode" rel="nofollow">https</a>：<a href="https://wiki.apache.org/hadoop/ZooKeeper/GSoCReadOnlyMode" rel="nofollow">//wiki.apache.org/hadoop/ZooKeeper/GSoCReadOnlyMode</a>。连接将保持只读模式，直到发送另一个状态更改。</td> 
  </tr> 
  <tr> 
   <td style="text-align:left;vertical-align:top;">SUSPENDED</td> 
   <td style="text-align:left;vertical-align:top;">失去联系。领导者，锁等应该暂停，直到重新建立连接。</td> 
  </tr> 
  <tr> 
   <td style="text-align:left;vertical-align:top;">RECONNECTED</td> 
   <td style="text-align:left;vertical-align:top;">已重新建立暂停或丢失的连接。</td> 
  </tr> 
  <tr> 
   <td style="text-align:left;vertical-align:top;">LOST</td> 
   <td style="text-align:left;vertical-align:top;"> <p>Curator在认为ZooKeeper会话已过期时将设置LOST状态。ZooKeeper连接有一个会话。会话到期时，客户端必须采取适当的措施。在Curator中，由于Curator内部管理ZooKeeper连接，这很复杂。当发生以下任何一种情况时，Curator将设置LOST状态：</p> <p>a）ZooKeeper返回Watcher.Event.KeeperState.Expired或KeeperException.Code.SESSIONEXPIRED;&nbsp;</p> <p>b）Curator关闭内部管理的ZooKeeper实例;&nbsp;</p> <p>c）网络分区期间会话超时。在此之后可能会获得RECONNECTED状态，但您仍应将任何锁等视为脏/不稳定。</p> <p><strong>注意</strong>：自Curator 3.0.0以来，LOST的含义已经改变。3.0.0之前LOST仅表示重试策略已过期。</p> </td> 
  </tr> 
 </tbody> 
</table>

当后台任务等捕获异常时，将调用UnhandledErrorListener。一般而言，Curator用户在记录时不应该关心这些。但是，如果您愿意，可以听取它们。

### **错误政策** ###

Curator有一个可插入的错误政策。默认策略采用保守方法以相同方式处理连接状态SUSPENDED和LOST。即，当配方看到状态更改为SUSPENDED时，它将假定ZooKeeper会话丢失并将清理所有观察者，节点等。但是，您可以通过将错误策略设置为仅处理LOST来选择更积极的方法（即真正的会话丢失）作为错误状态。通过：connectionStateErrorPolicy(new SessionConnectionStateErrorPolicy())在CuratorFrameworkFactory中执行此操作。

参考：[https://curator.apache.org/errors.html][https_curator.apache.org_errors.html]

[https_curator.apache.org_errors.html]: https://curator.apache.org/errors.html