卡桑德拉连接异常

Question

我有这个代码:

private final String CONTACT_POINT = "127.0.0.1";
private SynchronizationTableManager()
{
     cluster = Cluster.builder().addContactPoint(CONTACT_POINT).build();;
     session = cluster.connect(KEYSPACE);
    createTableIfNotExists();
}

我得到以下异常:

所有主机尝试查询失败（已尝试：/127.0.0.1:9042（com.datastax.driver.core.TransportException：[/127.0.0.1:9042]无法连接）），堆栈跟踪：com.datastax.driver.core.exceptions.NoHostAvailableException：所有主机尝试查询失败（已尝试：/127.0.0.1:9042（com.datastax.driver.core.TransportException：[/127.0.0.1:9042]无法连接））

这发生在调用< code > cluster . connect(KEYSPACE)的行上。知道怎么解决这个问题吗？

Answer 1

当我使用ssl证书从本地计算机连接到cassandra集群时，我遇到了同样的异常
就我的情况而言，Java版本存在一些问题。我使用的是java1.80_91，这是一个稍旧的版本。之后，我将我的java版本更新为1.8.0_221。

这可能有帮助，有人在同一条船上。

Answer 2

这很可能是cassandra.yaml设置的问题。请检查listen_address、rpc_address和broadcast_rpc_address的设置。

另请检查 Java 驱动程序的连接要求：https://github.com/datastax/java-driver/wiki/Connection-requirements

另外，nodetool ring告诉您有关C*节点的什么信息？您可以通过cqlsh连接到您的节点吗？