如何解决Cassandra容器数据库NoNodeAvailableException
我使用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();
问题出在开始,
- 我使用
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")
。
- 配置后,启动容器时没有错误,但是当我打查询时,出现了以下错误,
- 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
文件中验证您正在使用的数据中心名称。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。