java - Cassandra-unit:java.io.IOException:对等方重置连接
问题描述
我正在使用 cassandra-unit 尝试嵌入式 Cassandra 并遇到以下异常,
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1 (com.datastax.driver.core.ConnectionException: [/127.0.0.1] Unexpected error during transport initialization (com.datastax.driver.core.TransportException: [/127.0.0.1] Unexpected exception triggered (java.io.IOException: Connection reset by peer))))
at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:195)
at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:78)
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1029)
at com.datastax.driver.core.Cluster.init(Cluster.java:120)
at com.datastax.driver.core.SessionManager.init(SessionManager.java:61)
at com.datastax.driver.core.SessionManager.execute(SessionManager.java:416)
at com.datastax.driver.core.SessionManager.executeQuery(SessionManager.java:453)
at com.datastax.driver.core.SessionManager.executeAsync(SessionManager.java:103)
at com.datastax.driver.core.SessionManager.execute(SessionManager.java:91)
at com.datastax.driver.core.SessionManager.execute(SessionManager.java:83)
at com.me.cc.bma.cassandra.test.main(test.java:30)
对于以下代码,
import com.datastax.driver.core.Cluster;
import org.cassandraunit.CQLDataLoader;
import org.cassandraunit.dataset.CQLDataSet;
import org.cassandraunit.dataset.cql.ClassPathCQLDataSet;
import org.cassandraunit.utils.EmbeddedCassandraServerHelper;
import org.apache.cassandra.config.DatabaseDescriptor;
import com.datastax.driver.core.ResultSet;
import static com.datastax.driver.core.Cluster.builder;
import com.datastax.driver.core.Session;
public class Test{
static Session session;
public static void main(String args[]) throws Exception {
EmbeddedCassandraServerHelper.startEmbeddedCassandra(500000L);
Cluster.Builder clusterBuilder = builder().addContactPoint("127.0.0.1").withClusterName(EmbeddedCassandraServerHelper.getClusterName()).withPort(7010);
Cluster cluster = clusterBuilder.build();
session = cluster.newSession();
try {
session.execute("CREATE KEYSPACE ci WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}");
session = cluster.connect("ci");
session.execute("CREATE TABLE login (l_id int)");
session.execute("insert into login(l_id) values(1)");
ResultSet res = session.execute("select * from login");
System.out.println(res.all());
}
catch (Exception ex) {
ex.printStackTrace();
}
}
}
版本:
- cassandra 驱动程序核心:3.5.0
- Cassandra 单元:3.5.0.1
任何修复将不胜感激!
解决方案
将端口更改为 9142 默认 cassndra 本机传输端口。
Cluster.builder().addContactPoint("127.0.0.1").withClusterName(EmbeddedCassandraServerHelper.getClusterName()).withPort(9142);
还要在创建表查询中指定 PRIMARY KEY
推荐阅读
- caching - https://cache.nixos.org 上整个 nixos 缓存的大小(以字节为单位)是多少?
- python - 给定另一个列表中的索引值,附加一个列表中的值
- reactjs - NextJS getStaticProps 正在使用 fallback: true 向同一个端点发出多个请求
- javascript - 找不到不是 es5 的 javascript 行
- flutter - 如何使该表可滚动到底部
- reactjs - ReactJS 中的动态组件名称
- pine-script - 如何重新格式化 pine.script 中输入对话框的外观/格式?
- rust - 是什么使用 crate::body::Body; 意思是?
- linux-kernel - 如何让 Linux conntrack 单独处理 ip 片段?
- ios - 查询 mongo 数据库以获取唯一 ID 时,领域抛出谓词异常