以下是我的Java代码:
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Metadata;
import com.datastax.driver.core.Session;
public class CustomerController {
public void execute() {
Cluster cluster = Cluster.builder()
.addContactPoints("172.16.11.126", "172.16.11.130")
.withPort(9042)
.build();
Session session = cluster.connect();
String command = "drop keyspace if exists bookstore";
session.execute(command);
cluster.close();
}
}
当我运行代码时,出现以下错误:
环境信息:异常线程 "main" com.datastax.driver.core.exceptions.NoHostAvailableException: 所有 尝试查询的主机均失败(尝试:/172.16.11.130 (com.datastax.driver.core.TransportException:[/172.16.11.130]无法连接),/172.16.11.126(com.datastax.driver.core.TransportException: [/172.16.11.126]无法连接))
在com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:195)中重新连接
在com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:78)中连接
在com.datastax.driver.core.Cluster$Manager.init(Cluster.java: 1029)
中初始化 在com.datastax.driver.core.Cluster.init(Cluster.java:120)中初始化
在com.datastax.driver.core.Cluster.connect(Cluster.java:197)中连接
在com.pragatisoftware.datastax99.app.CustomerController.execute(CustomerController.java:12)中执行
在com.pragatisoftware.datastax99.app.Application.run(Application.java:10)中运行
在com.pragatisoftware.datastax99.app.Application.main(Application.java:6)中运行
- Ubuntu 操作系统
- Eclipse Luna IDE
- Java 1.7 版本
- Cassandra 2.0.11 数据库
native_transport_port: 9042
Cassandra正在运行在上面提供的两个IP地址(172.16.11.130和172.16.11.126)上,我能够使用CQLSH连接到这两台机器。
顺便说一下,相同的代码(使用相应的IP地址)在Windows机器上运行良好,使用的是Cassandra 2.0.9版本。
cassandra.yaml
是什么?特别是rpc_address
是什么意思? - Chironstart_native_transport: true
。 - Mikhail Stepura