Cassandra容器数据库NoNodeAvailableException

Question

我使用在docker容器上运行的Cassandra docker映像和Spring Boot服务，并使用Datastax Java驱动程序。

我可以连接Cassandra，也可以查看日志，下面是docker compose文件，

version: '3.5'

networks:
  my-network:

 cassandra-db:
    container_name: cassandra-db
    image: cassandra:4.0-beta1
    ports:
      - "9042:9042"
    restart: on-failure
    environment:
      - CASSANDRA_CLUSTER_NAME='cassandra-cluster'
      - CASSANDRA_NUM_TOKENS=256
      - CASSANDRA_RPC_ADDRESS=0.0.0.0
      - CASSANDRA_ENDPOINT_SNITCH=GossipingPropertyFileSnitch
    volumes:
      - ./out/cassandra_data:/var/lib/cassandra
    networks:
      - my-network


 client-service:
    container_name: client-service
    image: data/client-service
    environment:
      - SPRING_PROFILES_ACTIVE=dev
    ports:
      - 8087:8087
    depends_on:
      - cassandra-db
    links:
      - cassandra-db
    networks:
      - my-network

我的密钥空间查询是，

CREATE KEYSPACE IF NOT EXISTS SensorKeySpace WITH replication = {'class':'NetworkTopologyStrategy','replication_factor':3}

以及使用，

.addContactEndPoint(new DefaultEndPoint(
                        InetSocketAddress.createUnresolved("cassandra-db",9042)))
                .withLocalDatacenter("DC1")
                .withKeyspace(CassandraConstant.KEY_SPACE_NAME.getValue())
                .build();

Cassandra已经启动并运行了，并且验证了它，

CONTAINER ID        IMAGE         COMMAND                  CREATED             STATUS              PORTS                                  NAMES
57d1d29dbf00  client-service      "java -Djava.securit…"   4 minutes ago       Up 4 minutes   0.0.0.0:8087->8087/tcp                      client-service
00548a4058e6  cassandra:4.0-beta1  "docker-entrypoint.s…"   4 minutes ago  Up 4 minutes   7000-7001/tcp, 7199/tcp, 9160/tcp, 0.0.0.0:9042->9042/tcp   cassandra-db

问题是在一开始，

1. 我使用了simplestregy来创建键空间，得到了以下错误：

Caused by: [com.datastax.oss.driver.api.core.CqlSession]: Factory method 'session' threw exception; nested exception is java.lang.IllegalStateException: Since you provided explicit contact points, the local DC must be explicitly set (see basic.load-balancing-policy.local-datacenter in the config, or set it programmatically with SessionBuilder.withLocalDatacenter). Current contact points are: Node(endPoint=cassandra-db:9042, hostId=729bd04f-b345-4df3-a148-80545d30e032, hashCode=5563e4c4)=datacenter1. Current DCs in this cluster are: datacenter1

然后配置. with LocalDatacenter（"DC1"）和-在docker撰写中的CASSANDRA_ENDPOINT_SNITCH=不过。

The Select Query is [SELECT NAME,VALUE FROM READING ]
client-service       | 2020-09-08 11:12:38.480 ERROR 1 --- [nio-8087-exec-3] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.util.concurrent.ExecutionException: org.springframework.data.cassandra.CassandraConnectionFailureException: Query; CQL [com.datastax.oss.driver.internal.core.cql.DefaultSimpleStatement@1265401a]; No node was available to execute the query; nested exception is com.datastax.oss.driver.api.core.NoNodeAvailableException: No node was available to execute the query] with root cause
client-service       | com.datastax.oss.driver.api.core.NoNodeAvailableException: No node was available to execute the query

我看了API文档https://docs.datastax.com/en/drivers/java/4.0/com/datastax/oss/driver/api/core/NoNodeAvailableException.html告诉我

This can happen if all nodes are down, or if all the contact points provided at startup were invalid.

我的Cassandra DB已启动（已验证），并且连接成功。这里有什么东西不见了吗？




Answer 1

匿名用户

所以这里的问题是键空间的定义。

CREATE KEYSPACE IF NOT EXISTS SensorKeySpace WITH replication = 
    {'class':'NetworkTopologyStrategy','replication_factor':3}

网络拓扑策略支持数据中心。这意味着需要为每个数据中心设置复制。据我所见，你的代码似乎在寻找“DC1”数据中心。

.withLocalDatacenter("DC1")

但是，你的日志告诉你：

该集群中的当前DC是：数据中心1

这意味着您的密钥空间定义应该如下所示：

CREATE KEYSPACE IF NOT EXISTS SensorKeySpace WITH replication = 
    {'class':'NetworkTopologyStrategy','datacenter1':3}

你的代码应该是：

.withLocalDatacenter("datacenter1")

注意：数据中心名称区分大小写。确保验证您在cassandra rackdc中使用的数据中心名称。属性文件。