1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
| #!/bin/bash
REPLICA_SET_NAME="rs0"
MONGO_PORT=27017
DATA_DIR="/data/mongodb"
LOG_DIR="/var/log/mongodb"
CONFIG_DIR="/etc/mongodb"
ADMIN_USER="admin"
ADMIN_PASS="admin123"
start_mongodb_services() {
echo "启动MongoDB副本集三节点服务..."
echo "启动主节点..."
mongod --config $CONFIG_DIR/mongod-primary.conf
sleep 5
echo "启动从节点1..."
mongod --config $CONFIG_DIR/mongod-secondary1.conf
sleep 5
echo "启动从节点2..."
mongod --config $CONFIG_DIR/mongod-secondary2.conf
sleep 5
echo "MongoDB副本集三节点服务启动完成"
}
initialize_replica_set() {
echo "初始化MongoDB副本集三节点..."
mongo --port $MONGO_PORT << EOF
// 初始化MongoDB副本集三节点
// @author 运维实战
// 初始化副本集配置
rs.initiate({
_id: "$REPLICA_SET_NAME",
members: [
{
_id: 0,
host: "localhost:$MONGO_PORT",
priority: 2,
tags: { "dc": "primary", "role": "primary", "hardware": "4c8g" }
},
{
_id: 1,
host: "localhost:$((MONGO_PORT + 1))",
priority: 1,
tags: { "dc": "secondary", "role": "secondary", "hardware": "4c8g" }
},
{
_id: 2,
host: "localhost:$((MONGO_PORT + 2))",
priority: 1,
tags: { "dc": "secondary", "role": "secondary", "hardware": "4c8g" }
}
],
settings: {
heartbeatIntervalMillis: 2000,
electionTimeoutMillis: 10000,
catchUpTimeoutMillis: 2000,
catchUpTakeoverDelayMillis: 30000
}
});
// 等待副本集初始化完成
print("等待副本集初始化完成...");
while (rs.status().ok !== 1) {
sleep(1000);
}
// 检查副本集状态
print("副本集状态:");
rs.status();
print("副本集三节点初始化完成");
EOF
echo "副本集三节点初始化完成"
}
create_users() {
echo "创建MongoDB用户账户..."
sleep 10
mongo --port $MONGO_PORT << EOF
// 创建MongoDB用户账户
// @author 运维实战
use admin;
// 创建管理员用户
db.createUser({
user: "$ADMIN_USER",
pwd: "$ADMIN_PASS",
roles: [
{ role: "root", db: "admin" },
{ role: "clusterAdmin", db: "admin" },
{ role: "userAdminAnyDatabase", db: "admin" },
{ role: "dbAdminAnyDatabase", db: "admin" }
]
});
// 创建应用用户
use appdb;
db.createUser({
user: "appuser",
pwd: "app123",
roles: [
{ role: "readWrite", db: "appdb" },
{ role: "read", db: "appdb" }
]
});
// 创建只读用户
use appdb;
db.createUser({
user: "readonly",
pwd: "read123",
roles: [
{ role: "read", db: "appdb" }
]
});
print("用户账户创建完成");
EOF
echo "用户账户创建完成"
}
configure_replica_set_optimization() {
echo "配置副本集优化..."
mongo --port $MONGO_PORT -u $ADMIN_USER -p $ADMIN_PASS --authenticationDatabase admin << EOF
// 配置副本集优化
// @author 运维实战
use admin;
// 配置副本集设置
var config = rs.conf();
config.settings.heartbeatIntervalMillis = 2000;
config.settings.electionTimeoutMillis = 10000;
config.settings.catchUpTimeoutMillis = 2000;
config.settings.catchUpTakeoverDelayMillis = 30000;
// 应用配置
rs.reconfig(config);
// 设置从节点读取偏好
rs.slaveOk();
// 配置读写分离
db.getMongo().setReadPref("secondaryPreferred");
// 配置写入关注
db.getMongo().setWriteConcern({
w: "majority",
j: true,
wtimeout: 5000
});
print("副本集优化配置完成");
EOF
echo "副本集优化配置完成"
}
verify_deployment() {
echo "验证MongoDB副本集三节点部署结果..."
mongo --port $MONGO_PORT -u $ADMIN_USER -p $ADMIN_PASS --authenticationDatabase admin << EOF
// 验证MongoDB副本集三节点部署结果
// @author 运维实战
use admin;
// 检查副本集状态
print("=== 副本集部署验证 ===");
var status = rs.status();
print("副本集成员数量: " + status.members.length);
// 检查每个成员状态
for (var i = 0; i < status.members.length; i++) {
var member = status.members[i];
print("成员 " + (i + 1) + ": " + member.name + " 状态: " + member.stateStr + " 优先级: " + member.priority);
}
// 检查主节点
print("\n=== 主节点检查 ===");
var primary = rs.isMaster();
print("主节点: " + primary.primary);
print("副本集名称: " + primary.setName);
// 检查数据同步
print("\n=== 数据同步检查 ===");
rs.printSlaveReplicationInfo();
// 检查复制延迟
print("\n=== 复制延迟检查 ===");
var members = status.members;
for (var i = 0; i < members.length; i++) {
var member = members[i];
if (member.state === 2) { // 从节点
var lag = member.optimeDate - member.lastHeartbeat;
print("从节点 " + member.name + " 复制延迟: " + lag + " ms");
}
}
// 检查oplog状态
print("\n=== Oplog状态检查 ===");
use local;
var oplogStats = db.oplog.rs.stats();
print("Oplog大小: " + oplogStats.size + " bytes");
print("Oplog使用率: " + (oplogStats.storageSize / oplogStats.maxSize * 100).toFixed(2) + "%");
print("\n副本集三节点部署验证完成");
EOF
echo "副本集三节点部署验证完成"
}
main() {
echo "开始部署MongoDB副本集三节点..."
start_mongodb_services
initialize_replica_set
create_users
configure_replica_set_optimization
verify_deployment
echo "MongoDB副本集三节点部署完成！"
echo "主节点: localhost:$MONGO_PORT"
echo "从节点1: localhost:$((MONGO_PORT + 1))"
echo "从节点2: localhost:$((MONGO_PORT + 2))"
echo "管理员用户: $ADMIN_USER"
echo "管理员密码: $ADMIN_PASS"
}
main "$@"
|
微信
