我有以下代码:

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]无法连接))


这发生在调用cluster.connect(KEYSPACE)的行上。任何想法如何解决这个问题?

最佳答案

cassandra.yaml设置很可能是一个问题。请检查listen_addressrpc_addressbroadcast_rpc_address的设置。

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

另外,nodetool会告诉您有关C *节点的信息吗?您可以通过cqlsh连接到您的节点吗?

10-07 16:15
查看更多