Golang mgo驱动指定Mongo服务器读取

Replica Sets搭建

服务器采用Replica Sets搭建，可参考Deploy a Replica Set

读模式

Mongod的读模式共有五种：

• primary. 在主节点上进行全部的读操做
• primaryPreferred. 优先在主节点上进行读操做，若是主节点不可用，再从从节点操做。
• secondary.全部的读操做在从节点上进行。
• secondaryPreferred.优先在从节点进行读操做，若是全部从节点都不可用，再从主节点操做。
• nearest. 根据网络延迟时间 ，就近进行读操做，不考虑节点类型。

配置节点Tags Sets

Tag sets 容许指定一个replica set进行读操做，其中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代码示例

根据以上的配置，若是须要指定从members 1中进行数据库读操做，可采起如下代码：

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)