使用datastax java驱动程序2.1.4连接到Cassandra集群太慢

Question

我最近在同一个内网的两台硬件配置完全相同的服务器上搭建了一个只有两个节点的cassandra集群。它与cqlsh配合得很好，一切似乎都很完美。然后我按照datastax网站上的代码示例编写java代码来处理集群，问题就来了。该程序正常工作，它连接到群集，并成功地向其中写入数据和从中读取数据。然而，连接速度太慢了！我将代码部署在一个集群节点所在的同一台机器上，连接需要5秒多的时间。更准确地说，是行session = cluster.connect()占用了大部分时间。

我尝试在同一个网络中设置另一个只有一个节点的cassandra集群，其硬件配置相似。连接大约需要1秒钟。所以我想我在写代码的时候可能漏掉了一些配置。我花了相当多的时间寻找答案，但没有得到任何答案。考虑到5秒的连接时间，我很难考虑用它来替代我当前的数据库。

另外，这些机器之间的ping时间在1ms以内，所以我不认为这是网络的问题。使用cqlsh连接集群也非常快。

cassandra版本为2.1.4，datastax的maven依赖项为

<dependency>
    <groupId>com.datastax.cassandra</groupId>
    <artifactId>cassandra-driver-core</artifactId>
    <version>2.1.4</version>
</dependency>

所以我想知道是否有人可以启发我为什么需要这么长时间才能连接到只有两个节点的集群。谢谢。

这是连接到卡桑德拉集群的代码，基本上它与其网站上显示的相同。

    long start = System.currentTimeMillis();
    cluster = Cluster.builder().addContactPoint(node1).addContactPoint(node2).build();
    Metadata metadata = cluster.getMetadata();
    System.out.printf("Connected to cluster: %s\n",metadata.getClusterName());
    System.out.println(metadata.getPartitioner());

    session = cluster.connect();
    long time = System.currentTimeMillis() - start;
    System.out.println("time to connect : " + time);

Answer 1

我相信我找到了它如此缓慢的原因。这只是因为我在[cassandra]/conf/cassandra.yaml中将rpc_address设置为 。一旦我将它设置为实际的IP地址，连接时间就从5秒下降到0.2秒。

是因为 rpc 地址会显著影响节点发现时间吗？