Gorm 读写分离(转)
作者:互联网
在gorm v2版本中,我们可以看到已经支持读写分离,那读写分离是基于主从复制的,所以我们要先配置mysql的主从复制
1、为什么需要主从复制?
在业务复杂的系统中,有这么一个情景:如果有一句sql语句需要锁表,导致暂时不能使用读的服务,那么就很影响运行中的业务。使用主从复制,让主库负责写,从库负责读,这样,即使主库出现了锁表的情景,通过读从库也可以保证业务的正常运作。
做数据的热备
业务量越来越大,I/O访问频率过高,单机无法满足,此时做多库的存储,降低磁盘I/O访问的频率,提高单个机器的I/O性能。
2、 什么是主从复制?
MySQL 主从复制是指数据可以从一个MySQL数据库服务器主节点复制到一个或多个从节点。
MySQL 默认采用异步复制方式,这样从节点不用一直访问主服务器来更新自己的数据,数据的更新可以在远程连接上进行,从节点可以复制主数据库中所有的数据库或者特定的数据库,或者特定的表。
节选自:Gorm 读写分离
3、实现
import (
"gorm.io/gorm"
"gorm.io/plugin/dbresolver"
"gorm.io/driver/mysql"
)
db, err := gorm.Open(mysql.Open("db1_dsn"), &gorm.Config{})
db.Use(dbresolver.Register(dbresolver.Config{
// use `db2` as sources, `db3`, `db4` as replicas
Sources: []gorm.Dialector{mysql.Open("db2_dsn")},
Replicas: []gorm.Dialector{mysql.Open("db3_dsn"), mysql.Open("db4_dsn")},
// sources/replicas load balancing policy
Policy: dbresolver.RandomPolicy{},
}).Register(dbresolver.Config{
// use `db1` as sources (DB's default connection), `db5` as replicas for `User`, `Address`
Replicas: []gorm.Dialector{mysql.Open("db5_dsn")},
}, &User{}, &Address{}).Register(dbresolver.Config{
// use `db6`, `db7` as sources, `db8` as replicas for `orders`, `Product`
Sources: []gorm.Dialector{mysql.Open("db6_dsn"), mysql.Open("db7_dsn")},
Replicas: []gorm.Dialector{mysql.Open("db8_dsn")},
}, "orders", &Product{}, "secondary"))
参考:DBResolver
4、疑问
读resolver会从从库读取数据,只能做读操作,写resolver直接操作主库,可以同时做读写操作。但是发现读resolver也能做写操作,这里推测可能是未开启主从复制,导致主从库是同一个,从而读写resolver的source源是同一个,所以读 reolver 既可以读也可以写,存疑,待考证。
标签:主从复制,读写,分离,dbresolver,gorm,dsn,mysql,Open,Gorm 来源: https://www.cnblogs.com/hi3254014978/p/16440769.html