4

我是使用 astyanax 连接到 cassandra(1.2.8) 的新手。我从 [https://github.com/Netflix/astyanax] 下载了 astyanax，从 [http://www.apache.org/dyn/closer.cgi?path=/cassandra/1.2.8/apache-cassandra- 1.2.8-bin.tar.gz]。一切都是根据指​​令安装/构建并保持默认设置（如 conf/cassandra.yaml）。现在我尝试运行示例代码 [https://github.com/Netflix/astyanax/blob/master/astyanax-examples/src/main/java/com/netflix/astyanax/examples/AstCQLClient.java] 和一个令人作呕的错误一直困扰着我（在日食中显示）：

引起：com.netflix.astyanax.connectionpool.exceptions.PoolTimeoutException：PoolTimeoutException：[host=127.0.0.1(127.0.0.1):9160，latency=5021(5021)，尝试=1]等待连接超时

当我启用 cassandra 调试模式时，终端上会显示以下内容：

调试 17:06:48,968 处理消息期间发生 Thrift 传输错误。org.apache.thrift.transport.TTransportException：无法读取。远程端已关闭。试图读取 4 个字节，但只得到 0 个字节。（这通常表示服务器端出现内部错误。请检查您的服务器日志。）在 org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) 在 org.apache.thrift.protocol.TBinaryProtocol .readAll(TBinaryProtocol.java:378) 在 org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) 在 org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) 在 org. apache.thrift.TBaseProcessor.process(TBaseProcessor.java:22) 在 org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:199) 在 java.

只是强调一下，我没有更改 cassandra.yaml 中的任何内容（实际上我不知道它们是什么意思）；来自 astyanax 和 cassandra-1.2.8 的所有库都导入到 java 项目中。我想问题是由于当我尝试通过帧转换刷新时连接将关闭......我是数据库的菜鸟。我非常感谢所有的帮助！

附言。我正在等待stackoverflow。如果您需要检查任何日志（请同时给我找到它的目录。我是菜鸟>_<），只要说，我会获取它。非常感谢！！

4

1 回答 1

1

尽管这是一个老问题，我不确定我的建议是否会对任何人有所帮助，但我遇到了同样的错误，这就是我解决它的方法。希望这将帮助另一个可怜的灵魂。

我看到了同样的错误“无法读取远程端已关闭”，但我使用的是 csharp、Apache.Cassandra 命名空间和 Thrift.dll。

以下是一个工作片段，

    TSocket socket = null;
    TTransport transport = null;

    socket = new TSocket("localhost", 9160);


    transport = new TFramedTransport(socket);
    TProtocol protocol = new TBinaryProtocol(transport);
    CassandraClient cassandraClient = new CassandraClient(protocol);
    cassandraClient.InputProtocol.Transport.Open();

诀窍是使用 cassandraClient.InputProtocol.Transport.Open(); 而不是 transport.open()

于 2014-08-03T16:42:10.677 回答