NoHostAvailable异常:所有尝试查询的主机都失败

Question

当我连接单个节点Cassandra时，它工作正常。当我连接一个三节点集群(10.20.12.20、10.20.12.21、10.20.12.22(时，它抛出以下错误。为什么它试图连接本地主机？

Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: localhost/0:0:0:0:0:0:0:1:9042 (com.datastax.driver.core.exceptions.TransportException: [localhost/0:0:0:0:0:0:0:1:9042] Cannot connect), localhost/127.0.0.1:9042 (com.datastax.driver.core.exceptions.TransportException: [localhost/127.0.0.1:9042] Cannot connect))
at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:232) ~[cassandra-driver-core-3.4.0.jar:na]
at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:79) ~[cassandra-driver-core-3.4.0.jar:na]
at com.datastax.driver.core.Cluster$Manager.negotiateProtocolVersionAndConnect(Cluster.java:1619) ~[cassandra-driver-core-3.4.0.jar:na]
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1537) ~[cassandra-driver-core-3.4.0.jar:na]
at com.datastax.driver.core.Cluster.init(Cluster.java:159) ~[cassandra-driver-core-3.4.0.jar:na]

Answer 1

默认情况下(如果出现任何错误或缺少属性(，它将尝试连接到本地主机，因为这被设置为DEFAULT_CONTACT_POINTS

您的语法是正确的，我的猜测是您的应用程序根本没有读取该属性。您可以尝试调试并验证它。

至于调试：联系点设置在这里，如果你检查它总是设置为默认=localhost。

在 CassandraConfig 中，除了覆盖getKeyspaceName()方法之外，您还需要覆盖cluster()和cassandraMapping()方法，以使其适用于您想要的设置。例如：

@Configuration
public class CassandraConfig extends AbstractCassandraConfiguration {
public static final String KEYSPACE = "my_keyspace";
// read contact points from config
@Value("${spring.data.cassandra.contact-points}")
private String contactPoints;

@Override
public CassandraClusterFactoryBean cluster() {
CassandraClusterFactoryBean bean = super.cluster();
bean.setContactPoints(contactPoints);
return bean;
}

还有一个旁注：如果您只添加一个接触点，您将获得预期的行为，因为驱动程序将查找所有可用节点。实际上，如果要限制与特定节点的通信，则需要实现loadBalancingPolicy以进行排除。