我最近开始使用cassandra数据库,我正在使用netflix客户端填充和读取cassandra数据库中的数据。
我有一个有四个节点的集群。我创建了这样的键空间-
create keyspace profilekeyspace
with placement_strategy = 'NetworkTopologyStrategy'
and strategy_options = {DC2 : 1, DC1 : 1}
and durable_writes = true;
我的姓是- profile_columnfamily
这是我的四个节点-
lp-host01.vip.slc.qa.host.com:9160
lp-host02.vip.slc.qa.host.com:9160
lp-host03.vip.phx.qa.host.com:9160
lp-host04.vip.phx.qa.host.com:9160
现在我只使用上面的一个节点连接到cassandra数据库并填充数据。但是我的数据库管理员说,你需要使用所有的四个节点来建立连接。
private AstyanaxContext<Keyspace> context;
private CassandraAstyanaxConnection() {
context = new AstyanaxContext.Builder()
.forCluster("TEST CLUSTER")
.forKeyspace("PROFILE")
.withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
.setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
)
.withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
.setPort(9160)
.setMaxConnsPerHost(1)
.setSeeds("lp-host01.vip.slc.qa.host.com:9160:9160")//using only node from above to make the connection
)
.withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
.setCqlVersion("3.0.0")
.setTargetCassandraVersion("1.2"))
.withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
.buildKeyspace(ThriftFamilyFactory.getInstance());
context.start();
keyspace = context.getEntity();
emp_cf = ColumnFamily.newColumnFamily(
"PROFILE_COLUMNFAMILY",
StringSerializer.get(),
StringSerializer.get());
}
现在我不知道如何使用所有的四个节点,使连接使用netflix客户端?有人能帮我吗?
谢谢你的帮助。
1条答案
按热度按时间t3irkdon1#
种子列表是一个逗号分隔的列表。因此,您可以在setseeds调用中添加其余部分:
setSeeds("server1:9160,server2:9160,server3:9160")
另外,astyanax将发现环中的其他服务器。您只需要列出一个就可以发现所有其他服务器,但如果该服务器已关闭,则需要列出更多。它非常像cassandra.yaml中的种子列表。请注意,您已经在您的行中复制了端口:
.setseeds(“lp-host01.vip.slc.qa.host。com:9160:9160")