Cassandra容器数据库NoNodeAvailableException

编程问答 2022-08-11

问题描述

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

我可以使用以下docker compose文件连接connect Cassandra并查看日志，

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}

并使用{p> 

Cqlsession

Cassandra已启动并运行，并对其进行了验证，

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

问题出在开始，

  1. 我使用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 创建Keyspace并收到以下错误消息，
SimpleStrategy

然后在docker compose中配置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 和.withLocalDatacenter("DC1")。

  1. 配置后，启动容器时没有错误，但是当我打查询时，出现了以下错误，
- CASSANDRA_ENDPOINT_SNITCH=GossipingPropertyFileSnitch

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

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

我的Cassandra数据库已启动（已验证），并且连接成功。这里缺少什么吗？

解决方法

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

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

NetworkTopologyStrategy支持数据中心。这意味着它需要在每个每个数据中心设置复制。据我所知，您的代码似乎正在寻找“ DC1”数据中心。

.withLocalDatacenter("DC1")

但是随后，您的日志告诉您：

此群集中的当前DC为：datacenter1

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

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

您的代码应为：

.withLocalDatacenter("datacenter1")

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

cassandradatastax-java-driverdockerdocker-compose