gocql驱动中不应复用session.Clone()应对高并发写，因其仅复制配置而不隔离连接池与执行器状态，易引发“no hosts available”或超时；应通过调整ProtoVersion、NumConnsPerHost、使用Unlogged Batch、启用TokenAware策略及显式关闭Session来优化。
为什么 gocql 驱动的 Session 不该复用 session.Clone() 来应对高并发写
直接复用 session.Clone() 生成新 session 是常见误区。它只复制会话配置，不隔离底层连接池和执行器状态，高并发下容易触发 gocql: no hosts available 或 context deadline exceeded——本质是连接争用和内部队列阻塞。
- 真正需要的是连接池粒度控制：通过
ClusterConfig.ProtoVersion设为4（Cassandra 3.6+ 推荐），并显式设置ClusterConfig.NumConnsPerHost = 4（单 host 默认 2，写密集场景至少翻倍） - 避免在 handler 内反复调用
session.Query(...).Exec()：每次 Query 创建新执行单元，开销大；应改用session.Batch()批量写，或预编译语句session.Prepare()+stmt.Bind().Exec() - 务必关闭自动重试：
ClusterConfig.Timeout = 1500 * time.Millisecond，并设ClusterConfig.RetryPolicy = &gocql.NoRetryPolicy{}，否则网络抖动时重试放大写压力
如何用轻量级 gocql.BatchTypeUnlogged 实现每秒百万级写入
Logged batch 在 Cassandra 中用于保证原子性，但写放大严重，完全不适合高吞吐写入；Unlogged batch 不跨 partition，性能接近单条，且规避了 coordinator 节点瓶颈。
- 必须确保 batch 中所有语句目标 partition key 完全一致，否则会报
Invalid query: Batch statements cannot span multiple partitions - 单个 batch 行数建议 ≤ 20（实测超过 50 易触发 coordinator OOM），配合
session.SetConsistency(gocql.LocalQuorum)平衡一致性与延迟 - 不要手动拼接 batch：用
batch := session.NewBatch(gocql.BatchTypeUnlogged)，再循环batch.Query("INSERT ...", args...)，最后session.ExecuteBatch(batch)
写热点导致某节点 CPU 暴涨？检查 token-aware load balancing 是否启用
Cassandra 默认 round-robin 负载策略会让写请求均匀打到所有节点，但实际数据分布由 partition key 的 token 决定——若大量写同 prefix 的 key（如 "user_123:order_*），所有请求都会路由到同一 replica 节点。
Go 配置库，使用 spf13/viper — 分层优先级（flag > env >file > KV > default），提供 BindPFlag/BindPFlags、SetEnvPrefix + SetEnvKeyReplace 等功能。
- 启用 token-aware 策略后，驱动自动将请求发往负责该 token range 的节点，减少网络跳转；需确认
ClusterConfig.PoolConfig.HostSelectionPolicy = gocql.TokenAwareHostPolicy(gocql.RoundRobinHostPolicy()) - 验证是否生效：开启
gocql.Debug日志，观察日志中是否出现using token-aware policy和routing to host xxx - 根本解法是重构 partition key：加入随机前缀（如
rand.Intn(100)）或时间桶（如YYYYMMDD），把写分散到多个 token range
为什么 gocql.Session.Close() 必须在进程退出前调用，且不能 defer
gocql 的连接池不会自动 GC，session.Close() 不仅释放 socket，还会触发后台 goroutine 清理（如 hostUp/Down 监听、query metrics collector）。若仅靠 defer，在 long-running service 中可能因 panic 或提前 return 导致漏调。
立即学习“go语言免费学习笔记（深入）”；
- 正确做法：在 main 函数结尾或 signal handler（如
os.Interrupt）中显式调用session.Close()，并等待session.Closed()返回 true - 禁止在 http handler 或 goroutine 中 defer
session.Close()：这会立刻断开整个 session，影响其他并发请求 - 若使用 wire/dig 等 DI 框架，应在 provider cleanup 阶段注册
func() error { return session.Close() }
真实压测中，写入瓶颈往往卡在 coordinator 节点的 network buffer 或单 partition 的 memtable flush 频率，而不是驱动本身——驱动层能做的，是别让它成为第一道墙。
