java—如何使用所有四个节点连接到cassandra数据库

pkbketx9  于 2021-06-14  发布在  Cassandra
关注(0)|答案(1)|浏览(369)

我最近开始使用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客户端?有人能帮我吗?
谢谢你的帮助。

t3irkdon

t3irkdon1#

种子列表是一个逗号分隔的列表。因此,您可以在setseeds调用中添加其余部分: setSeeds("server1:9160,server2:9160,server3:9160") 另外,astyanax将发现环中的其他服务器。您只需要列出一个就可以发现所有其他服务器,但如果该服务器已关闭,则需要列出更多。它非常像cassandra.yaml中的种子列表。
请注意,您已经在您的行中复制了端口:
.setseeds(“lp-host01.vip.slc.qa.host。com:9160:9160")

相关问题