如何检查Cassandra会话是否活跃并实现健康检测

Cassandra官方生态有和MySQL sql.Ping() 完全对等的会话健康检查能力，不需要自己实现复杂逻辑，具体用法如下：

• 优先用驱动内置的Ping方法
  目前主流官方维护的Cassandra驱动，大部分都直接提供了命名为Ping()的原生探活接口，调用逻辑和MySQL的sql.Ping()完全一致：只会校验当前会话连接池是否存在可用连接、和集群的通信链路是否正常，不会执行多余的业务逻辑，返回空值代表会话可用，返回错误即代表会话异常。
  以最常用的Go版gocql驱动为例，直接调用session.Ping()即可完成探活。
• 无内置Ping方法时的标准替代方案
  部分版本的驱动没有提供显式的Ping接口，直接执行Cassandra生态通用的轻量探活语句即可，开销和原生Ping完全一致：

  SELECT now() FROM system.local WHERE key = 'local'
  

  这个语句只会触发连接到的协调节点本地查询，不会产生跨节点通信、不会访问业务表、返回数据量极小，是社区公认的标准探活语句，执行不报错就代表会话可用。

探活注意事项 #

• 不要仅以会话初始化成功作为会话可用的判断依据：初始化成功只代表建连阶段集群可达，后续网络闪断、节点宕机、连接池耗尽都可能让会话进入不可用状态，业务运行阶段的探活必须主动触发，或者依赖驱动自带的后台心跳机制。
• 不要用自定义复杂查询做探活：比如查询业务表、带聚合/多表关联的查询，会给集群增加不必要的压力，完全没有必要。
• 官方驱动默认开启连接池后台心跳，通常间隔30秒会自动探测并剔除死连接、补建新连接，如果业务没有快速探活的强需求（比如K8s就绪探针、服务启动前置校验、流量切分前的节点检查），不需要额外主动探活，驱动在执行业务查询前会自动过滤不可用连接。

内容的提问来源于stack exchange，提问作者Mesc