七叶笔记 » golang编程 » Golang + MongoDB ReplSet副本集

Golang + MongoDB ReplSet副本集

本文介绍MongoDB副本集,暂且按照3个节点来配置:A( PRIMARY )、B(secondary)、C(arbiter)

  1. 在集群每个节点上安装一份MongoDB;

  2. 配置副本集;

  3. 配置副本集的用户名、密码;

  4. 配置副本集的KeyFile安全鉴权;

  5. 配置开机启动;

  6. golang连接MongoDB副本集,并执行CRUD操作;

每个节点IP:

  • A节点: 11.11.11.11

  • B节点: 22.22.22.22

  • C节点: 33.33.33.33

第一步: 安装MongoDB

每个节点安装 mongodb

vi /etc/yum.repos.d/mongodb-enterprise.repo 

在mongodb-enterprise.repo文件中加入以下内容

然后运行以下命令

sudo yum install -y mongodb-enterprise 

配置mongod.conf

先创建以下目录

/test/db/mongodb

|–logs

|–keyfiles

|–data

再配置日志文件的路径、数据目录、副本集名称

> vi /etc/mongod.conf

systemLog:

path: /test/db/mongodb/logs/mongod.log #日志文件的路径

storage:

dbPath: /test/db/mongodb/data #数据目录

net:

port: 27017

bindIp: 11.11.11.11 #客户端通过此ip连接

replication:

replSetName: “rs0” #副本集名称

注意 : 数据目录、日志文件目录要将用户改为mongod

chown mongod:mongod -R /test/db/mongodb/data

chown mongod:mongod -R /test/db/mongodb/logs

分别启动每个节点:A、B、C节点

mongod --config /etc/mongod.conf 

第二步: 组建副本集

假设我们要将A结点作为 primary , B结点作为 secondary , C结点作为 arbiter

在A结点(11.11.11.11)这台机器上运行

mongo 

连接成功后,开始配置副本集:

> config = {

“_id”: “rs0”,

“members”: [

{

“_id”: 0,

“host”: “11.11.11.11:27017”

}

]

}

> rs.initiate(config) #初始化副本集

{ “ok” : 1 }

> rs.add({host: ‘22.22.22.22:27017’})

> rs.addArb(‘33.33.33.33:27017’)

> rs.status() #查看副本集状态,找到primary节点的IP

第三步: 创建帐户密码

副本集搭建成功后,需要给整个副本集创建帐户、密码

在A结点(primary)上,用客户端连接,创建用户权限(主节点,可以用 rs.status() 查看)

[root@servera ~]# mongo

rs0:PRIMARY> use admin

switched to db admin

#创建超级管理员:root

replSet:PRIMARY> db.createUser({

“user”: “root”,

“pwd”: “rootpwd”,

“roles”: [

{

“role”: “root”,

“db”: “admin”

}

]

})

Successfully added user: {

“user” : “root”,

“roles” : [

{

“role” : “root”,

“db” : “admin”

}

]

}

rs0:PRIMARY> use mytest #创建mytest数据库

switched to db mytest

#创建mytest数据库管理员

replSet:PRIMARY> db.createUser({

“user”: “mytest”,

“pwd”: “mytestpwd”,

“roles”: [

{

“role”: “dbOwner”,

“db”: “mytest”

}

]

})

Successfully added user: {

“user” : “mytest”,

“roles” : [

{

“role” : “dbOwner”,

“db” : “mytest”

}

]

}

第四步: 创建keyfile

创建key文件, 三个节点必须要用同一份keyfile,在一台机器生成,拷贝到另外两台,并且修改成 400 的文件属性。

结点A、结点B、结点C上都创建 /test/db/mongodb/keyfiles 目录, 然后在结点A上输入以下命令

openssl rand -base64 756 > /test/db/mongodb/keyfiles/keyfile
chmod 400 /test/db/mongodb/keyfiles/keyfile 

并且把这份keyfile同步到其他两个节点的 /test/db/mongodb/keyfiles 目录下;

关闭副本集的所有成员

先关闭结点B(secondary)上的mongod, 再关闭结点C(arbiter)上的mongod, 最后关闭结点A(primary)上的mongod

分别依次在B, C, A上运行mongo shell, 然后再输入以下命令来关闭mongod

use admin
db.shutdownServer() 

修改每个节点的配置文件mongo.conf中的security配置项:

security:
 keyFile: /test/db/mongodb/keyfiles/keyfile
 authorization: enabled 

注意 :三台机器都要修改mongod.conf。另外,keyfiles目录要将用户改为mongod

chown mongod:mongod -R /test/db/mongodb/keyfiles 

重新启动副本集

[root@servera ~]# mongod -f /etc/mongod.conf #机器A

[root@serverb ~]# mongod -f /etc/mongod.conf #机器B

[root@serverc ~]# mongod -f /etc/mongod.conf #机器C

第五步: 设置MongoDB开机启动

[root@servera ~]# systemctl enable mongod. service

[root@serverb ~]# systemctl enable mongod.service

[root@serverc ~]# systemctl enable mongod.service

第六步: Golang连接MongoDB

package main

import (	
 "os"
"fmt"
"github.com/globalsign/mgo")func main() {	 // user, password, rs0分别为用户名、密码、副本集,请自行修改
URL := "mongodb://user:password@11.11.11.11,22.22.22.22/database?replicaSet=rs0"
session, err := mgo.Dial(URL)	 if err != nil {
fmt.Println(err.Error())
os.Exit(-1)
}
session.SetMode(mgo.Monotonic, true)
Conn := session.DB("")	// 获得 Mongodb的连接后,再就可以进行各种CRUD啦
} 

本文由 shen100 原创, Golang中文社区 首发,现同步到头条。欢迎转载, 请在正文中标明原文链接及作者,谢谢。也欢迎来 Golang中文社区 学习、交流。

相关文章