你可以试试这样的 ResultSetFuture 工具 ListenableFuture 来自guava图书馆：

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);
        }
    });

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

您可以将回调传递给该方法以对异常执行操作。如果你需要 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);
}