如何针对 Zookeeper 测试应用程序答案

【问题标题】：How to test application against Zookeeper如何针对 Zookeeper 测试应用程序
【发布时间】：2015-06-24 16:54:05
【问题描述】：

我有一个使用 Curator 框架来确定领导力的应用程序。我们希望能够从 Zookeeper 服务器测试状态变化，有没有办法做到这一点？

从我们的角度来看，如果我们可以让服务器向连接的客户端发送连接状态（CONNECTED、RECONNECTED、SUSPENDED、LOST），那将是有益的。我知道 Curator 提供了一个 TestingServer 类，但它似乎没有这个功能。

任何解决方案或想法将不胜感激！

【问题讨论】：

你看过Curator自己的测试吗？许多测试模拟了这些事件。
酷，没有意识到那些存在。谢谢！

标签： apache apache-zookeeper apache-curator

【解决方案1】：

https://apache.googlesource.com/curator/+/refs/heads/CURATOR-190/curator-recipes/src/test/java/org/apache/curator/framework/client/TestBackgroundStates.java

@Test
public void testConnectionStateListener() throws Exception
{
    server.close();
    Timing timing = new Timing();
    CuratorFramework client = CuratorFrameworkFactory.newClient(server.getConnectString(), timing.session(), timing.connection(), new RetryOneTime(timing.milliseconds()));
    try
    {
        client.start();
        final BlockingQueue<ConnectionState> stateVector = Queues.newLinkedBlockingQueue(1);
        ConnectionStateListener listener = new ConnectionStateListener()
        {
            @Override
            public void stateChanged(CuratorFramework client, ConnectionState newState)
            {
                stateVector.offer(newState);
            }
        };
        Timing waitingTiming = timing.forWaiting();
        client.getConnectionStateListenable().addListener(listener);
        server = new TestingServer(server.getPort());
        Assert.assertEquals(stateVector.poll(waitingTiming.milliseconds(), TimeUnit.MILLISECONDS), ConnectionState.CONNECTED);
        server.stop();
        Assert.assertEquals(stateVector.poll(waitingTiming.milliseconds(), TimeUnit.MILLISECONDS), ConnectionState.SUSPENDED);
        Assert.assertEquals(stateVector.poll(waitingTiming.milliseconds(), TimeUnit.MILLISECONDS), ConnectionState.LOST);
        server.restart();
        Assert.assertEquals(stateVector.poll(waitingTiming.milliseconds(), TimeUnit.MILLISECONDS), ConnectionState.RECONNECTED);
        server.close();
        Assert.assertEquals(stateVector.poll(waitingTiming.milliseconds(), TimeUnit.MILLISECONDS), ConnectionState.SUSPENDED);
        Assert.assertEquals(stateVector.poll(waitingTiming.milliseconds(), TimeUnit.MILLISECONDS), ConnectionState.LOST);
    }
    finally
    {
        CloseableUtils.closeQuietly(client);
    }
}

【讨论】：