首页 文章

告诉Datastax Java Cassandra驱动程序超时集群连接

提问于
浏览
5

如何在尝试连接到群集时告诉Datastax Java Cassandra驱动程序超时?

我对主机可以访问的情况特别感兴趣,但是Cassandra端口被阻塞或者Cassandra守护进程没有运行 . 我正在编写一个命令行客户端,如果它无法在合理的时间内连接,则应退出并报告合适的错误消息 . 目前,如果联系点可以到达,驱动程序似乎将永远等待接触点响应 .

也就是说,如果驱动程序在给定的最大时间内无法与任何接触点的Cassandra守护进程通信,我希望Cluster.build()抛出NoHostAvailableException .

  • 创建我自己的RetryPolicy将无效:这是为了重试查询,我希望在我们准备运行查询之前应用超时 .

  • 创建我自己的ReconnectinoPolicy最初看起来很有希望,但是接口的 Contract 没有给出指示的方法"consider this node to be dead forever more"

1 回答

  • 7

    也就是说,如果驱动程序无法在给定的最大时间内与任何联系点的Cassandra守护程序通信,我希望Cluster.build()抛出NoHostAvailableException .

    应该是这种情况 . 驱动程序将尝试连接到每个联系点,如果无法连接到任何联系点,则抛出异常 . 您可以通过SocketOptions.setConnectTimeoutMillis()控制驱动程序尝试连接(到每个节点)的最长时间(默认值为5秒) .

    我的经验是,如果没有节点可以连接,Cluster.build()确实会返回异常,但如果您的体验不同,您可能希望将其报告为错误(但有关如何重现这一点的更多详细信息会有所帮助) .

    话虽如此:

    • 上面的超时是每个主机 . 因此,如果您传递100个联系点的列表,理论上您必须等待500秒(默认情况下)才能获得NoHostAvailableException . 但是提供那么多接触点没有任何意义,实际上,如果Cassandra没有在尝试的节点上运行,连接尝试通常会立即失败(你不会等待超时) .

    • 目前驱动程序端没有真正的查询超时 . 这意味着如果驱动程序确实连接到一个节点(这意味着某个进程正在侦听该端口并接受连接),但是没有得到他的初始消息的答案,那么它确实可以永久保留 . 这应该是固定的,我鼓励你在https://datastax-oss.atlassian.net/browse/JAVA打开一张票 . 但是,这并不能在第一时间连接 .

相关问题