2

我们有一个带有 RF 3 的 3 节点集群。

一旦我们从集群中耗尽一个节点，我们就会看到很多：

All host(s) tried for query failed (no host was tried)
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (no host was tried)
        at com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:84)
        at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
        at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:214)
        at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)

我们所有的写入和读取都具有一致性级别 QUORUM 或 ONE，因此在一个节点关闭的情况下，一切都应该完美运行。但是只要节点关闭，就会抛出异常。

我们使用 Cassandra 2.2.4 + Java Cassandra Driver 2.1.10.2

以下是我们创建集群的方式：

new Cluster.Builder()
    .addContactPoints(CONTACT_POINTS)
    .withCredentials(USERNAME, PASSWORD)
    .withRetryPolicy(new LoggingRetryPolicy(DefaultRetryPolicy.INSTANCE))
    .withReconnectionPolicy(new ExponentialReconnectionPolicy(10, 10000))
    .withLoadBalancingPolicy(new TokenAwarePolicy(new RoundRobinPolicy()))
    .withSocketOptions(new SocketOptions().setReadTimeoutMillis(12_000))
    .build();

CONTACT_POINTS 是节点的 3 个公共 ip 的字符串数组。

几个月前，集群在暂时只有 2 个节点的情况下运行良好，但由于未知原因，情况不再如此，我的想法已经不多了 :(

非常感谢你的帮助！

4

1 回答 1

0

问题解决了。

更多分析表明该问题来自知识产权问题。我们的 cassandra 服务器使用私有本地 IP (10.0.) 进行通信，而我们的应用服务器在其配置中具有其公共 IP。

当他们在同一个网络中时，它工作正常，但是当他们移动到不同的网络时，他们只能连接到集群中的一台机器，而另外两台在尝试连接到私有本地时被认为已关闭IP 而不是其他两个的公共 IP。

解决方案是在集群构建器中添加一个 IPTranslater：

.withAddressTranslater(new ToPublicIpAddressTranslater())

使用以下代码：

private static class ToPublicIpAddressTranslater implements AddressTranslater {

    private Map<String, String> internalToPublicIpMap = new HashMap<>();

    public ToPublicIpAddressTranslater() {
        for (int i = 0; i < CONTACT_POINT_PRIVATE_IPS.length; i++) {
            internalToPublicIpMap.put(CONTACT_POINT_PRIVATE_IPS[i], CONTACT_POINTS[i]);
        }
    }

    @Override
    public InetSocketAddress translate(InetSocketAddress address) {
        String publicIp = internalToPublicIpMap.get(address.getHostString());
        if (publicIp != null) {
            return new InetSocketAddress(publicIp, address.getPort());
        }
        return address;
    }
}
于 2016-06-20T10:01:20.870 回答