有没有一种检查 Datastax Session.executeAsync() 是否引发异常的好方法？

Question

我正在尝试通过调用session.executeAsync() 而不是session.execute() 来加快我们的代码写入速度。

我们有数据库连接可能断开的用例，当前之前的execute() 在连接丢失时抛出异常（集群中无法访问主机）。我们可以捕获这些异常并重试或将数据保存在其他地方等...

使用executeAsync()，看起来没有任何方法可以实现这个用例 - 需要访问返回的ResultSetFuture 对象以检查结果，这将违背使用executeAsync() 的目的第一名……

有没有办法在任何地方为 executeAsync() 调用添加一个监听器（或类似的东西），它会异步通知其他一些代码数据库写入失败？

这有关系吗？ 数据税 1.0.2 Java 1.7.40

Answer 1

您可以尝试这样的事情，因为 ResultSetFuture 实现了 Guava 库中的 ListenableFuture：

    ResultSetFuture resultSetFuture = session.executeAsync("SELECT * FROM test.t;");
    Futures.addCallback(resultSetFuture, new FutureCallback<ResultSet>() {
        @Override
        public void onSuccess(@Nullable com.datastax.driver.core.ResultSet resultSet) {
            // do nothing
        }

        @Override
        public void onFailure(Throwable throwable) {
            System.out.printf("Failed with: %s\n", throwable);
        }
    });

这种方法不会阻止您的应用程序。

Answer 2

您可以将回调传递给该方法以对异常采取措施。如果你需要ResultSetFuture，你可以试试这样的：

interface ResultSetFutureHandler {
    void handle(ResultSetFuture rs);
}

public void catchException(ResultSetFutureHandler handler) {
    ResultSetFuture resultSet = null;
    try {
        resultSet = getSession().executeAsync(query);
        for (Row row : results.getUninterruptibly()) {
            // do something
        }
    } catch (RuntimeException e) {
        handler.handle(resultSet); // resultSet may or may not be null
    }
}

然后这样称呼它：

catchException(new ResultSetFutureHandler() {
    void handle(ResultSetFuture resultSet) {
        // do something with the ResultSetFuture
    }
});

如果你想知道异常是什么，也添加一个异常参数：

interface ResultSetFutureHandler {
    void handle(ResultSetFuture rs, RuntimeException e);
}