$ Y- H0 E W2 `% T3 Z 在更改了这个配置之后,执行写操作的流程如下: ; ~- a d9 S! E7 A) ~! Y , \! H; W3 H8 j+ R; g/ f" G 在primary上完成写操作;, D5 p0 s" i1 i/ d# d5 N6 N2 w& P
写操作被记录在primary的oplog中,oplog中包含一个ts字段,记录了写操作发生的时间t;! [! G6 W I8 ~+ |# n# m) ~0 S
客户端在primary中执行{getLastError:1, w:2}命令,primary完成了写操作,只要再有一个节点完成写操作,就可以满足w:2 了;0 `8 s. s" f. p' a) O
secondary从primary获得oplog,获得上一次操作的记录; 2 |" H) a- x/ q secondary执行oplog中刚才那一条时间t的操作; ; V- k% x, X D' Y secondary从primary的oplog中获取时间t之后的log,条件为{ts:{$gt:t}}; 2 T; y5 |& i- K B primary知道了secondary已经成功执行了时间t之前的oplog,因为secondary已经在请求时间t之后的oplog了; / I9 Q8 w H3 i# V( i% Y1 F getLastError知道primary与secondary都完成了这次写操作,于是 w:2 的条件满足了,向客户端返回成功。- I1 g! [6 T) v$ V0 w, I* q2 m
" j* G4 A4 H9 r. Q, s启动' L& ]. U4 G# f& n! Q
M, o, D+ s8 h0 y1 l
当在现有的某个replica set中加入一个新节点并启动时,这个新节点会查看自己的local.oplog.rs collection,执行一个叫 lastOpTimeWritten 的命令,查找到它最近的一条被secondary同步过的写操作。 3 r( T! A5 `7 ~9 _5 L9 ^0 U" @0 `9 h L! [1 T
这个命令会返回一条oplog记录,其中的ts字段就是最近一次写操作的时间。如果一个节点启动的时候,oplog里没有数据,这个节点会同步其他节点中的所有数据。 7 w! n! M4 W) n6 @: B 5 X# t& s3 @7 r选择同步源节点3 B- W, Y C8 x: U1 M6 h- ?
# u% N& t: P. c! s( n0 w ~
Replica Sets中的节点从距离它“最近”的节点同步数据,这个“最近”是通过ping的时间来判断的。在节点之间的心跳检测中,会记录ping某个节点和收到响应的时间,通过这个时间的长短,来确定距离的远近,时间越长视为距离越远。知道了和节点之间的距离,再通过如下的算法,来确定可以同步数据的源节点:& M9 p, n @7 \$ l8 p
0 T1 {4 q9 d/ s9 B+ Z: k0 `' i
for each member that is healthy:! s$ V2 e, x$ R. E3 t2 r* ^# E4 a
if member[state] == PRIMARY: e8 }; \; N/ r* _
add to set of possible sync targets1 ], d, U. Y. y: S+ a g' e
" j* X4 \3 z J( ?* s a' P7 ^ if member[lastOpTimeWritten] > our[lastOpTimeWritten]! G5 W+ x# J6 z+ m6 k0 K& I
add to set of possible sync targets" s" B* A( c N% F
- P# N4 V) K& X( x8 [
sync target = member with the min ping time from the possible sync targets + |6 N% W5 l9 N" H* x* c ( s7 V: d- Z" t$ ]. W7 l 对于节点是否健康,MongoDB各个版本的判断依据有所不同,但都是为了找到能够正常运行的节点。 ; x! p3 s( u5 |/ y) G - x; w; w3 Y5 c7 U4 g, f, U+ X6 C 我们可以通过运行db.adminCommand({replSetGetStatus:1})命令来查看当前的节点状况,在secondary上运行这个命令的时候,能够看到syncingTo这个字段,这个字段的值就表示secondary节点同步数据的源节点。 / B0 I9 h9 R3 j5 d1 u6 c7 e% ]- t9 X: I
链式同步3 m) M# n K% B
- G/ y) D, Y. J9 t 前边所说的内容,都是假设有一个primary和一个secondary,这种情况下的同步过程比较简单,但是如果有2个secondary或者更多,那么这个过程就要复杂的多。# m' v2 X2 X( b8 a