直接用 database/sql 做 cqrs 会出问题，因 go 无开箱即用框架，硬套易致读写共用同一 *sql.db 实例，引发事务污染、连接池争用、读请求被写锁拖慢；正确做法是物理分离读写数据源，写库配小连接池并启用连接生命周期管理，读库单独初始化、禁用写操作且显式指向只读副本。
为什么直接用 database/sql 做 CQRS 会出问题
Go 里没有“开箱即用”的 CQRS 框架，硬套概念容易让读写共用同一 *sql.DB 实例，导致事务污染、连接池争用、读请求被写锁拖慢。典型表现是：后台定时任务执行 UPDATE 时，API 的 SELECT 响应延迟飙升，甚至超时。
真正可行的起点不是设计事件总线，而是物理分离读写数据源：
- 写库（主库）用
*sql.DB配置maxOpenConns较小（如 20），启用SetConnMaxLifetime防连接老化 - 读库（从库）单独建
*sql.DB，maxOpenConns可设为 100+，且禁用Exec/QueryRow以外的写操作（靠封装拦截） - 读库连接字符串必须显式指向只读副本，不能依赖 DNS 轮询或代理自动识别
如何用结构体字段控制读写路由
别在每个 handler 里手动选 DB，把路由逻辑收口到 Repository 层。关键不是抽象接口，而是让结构体自己“知道”该走哪条路：
type UserRepo struct {
writer *sql.DB // only for INSERT/UPDATE/DELETE
reader *sql.DB // only for SELECT
}
<p>func (r *UserRepo) Create(u User) error {
_, err := r.writer.Exec("INSERT INTO users ...", u.Name)
return err
}</p><p>func (r <em>UserRepo) FindByID(id int) (User, error) {
var u User
err := r.reader.QueryRow("SELECT </em> FROM users WHERE id = ?", id).Scan(&u.ID, &u.Name)
return u, err
}</p>
注意：reader 和 writer 必须是两个独立初始化的 *sql.DB，共享同一个 *sql.DB 实例再加 if 判断毫无意义——底层连接池和事务状态完全混在一起。
sql.Tx 只能用于写操作，读操作绝不应进事务
常见错误是给查询方法也套上 BeginTx，以为“统一事务管理”。但 MySQL 的 REPEATABLE READ 隔离级别下，只读事务仍会持锁、占连接、触发 MVCC 版本链遍历，吞吐直接掉一半。
Go 配置库，使用 spf13/viper — 分层优先级（flag > env >file > KV > default），提供 BindPFlag/BindPFlags、SetEnvPrefix + SetEnvKeyReplace 等功能。
正确做法：
- 写操作：用
tx, err := repo.writer.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelReadCommitted}) - 读操作：永远直连
repo.reader，不调BeginTx，不传context.WithTimeout给QueryRow（超时应在 HTTP 层或 service 层控制） - 如果读场景真需要一致性（比如查余额后立即下单），那就不是“CQRS 读”，而是“强一致读”，应走写库 + 显式事务，此时 CQRS 模式已退化，需在文档里明确标注例外路径
缓存层不能替代读库分离
加 Redis 缓存 GET user:123 看似解决读压力，但掩盖了更根本的问题：缓存未命中时，回源查询仍打在主库上。一旦缓存雪崩，所有读请求瞬间压垮写库。
所以缓存和读库分离是两件事，必须同时做：
- 缓存 key 设计要包含版本号或更新时间戳，避免脏读
- 写操作成功后，先删缓存（
DEL user:123），再异步刷新（或靠 binlog 监听），不要同步写缓存 - 所有
reader查询都应带FOR UPDATE或LOCK IN SHARE MODE的地方，必须回归写库——读库不支持这些语法，强行用会报错ERROR 1290 (HY000): The MySQL server is running with the --read-only option
最易被忽略的一点：读库延迟。MySQL 主从同步有秒级延迟，业务代码里不能假设 Create 后立刻能在 FindByID 查到，得要么重试读取，要么前端轮询，要么改用写库查（并接受性能代价）。这个权衡点，文档里常一笔带过，但上线后第一个报警就是它。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
