当zookeeper的状态自动更改时，手表和临时节点不工作？

Question

我对Python Kazoo库有一个非常奇怪的例子。我在下面的代码中所做的是-

一旦我使用kazoo库连接到ZooKeeper，我就会创建一个短暂的节点，然后在其他节点上保持监视，然后我继续在无限循环中永远运行程序。.我还为ZooKeeper添加了一个侦听器，它也将监控状态。

一切都工作得很好，我，短暂的节点是起来，手表上我的z节点也工作得很好...

有时候，我看到非常奇怪的行为，因为连接中断或下降。正如我上面提到的，我已经添加了一个监听器到zooManager，它将监控状态，我也有一个打印语句...我总是看到，那些打印语句被打印出来作为丢失，暂停，连接，我相信是因为连接中断，之后我的短暂节点死掉，我在znode上的手表也不能工作。

下面是我永远运行的代码-

#!/usr/bin/python

from kazoo.client import KazooClient
from kazoo.client import KazooState
from kazoo.protocol.states import EventType


def watch_host(event):
    print event


def my_listener(state):
    if state == KazooState.LOST:
    # Register somewhere that the session was lost
        print "Lost"
    elif state == KazooState.SUSPENDED:
    # Handle being disconnected from Zookeeper
        print "Suspended"
    else:
    # Handle being connected/reconnected to Zookeeper
    # what are we supposed to do here?
    print "Being Connected/Reconnected"


zk = KazooClient(hosts='127.0.0.1:2181')
zk.start()

zk.add_listener(my_listener)

# start an ephemeral node
zk.create("/my/example/h0", b"some value", None, True)

# put a watch on my znode
children = zk.get_children("/my/example/test1", watch=watch_host)


while True:
    time.sleep(5)

有没有办法克服这个问题？每当我的Zookeeper状态变为丢失或暂停或连接时，我都希望这样。我希望通过再次创建临时节点（如果这是正确的方法）来启动临时节点，并且我在znode上的手表也能一直正常工作。

因为我将永远运行我的程序，所以无论出于什么原因，如果ZooManager状态因连接中断而改变，并且它会自动重新连接，那么我需要确保我的短暂节点也已启动，并且我在znode上的手表也开始自动工作...

目前，如果状态自动改变，我的短暂死亡和手表也不起作用...

知道如何克服这个问题吗？

Answer 1

我对Python一无所知，但我想我会强调一下关于ZNodes
ZNodes有两种类型：短暂的或持久的

• 创建客户端会话结束后，ZooKeeper会立即删除一个短暂的znode
  一个persistent znode一旦创建，只有在客户端明确删除时才会被删除（不一定是创建它的客户端）

在Java版本（Java API）中，如果客户机连接到多个服务器，并且如果它与连接的服务器断开连接，那么我们将使用KeeperState触发事件。断开连接，但它会重新尝试并连接到另一台服务器，在这段时间内，短暂的znode和所有手表都完好无损，即它们不会被销毁，而是一次与保持状态的事件。Expired被调用（当客户端无法在指定时间内与任何服务器建立连接时），然后短暂的znode被破坏，如果我们想访问集合，然后重新建立一切，即节点创建和html" target="_blank">添加手表，我们必须创建一个新的客户端连接（实例化一个新的ZooKeeper实例）。

所以我认为在你们的情况下，这也可能是适用的，正如理解卡祖州一节所提到的

当连接转换为丢失时，Zookeeper将删除所有已创建的短暂节点。这会影响所有创建短暂节点的配方，例如锁配方。在状态转换为“再次连接”后，需要重新获取锁。当会话过期或停止客户端连接时，会发生此转换。

希望这些信息能帮助你了解各种状态，以及何时重新配置一切。

Answer 2

事情是这样的，当连接状态发生变化时，你的观察者也会被触发。有一个事件是给观察者的。它可以是nodeDataChanged或nodeChildrenChanged。但是，由于当会话终止或存在连接问题时，无法通知您感兴趣的事件，因此您的观察者将收到这些会话问题的通知。我认为这项活动的类型是“无”

从…起http://zookeeper.apache.org/doc/trunk/zookeeperProgrammers.html#ch_zkWatches

关于手表要记住的事情

• 监视是一次性触发器；如果您收到监视事件，并且希望收到未来更改的通知，则必须设置另一个监视。
• 因为监视是一次性触发器，并且在获取事件和发送新请求获取监视之间存在延迟，所以您无法可靠地看到ZooKeeper中节点发生的每一次更改。请准备好处理在获取事件和再次设置监视之间发生多次更改的情况。（你可能不在乎，但至少意识到它可能会发生。）
• 对于给定的通知，watch对象或函数/上下文对只会被触发一次。例如，如果为同一个文件注册了同一个watch对象，并且对同一个文件进行了getData调用，然后删除了该文件，则watch对象只会在文件的删除通知中被调用一次。
• 当您断开与服务器的连接时（例如，当服务器出现故障时），您将不会获得任何监视，直到重新建立连接。因此，会话事件会发送到所有未完成的监视处理程序。使用会话事件进入安全模式：断开连接时您不会接收事件，因此您的进程应该在该模式下保守行事。

因此，长话短说，您的观察者应该打开事件，看看它是什么类型的，并通过进入某种故障切换模式来适当地响应None类型。

我通常做的是我的观察者对象也是监听器。当重新连接发生时，我会重置手表，确保检查是否存在合适的Z节点，并在必要时创建它们。