Golang mgo驅(qū)動(dòng)指定Mongo服務(wù)器讀取

rollback 發(fā)布于2019-06-26 16:49 / 713人閱讀

摘要：搭建服務(wù)器采用搭建，可參考讀模式的讀模式共有五種在主節(jié)點(diǎn)上進(jìn)行所有的讀操作優(yōu)先在主節(jié)點(diǎn)上進(jìn)行讀操作，如果主節(jié)點(diǎn)不可用，再?gòu)膹墓?jié)點(diǎn)操作。

Replica Sets搭建

服務(wù)器采用Replica Sets搭建，可參考Deploy a Replica Set

讀模式

Mongod的讀模式共有五種：

primary. 在主節(jié)點(diǎn)上進(jìn)行所有的讀操作

primaryPreferred. 優(yōu)先在主節(jié)點(diǎn)上進(jìn)行讀操作，如果主節(jié)點(diǎn)不可用，再?gòu)膹墓?jié)點(diǎn)操作。

secondary.所有的讀操作在從節(jié)點(diǎn)上進(jìn)行。

secondaryPreferred.優(yōu)先在從節(jié)點(diǎn)進(jìn)行讀操作，如果所有從節(jié)點(diǎn)都不可用，再?gòu)闹鞴?jié)點(diǎn)操作。

nearest. 根據(jù)網(wǎng)絡(luò)延遲時(shí)間，就近進(jìn)行讀操作，不考慮節(jié)點(diǎn)類型。

配置節(jié)點(diǎn)Tags Sets

Tag sets 允許指定一個(gè)replica set進(jìn)行讀操作，其中Mongod的讀模式必須是以下四種之一：
primaryPreferred、secondary、secondaryPreferred、nearest
Tags Sets配置參考：Configure Replica Set Tag Sets
主要操作如下：

conf = rs.conf()
conf.members[0].tags = { "dc": "east", "use": "production"  }
conf.members[1].tags = { "dc": "east", "use": "reporting"  }
conf.members[2].tags = { "use": "production"  }
rs.reconfig(conf)

mgo代碼示例

根據(jù)以上的配置，如果需要指定從members 1中進(jìn)行數(shù)據(jù)庫(kù)讀操作，可采取以下代碼：

session, err := mgo.Dial("localhost")
if err != nil {
    log.Fatalln(err)
}
defer session.Close()
session.SetMode(mgo.Eventual, true) //需要指定為Eventual
session.SelectServers(bson.D{{"dc", "east"}, {"use", "reporting"}}) // 指定從1中讀取
db := session.DB("test")
col := db.C("tbl")
data := make([]interface{}, 10)
col.Find(nil).Limit(10).All(&data)
log.Println(data)