DataStax Cassandra java驱动程序在数百次插入后与NoHost可用性异常一起崩溃

Question

我想写一个应用程序，将5个字符串（与文件资产相关）写入卡桑德拉。我根据数据斯塔克斯文档中的教程编写了代码。它可以工作大约 30 秒，进行几百次插入，但崩溃并出现错误：

Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (no host was tried)
    at com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:65)
    at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:256)
    at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:172)
    at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
...
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:744)
Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (no host was tried)
    at com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:103)
    at com.datastax.driver.core.SessionManager.execute(SessionManager.java:368)
    at com.datastax.driver.core.SessionManager.executeQuery(SessionManager.java:404)
    at com.datastax.driver.core.SessionManager.executeAsync(SessionManager.java:85)
    ... 8 more

该过程仍在运行，我可以重新运行单元测试，并得到相同的结果:几百次插入，然后出现这个错误。服务器没有显示出任何故障或错误的迹象。

我正在使用驱动程序：

    <dependency>
        <groupId>com.datastax.cassandra</groupId>
        <artifactId>cassandra-driver-core</artifactId>
        <version>2.0.3</version>
    </dependency>

这是我的客户端代码：

private static final String BOUND_STATEMENT = "INSERT INTO myschema.files(file_name, md5, last_modified, size, hash_date) "
        + "VALUES (?, ?, ?, ?, ?);";
@Override
public void persist(FileEntry entry) {
    Session session = cluster.connect();
    //prepare statement, if it doesn't exist.
    if (persistPs == null) {
        persistPs = session.prepare(BOUND_STATEMENT);
    }
    BoundStatement boundStatement = new BoundStatement(persistPs);
    session.execute(boundStatement.bind(entry.getFileName(), entry.getMd5(), entry.getLastModified(),
            entry.getSize(), entry.getHashDate()));
    session.close();
    System.out.print(".");
}

我正在我的本地主机上运行卡桑德拉2.0.9（带有固态驱动器和最新Macbook的OSX）。

关于如何使它不崩溃的任何线索？如果这只是 DataStax 驱动程序的问题，我很乐意使用任何其他驱动程序。

我不会产生太严重的负载，服务器进程也不会抛出任何异常或提示，说明可能出现的问题。我听说过其他组织在Cassandra上取得了成功，所以我认为这是我的客户代码。

谢谢

Answer 1

BryceAtNetwork23是正确的。通过我将会话对象从一个调用传递到另一个调用，问题得到了“解决”。

public final void persist(final FileEntry entry, final Session session) {
    prepareInsertStatement(session);
    final BoundStatement boundStatement = new BoundStatement(persistPs);
    //bind values from our bean to our insert query
    session.execute(boundStatement.bind(entry.getFileName(), entry.getMd5(), entry.getLastModified(),
            entry.getSize(), entry.getHashDate()));
}

private final synchronized void prepareInsertStatement(final Session session) {
    // prepare statement, if it doesn't exist.
    if (persistPs == null) {
        persistPs = session.prepare(BOUND_STATEMENT);
    }
}

我不知道这是Cassandra引擎的可扩展性还是DataStax驱动程序的问题，但通常情况下，我必须比一天在一个平台上工作更努力才能让它屈服。不管怎样，我对他们的留档感到沮丧。我从来没有在一个平台上遇到过这么多问题，让它在不崩溃的情况下运行。他们的例子在大约1000次插入后崩溃了一个节点。如果我们正在评估Cassandra，我们很可能想要插入超过1000行的数据。

也就是说，一旦我从一个调用传递到另一个调用，代码运行得非常快，执行得也很好。我有一些矛盾，但我很高兴一切终于工作。谢谢大家的帮助。