使用XORM EngineGroup实现读写分离需先独立初始化Master和Slave引擎并验证连通性,再通过NewEngineGroup创建引擎组并指定策略,最后配置连接池与生命周期参数,读写操作自动路由。

要在Go项目中使用XORM的EngineGroup实现数据库读写分离或负载均衡,必须明确区分Master和Slave节点,并确保各引擎实例已独立初始化完成,否则NewEngineGroup会直接panic。
准备独立的Master与Slave引擎实例
先分别创建Master和Slave的*xorm.Engine,不能复用同一个Engine对象。每个Engine必须调用Ping()验证连通性,否则EngineGroup在首次操作时可能静默失败。
Master引擎必须使用写权限账号连接主库;Slave引擎必须使用只读账号连接从库,【若Slave库误配了写权限账号,可能导致事务被从库拒绝或数据不一致】。
示例中PostgreSQL的Slave连接串需显式添加?sslmode=disable(除非服务端强制SSL);MySQL则需确保read_only=1已在从库生效。
用NewEngineGroup创建引擎组
方法一:传入DriverName + DataSourceNames切片
DriverName必须与所有DataSourceName匹配(如全为"postgres"或全为"mysql"),DataSourceNames[0]是Master地址,后续元素为Slave地址。
方法二:传入*xorm.Engine + []*xorm.Engine切片
第一个参数是Master引擎指针,第二个参数是Slave引擎指针切片(可为空)。此方式允许Master与Slave使用不同驱动(例如Master用MySQL、Slave用TiDB兼容层),但实际生产环境极少需要。
两种方式都必须传入GroupPolicy参数,常用值为xorm.GroupRandom或xorm.GroupRoundRobin;【若传nil,NewEngineGroup将返回error且不 panic,但后续所有查询都会失败】。
配置连接池与生命周期策略
第一步:获取EngineGroup底层的Master引擎引用
engineGroup.GetMaster().SetMaxOpenConns(50)
第二步:遍历所有Slave引擎并单独设置
for _, slave := range engineGroup.GetSlaves() { slave.SetMaxOpenConns(30) }
第三步:统一设置空闲连接最大存活时间
engineGroup.SetConnMaxIdleTime(30 * time.Minute)
第四步:强制所有连接最长存活8小时(匹配MySQL默认wait_timeout)
engineGroup.SetConnMaxLifetime(8 * time.Hour)
注意:SetConnMaxLifetime必须设为非零值,否则大量CLOSED_WAIT连接会在凌晨堆积,最终触发“too many connections”错误。
执行读写分离操作
写操作自动路由到Master:engineGroup.Insert(&user)
读操作默认轮询Slave:engineGroup.Find(&users)
强制走Master读取(如刚写入需立即查):engineGroup.UseMaster().Find(&users)
强制指定某个Slave读取(调试或灰度):engineGroup.UseSlave(1).Find(&users) ——索引从0开始,越界则回退到随机策略。


















