我正在尝试通过调用session.executeAsync()
而不是session.execute()
来加速我们的代码,以进行数据库写入。
我们有一些用例,在这些用例中DB连接可能会中断,当前的execute()
在连接丢失时会抛出异常(无法连接到集群中的任何主机)。我们可以捕获这些异常并重试或将数据保存到其他地方等...
使用executeAsync()
似乎没有任何方法来实现此用例 - 返回的ResultSetFuture
对象需要被访问以检查结果,这将破坏首次使用executeAsync()
的目的...
是否有任何方法可以在任何地方添加监听器(或类似内容)来异步通知其他代码DB写入失败的情况?
这与以下版本相关:
Datastax 1.0.2
Java 1.7.40