小编Ant*_*llo的帖子

我使用Google计算引擎来设置三个cassandra节点的集群.运行"nodetool status"后,我得到:

antoniogallo88@cassandra-7m0w:~$ nodetool status
Datacenter: europe-west1
========================
Status=Up/Down
|/ State=Normal/Leaving/Joining/Moving
--  Address         Load       Tokens  Owns (effective)  Host ID                               Rack
UN  10.240.41.185   56.28 KB   256     33.2%             edf4c2c8-f746-4c86-8b1e-4d4317788de9  b
UN  10.240.145.130  56.31 KB   256     30.6%             76025d1d-b5e4-4510-afd9-e0c52ae4aa2b  b
UN  10.240.194.231  60.94 KB   256     36.2%             1c5594d6-4a62-4cb7-bb4e-ab15545af6a0  b

所以,一切正常.

cqlsh命令也运行良好.

我的问题是当我运行以下内容时:

package com.example.cassandra;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Host;
import com.datastax.driver.core.Metadata;

    public class SimpleClient {
       private Cluster cluster;

       public void connect(String node, int port) {
          cluster = Cluster.builder()
               // .addContactPoints("10.240.41.185", "10.240.145.130", "10.240.194.231").withPort(port).build();
                  .addContactPoints(node).withPort(port).build();

          Metadata metadata = …