【问题标题】:Cannot connect to embedded Cassandra无法连接到嵌入式 Cassandra
【发布时间】:2013-10-22 20:08:26
【问题描述】:

我正在尝试使用代码启动 Cassandra,但无法连接到它。当我远程登录到端口 7000 时,它确实连接了,但是当我尝试连接到 9042(“本机传输”端口)时,我得到一个“连接被拒绝”。所以,不知何故,本地传输没有发生。

我的启动代码:

File file = new File(home, "etc/cassandra.yaml");
System.setProperty("cassandra.config", "file:" + file.getPath());
CassandraDaemon cassandra = new CassandraDaemon();
cassandra.init(null);

我的 cassandra.yaml 包含:

start_native_transport: true
native_transport_port: 9042

日志表明 Cassandra 正在启动。我在日志中看不到对任何本机传输的引用,即使日志级别设置为调试也是如此。没有对端口 9042 的引用。

我在 Windows 上。我不认为这是防火墙问题,因为我正在尝试从 localhost 进行连接。

有什么想法吗?

【问题讨论】:

  • 抱歉我的问题,您使用哪个框架连接到 cassandra?这是赫克托吗?

标签: java cassandra


【解决方案1】:

您是否尝试过调用 .start 方法?

【讨论】:

  • 对不起,如果这是一个愚蠢的问题,但这样的事情发生了。
【解决方案2】:

我在 Achilles 中实现了嵌入式 Cassandra 服务器,工作代码示例如下:https://github.com/doanduyhai/Achilles/blob/master/achilles-core/src/main/java/info/archinnov/achilles/embedded/CassandraEmbedded.java

CassandraDaemon cassandraDaemon = new CassandraDaemon();
cassandraDaemon.activate();

【讨论】:

    猜你喜欢
    • 2017-04-05
    • 2021-10-29
    • 1970-01-01
    • 1970-01-01
    • 2019-03-24
    • 2013-09-14
    • 1970-01-01
    • 2013-10-01
    • 2015-01-03
    相关资源
    最近更新 更多