gocql调用Session.Closed()检查Cassandra会话触发SIGSEGV报错解决

触发SIGSEGV空指针panic的核心原因是你持有的*gocql.Session实例本身为nil，和Closed()方法逻辑无关。
当Cassandra服务停机、连接初始化失败、会话异常销毁时，gocql不会返回有效的Session对象，若代码未校验创建接口返回的error，直接将空值存入全局会话变量，后续对nil指针调用Closed()等任何方法都会直接触发panic。
另外补充：Closed()方法本身就不适用于健康检查场景——该方法仅读取本地会话的主动关闭标记，不会发起任何网络请求，完全无法感知远端服务停机、网络中断等故障，哪怕Cassandra进程已经退出，只要本地没主动调用Close()，该方法都会返回false，根本达不到健康探测的目的。

健康检查需要同时覆盖空指针防护、真实连通性探测、panic兜底三层逻辑，具体步骤如下：

• 调用任何Session相关方法前，先判断实例是否为nil，nil状态直接判定为DOWN
• 废弃Closed()作为健康判断依据，改用短超时的轻量系统查询做真实连通性探测，查询选择无业务副作用的系统表即可，开销极低
• 增加defer recover兜底，避免gocql内部异常状态导致健康检查逻辑本身打崩进程

import (
	"context"
	"time"

	"github.com/gocql/gocql"
)

const (
	StatusUP   = "UP"
	StatusDOWN = "DOWN"
)

// CheckCassandraHealth Cassandra健康检查
func CheckCassandraHealth(session *gocql.Session) string {
	// 空指针直接返回DOWN，避免SIGSEGV
	if session == nil {
		return StatusDOWN
	}

	// 兜底recover，拦截所有可能的panic
	defer func() {
		if r := recover(); r != nil {
			// 可在此处追加panic日志记录，不要向外抛出panic
		}
	}()

	// 设置200ms短超时，避免健康检查阻塞
	ctx, cancel := context.WithTimeout(context.Background(), 200*time.Millisecond)
	defer cancel()

	// 探测查询：查系统本地表固定key，一致性级别设为One，开销最小
	var clusterName string
	err := session.Query(`SELECT cluster_name FROM system.local WHERE key = 'local'`).
		Consistency(gocql.One).
		WithContext(ctx).
		Scan(&clusterName)

	if err != nil {
		return StatusDOWN
	}
	return StatusUP
}

• 修复会话创建逻辑：CreateCassandraCluster返回时，只要err != nil，不要将返回的session对象赋值给全局持有的健康检查变量，直接置为nil，避免拿到半初始化的异常实例
• 不要主动在健康检查逻辑里调用Close()释放会话，避免影响正常业务请求
• 超时时间根据实际部署场景调整，同机房部署建议不超过300ms，跨可用区部署可适当放宽到500ms

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