我通過docker在三個數(shù)據(jù)中心（DC1、DC2和DC3）中設(shè)置了三個Cassandra節(jié)點（cas1、cas2和cas3）。我想使用 Java API 在 cas1 建立會話，但它無法連接并引發(fā)異常。我嘗試過手動設(shè)置端口并尋找可用的解決方案，但它們不起作用。cas1創(chuàng)建：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();預(yù)期結(jié)果：會話應(yīng)該已建立。錯誤 ：datastax.oss.driver.api.core.AllNodesFailedException：無法到達(dá)任何聯(lián)系點，請確保您提供了有效的地址（顯示前 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...] 初始化查詢啟動: 寫入錯誤)
3 回答
慕田峪7331174
TA貢獻(xiàn)1828條經(jīng)驗 獲得超13個贊
面臨同樣的問題。通過在配置類中將節(jié)點 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;
}
}
皈依舞
TA貢獻(xiàn)1851條經(jīng)驗 獲得超3個贊
所有 DataStax 驅(qū)動程序都從內(nèi)置數(shù)據(jù)中心故障轉(zhuǎn)移和來自接觸點的本地推理轉(zhuǎn)向。
如果使用 Spring/Springboot，則必須指定數(shù)據(jù)中心名稱。將此行添加到您的 application.properties 中：?spring.data.cassandra.local-datacenter=datacenter1
對于數(shù)據(jù)中心的名稱，“datacenter1”是默認(rèn)名稱。您可以在 cqlsh 中使用以下命令找到數(shù)據(jù)中心的名稱：select data_center from system.local;
另外，不要忘記關(guān)閉 cqlsh 會話，因為它可能會導(dǎo)致在下一個請求中到達(dá)單節(jié)點 cassandra 集群時出現(xiàn)一些問題。
Session.close()
添加回答
舉報
0/150
提交
取消