java - Cassandra 中的 NoHostAvailableException

Question

我需要为类(class)建立与 cassandra 的演示+连接。经过相当大的麻烦后，我留下了其他类型的错误，但我被困在这里，似乎无法获取 key 空间的地址。

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.exceptions.NoHostAvailableException;

public class conectaradb {

public static void main(String[] args) {
 try {
    Cluster cluster;
     Session sesion;

     cluster = Cluster.builder().addContactPoint("127.0.0.1").withPort(9042).build();

     sesion= cluster.connect("ejemplodb");

     ResultSet resultado= sesion.execute("select * from empleados");
     String nombreemp,fecha,cargo;
     double comision,salario;
     int empno;

     for (Row row:resultado) {
         empno=row.getInt("empno");
         cargo=row.getString("cargo");
         comision=row.getDouble("comision");
         fecha=row.getString("fechaing");
         nombreemp=row.getString("nombreempno");
         salario=row.getDouble("salario");
         System.out.println(empno+" "+cargo+" "+comision+" "+fecha+" "+nombreemp+" "+salario);
     }  
     cluster.close();

 }catch(NoHostAvailableException e) {
 System.out.println(e.getErrors());
}


}

}

如果有人能够确定错误所在，我会很高兴，我认为我的 yaml 文件是正确的。当代码到达 addcontactpoint 上的本地主机时，我收到错误:“所有主机尝试查询失败”。.getError 之后我得到一个“TransportException”。我不知道如何继续。

Answer 1

将cassandra.yaml中的rpc_broadcast_address更新为有效的IP；因为 rpc_address 是 0.0.0.0。然后重新启动 Cassandra 后尝试通过 Java 使用该 IP 连接。

https://docs.datastax.com/en/developer/java-driver/3.3/manual/address_resolution/