AllNodesFailedException：无法到达任何联系点

Question

我通过docker在三个数据中心（DC1、DC2和DC3）中设置了三个Cassandra节点（cas1、cas2和cas3）。我想使用 Java API 在 cas1 建立会话，但它无法连接并引发异常。我尝试过手动设置端口并寻找可用的解决方案，但它们不起作用。cas1创建：docker run --name cas1 -p 19041:9042 -e CASSANDRA_CLUSTER_NAME=MyCluster -e CASSANDRA_ENDPOINT_SNITCH=GossipingPropertyFileSnitch -e CASSANDRA_DC=DC1 -e CASSANDRA_RACK=RAC1 -d cassandraJava代码：InetAddress addr = InetAddress.getByName("172.17.0.2");InetSocketAddress addrSoc = new InetSocketAddress(addr,19041);CqlSession session = CqlSession.builder().addContactPoint(addrSoc).build();预期结果：会话应该已建立。错误 ：datastax.oss.driver.api.core.AllNodesFailedException：无法到达任何联系点，请确保您提供了有效的地址（显示前 1 个，使用 getErrors() 了解更多信息：com.datastax.oss.driver.internal.core .metadata.DefaultNode@605c5ab0(null,/172.17.0.2:19041): com.datastax.oss.driver.api.core.connection.ConnectionInitException: [s0|control|connecting...] 初始化查询启动: 写入错误)

Answer 1

面临同样的问题。通过在配置类中将节点 ip(172.18.0.2) 更改为全局 ip '127.0.0.1' 来解决。

我使用 docker-compose 命令来运行 cassandra。请查看我的 docker-compose.yml 文件：

version: '3'

services:

 n1:

  build: .

  image: cassandra-with-cqlshrc

  networks:

   - cluster

  ports:

   - "9042:9042"

networks:

 cluster:

我的 Java 中的 CassandraConfiguration 文件：

@Configuration

@EnableCassandraRepositories

public class CassandraConfiguration extends AbstractCassandraConfiguration {

    @Override

      public String getContactPoints() {

        return "127.0.0.1";

      }

      @Override

      protected String getKeyspaceName() {

        return "stockmarket";

      }

     

      @Override

      protected int getPort() {

          return 9042;

      }

}

Answer 2

有效。我使用 IP：127.0.0.1 而不是全局 IP 和端口 19041（我明确配置的）并且它成功连接。

Answer 3

所有 DataStax 驱动程序都从内置数据中心故障转移和来自接触点的本地推理转向。

如果使用 Spring/Springboot，则必须指定数据中心名称。将此行添加到您的 application.properties 中： spring.data.cassandra.local-datacenter=datacenter1

对于数据中心的名称，“datacenter1”是默认名称。您可以在 cqlsh 中使用以下命令找到数据中心的名称：select data_center from system.local;

另外，不要忘记关闭 cqlsh 会话，因为它可能会导致在下一个请求中到达单节点 cassandra 集群时出现一些问题。

Session.close()