我想将配置文件中的多个cassandra端点提供给我的java应用程序。
例如:cassandra主机:“host1,host2”
我试过了 addContactPoints(host)
,但没有起作用。如果其中一个cassandra节点宕机,我不希望我的应用程序宕机。
cluster = Cluster.builder()
.withClusterName(cassandraConfig.getClusterName())
.addContactPoints(cassandraConfig.getHostName())
.withSocketOptions(new SocketOptions().setConnectTimeoutMillis(30000).setReadTimeoutMillis(30000))
.withPoolingOptions(poolingOptions).build();
1条答案
按热度按时间wgx48brx1#
java驱动程序对提供的某个接触点不可用具有弹性。接触点用于建立初始连接[*]。只要驱动程序能够与一个接触点通信,它就应该能够查询
system.peers
以及system.local
表来发现群集中的其余节点。