|
ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php
1 _* t& T) D( c* [' W% O% F - return array() K/ e- Y+ e: ~9 Q% F- c
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
* `$ l1 F F- ~1 d- y - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离
4 r% e! h: y% C# }6 R - 'DB_TYPE' => 'mysql', // 数据库类型7 A1 c; w; r, k5 u. `
- 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址
* y- ~* K; q# b% S - 'DB_NAME' => 'kp_account', // 数据库名称" w5 \' o" J4 W- \5 G: I+ @
- 'DB_USER' => 'root,root,root', // 数据库用户名
N9 o' `1 T2 e8 F4 E - 'DB_PWD' => '', // 数据库密码& T* e+ J p: A0 M5 c
- 'DB_PORT' => '3306,3306,3306', // 数据库端口5 g" ]3 @2 M" a# h3 \
- 'DB_PREFIX' => 'acc_', // 数据表前缀
/ V' Y8 U' y4 F2 n/ ?+ q4 W# z - 'DB_MASTER_NUM' => 2
x8 h" n2 q _( j# e - );
复制代码
7 S; O- n: O8 g# W& x在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了DB_MASTER_NUM参数,则可以支持多个主服务器写入。其它的都是从数据库的配置信息,负责读取数据,数量不限制。每次连接从服务器并且进行读取操作的时候,系统会随机进行在从服务器中选择。 还可以设置DB_SLAVE_NO 指定某个服务器进行读操作。 小结: TP框架内置的分布式数据库处理,在默认的情况下,如果没有设置DB_MASTER_NUM参数,就会是默认第一个数据库作为写操作,其他是读数据库;如果设置了DB_MASTER_NUM参数,例如上面的数据库配置信息里面把DB_MASTER_NUM参数设置为2,在没有并发的情况下,写操作一直会是192.168.33.111这个数据库;有不对的地方还望多多指教! ----------------------------------------------------------------------------------------------------------------------------------------------------[color=rgba(0, 0, 0, 0.87)]ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 [color=rgba(0, 0, 0, 0.87)]配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下:
/ X3 I3 v {9 s3 `3 X1 m- l- //分布式数据库配置定义
, R" l" U, Y8 `, n; P1 s- S! ?! z - 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持" }. F! D$ `5 @: Q5 C7 e8 Z3 \; F
- 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同. b' k- w/ r6 e8 J5 b
- 'DB_HOST' => '192.168.0.1,192.168.0.2',
! P) x9 h1 ^" _' `. Q$ V* I9 p - 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个7 X; U6 R' H0 D K' T
- 'DB_USER' => 'user1,user2',
/ _! ?4 [& t* E4 `; C$ m - 'DB_PWD' => 'pwd1,pwd2', j Y* q, o* A% {* j
- 'DB_PORT' => '3306',% M5 x n# e: I& N5 K& ]7 _: I
- 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:
4 Q; _6 J2 n8 w# A. A2 b8 Y3 a. m( S) L5 z) `0 s* A v
[color=rgba(0, 0, 0, 0.87)]和) \- ]% d' Y5 B+ q& s3 G
[color=rgba(0, 0, 0, 0.87)]等效。
4 k) M2 h" w- H0 v- 'DB_USER'=>'user1',
# i* x2 s# g* O) B9 B: m1 c8 ^ - 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和( F7 {8 G n3 p: Q' ^3 ~
'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',
5 x0 L- G$ _& M2 j[color=rgba(0, 0, 0, 0.87)]等效。 [color=rgba(0, 0, 0, 0.87)]还可以设置分布式数据库的读写是否分离,默认的情况下读写不分离,也就是每台服务器都可以进行读写操作,对于主从式数据库而言,需要设置读写分离,通过下面的设置就可以: [color=rgba(0, 0, 0, 0.87)]在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了DB_MASTER_NUM参数,则可以支持多个主服务器写入。其它的都是从数据库的配置信息,负责读取数据,数量不限制。每次连接从服务器并且进行读取操作的时候,系统会随机进行在从服务器中选择。 [color=rgba(0, 0, 0, 0.87)]还可以设置DB_SLAVE_NO 指定某个服务器进行读操作 [color=rgba(0, 0, 0, 0.87)]3.2.3版本开始,如果从数据库连接错误,会自动切换到主数据库连接。
$ {: }3 a* `( K( ~6 i p[color=rgba(0, 0, 0, 0.87)]调用模型的CURD操作的话,系统会自动判断当前执行的方法的读操作还是写操作,如果你用的是原生SQL,那么需要注意系统的默认规则: [color=rgba(0, 0, 0, 0.87)]写操作必须用模型的execute方法,读操作必须用模型的query方法[color=rgba(0, 0, 0, 0.87)],否则会发生主从读写错乱的情况。
3 r$ P# L' x( S5 g2 |
8 `* a3 ~3 U) F- \1 X. h注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。2 t9 A9 L- U6 F' ~; X* [
----------------------------------------------------------------------------------------------------------------------------------------------------
- H- ~- j( o+ z7 m4 s5 v1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。
# H3 T9 ^" j% `& d- W 3.详解
6 v) c! x2 J0 Y$ j一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql',
U5 L, r! p+ y$ E0 k/ U - 'DB_HOST' => '192.168.5.102', / ]4 x4 O/ p" x! c
- 'DB_NAME' => 'databasename',
: U" p: I# c1 `# r - 'DB_USER' => 'user',
& s' I3 u- Q5 {) V3 J4 q, N% m - 'DB_PWD' => 'password', + Q8 u3 D7 y( Y+ l9 ? [( a
- 'DB_PORT' => '3306', # }: m9 |0 S% d. W7 q
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql', * r+ H+ g3 a2 j' s# A8 S
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', 2 `* R: D/ `. {% m9 Y
- 'DB_NAME' => 'test,test,test', s4 `' _' q: G. L4 O
- 'DB_USER' => 'masteruser,slaveuser,slaveuser', ( w& i% b" a" _" i* b) f3 h" p
- 'DB_PWD' => 'masterpass,slavepass,slavepass', ) X E: e5 h, E" R! T ?3 a
- 'DB_PORT' => '3306',
/ f3 Z: n6 A7 j1 q1 ? - 'DB_PREFIX' => '',
, I+ w1 n' F) i) ]7 Y, Q( v a - 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
* r$ B$ a7 a5 E& \ p2 x - 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效
P& G5 A8 ]& s: c2 W3 |# \ - 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量
" C" t0 t2 x0 t1 L4 y - 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); $ D6 s! I0 n _" P" a
- $_config['password'] = explode(',',$this->config['password']); + m C/ X7 m$ q8 }6 K* c
- $_config['hostname'] = explode(',',$this->config['hostname']);
. M, n1 D J4 |( U, ^4 R% p2 m - $_config['hostport'] = explode(',',$this->config['hostport']);
! F/ T! ^# {# W7 M - $_config['database'] = explode(',',$this->config['database']); & b! K6 \. a0 Y i) o: S
- $_config['dsn'] = explode(',',$this->config['dsn']);
% a/ t6 z" L9 S3 u4 @8 d - $_config['charset'] = explode(',',$this->config['charset']);
复制代码
2 v0 f- ?+ E* p7 C3 U% x‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) { 3 W. Y$ C3 c2 e; ], `3 C- j+ A
- if(!empty($this->config['deploy']))
2 `2 [+ w& p4 Q$ V - // 采用分布式数据库
" A6 X* A/ k% F' F - $this->_linkID = $this->multiConnect($master); , l0 E: N& I- d2 i; d, a* U
- else
0 X0 T' H$ r+ w6 C5 t& p9 J' i - // 默认单数据库 8 r) }; l8 X. ?7 q2 h! f: S# I8 V
- if ( !$this->_linkID ) $this->_linkID = $this->connect(); 0 }' }4 ?8 T$ b0 _0 F) t0 q/ Z' l
- }
复制代码 ! T' [" L. L' c
$this->config[‘deploy’]表示的就是’DB_DEPLOY_TYPE’这个配置选项,上面的配置在使用之前都已经经过解析了,配置项都在$this->config数组中。至于是如何解析配置文件的,这里我们不做介绍,感兴趣的可以参考Think\Db类。 $this->multiConnect()函数就是用来进行分布式连接的,如果’DB_DEPLOY_TYPE’选项设置为1,该函数就会执行。否则直接执行$this->connect()函数。 ‘DB_RW_SEPARATE’=>true true 表示读写分离;false表示读写不分离。 这里需要注意的是,读写分离是以主从式数据库系统为前提的。该选项设置为true的时候主数据库写,从数据库读。 - if($this->config['rw_separate']){ 3 l- F5 H6 x. G% }; `# D
- // 主从式采用读写分离
7 K/ u: x1 `0 S - if($master)
% ]+ m* a% u( ^" I( N0 n0 J! {, k - // 主服务器写入
* S6 A( u. p& G - $r = $m;
1 w- P, Z x# i( x7 v) K - else{
2 s' Y- ^) V0 A) e - if(is_numeric($this->config['slave_no'])) {// 指定服务器读
: ?6 @$ z+ ^' J - $r = $this->config['slave_no']; 2 |6 v: m6 p5 i3 p0 a
- }else{
5 d6 y6 t. M" E4 J - // 读操作连接从服务器
1 z! ^! f, Q# ]5 O, Z8 [9 u - $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
3 I+ p' h9 D* [/ Q' ~1 o6 A2 D! K; m, q - } 7 Y& J( M( l/ q+ W% Y1 m& ]; k& x
- } 5 q) l. Z. r$ U( D
- }else{
; k8 D, R& i8 R" ]* [ - // 读写操作不区分服务器
7 P* O2 y* K( m6 y h% ^) t" @ - $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库
3 f6 Y8 A8 n0 o' z2 @ - }
复制代码 8 ~+ ?& w% {7 M( y
$this->config[‘rw_separate’] 为true的时候采用读写分离,为false的时候读写不分离。读写分离为什么必须是主从式的呢?因为从服务器不能写只能读,如果向从服务器写入数据的话,数据是没法同步的。这样就会造成数据不一致的情况。所以说,如果我们的系统是主从式的话,我们必须采用读写分离。也就是说DB_RW_SEPARATE选项必须配置为true。 'DB_MASTER_NUM'=>1 该选项后面的数字表示读写分离后,主服务器的数量。因此该选项也是用于主从式数据库系统。 下面的代码是选择主服务器。 $m = floor(mt_rand(0,$this->config['master_num']-1)); 主从式数据库读取的时候选择从服务器读的核心代码 $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库 其中$this->config[‘master_num’]表示主服务器的数量。 'DB_SLAVE_NO'=> '' 指定从服务器的序号,用于读取数据。如果不设置,则根据主服务器的数量计算书从服务器的数量,然后从中随机选取一台进行读取。 if(is_numeric($this->config['slave_no'])) {// 指定服务器读
( `" E5 A# F' V- f0 u/ T6 |5 j $r = $this->config['slave_no'];6 g8 `" z* n3 J! L6 [( a6 Q
}else{1 b: r0 T% K! }9 f" o& v' A& V- ^
// 读操作连接从服务器
" p7 {- a( b$ _7 B $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库; U( a ~/ i5 v N6 s
} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){ , I+ b# ]) k4 _ }" c
- $db_master = array( : p, i: f- _8 W# S: Y% J
- 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], - K/ A; G: a% p/ _- X- @' v4 E. D
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0],
, r$ L' X4 s, i6 @ - 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0], 6 Z: e' ~3 D% D( \% E
- 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0],
! I/ c; O3 {- f* w - 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0],
, W/ J) a; {9 ?" Y - 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0], ( z1 m3 Z; X% b! u' U& Q
- 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], + P+ c9 [& o( c$ Q, s4 v/ D4 B
- );
! A( w1 K. x5 _; a - } ! `8 k: a, c7 X
- $db_config = array(
7 a) |9 C1 ^( ~4 ] - 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
. V6 b9 m! s+ {* f - 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0],
1 f, X% a3 w! O9 h$ v) s6 E - 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0],
$ o3 ~! g2 X% q. |0 }: M - 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0], ; d: k" H! }+ k6 z, w3 K5 M" J, S8 m6 {
- 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0],
: K3 F" U% U0 s3 I, A& F - 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], 7 Z W( g/ S( S C0 l4 ?. B
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0], , Y/ i2 d2 L+ L" G- {' s+ v8 B
- ); * N3 R) X" l! H& X# G2 ]6 T
- return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码
/ H# b. Q- F$ L看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{ $ l$ p4 D3 s5 J+ R
- if(empty($config['dsn'])) {
% X" C" T5 ~# E9 ~3 x# w6 D3 I/ u - $config['dsn'] = $this->parseDsn($config);
5 r# U' c9 O1 z) L - }
* |0 x+ O5 [* N! @6 y+ w - if(version_compare(PHP_VERSION,'5.3.6','<=')){ , I7 c0 a! T! e9 j
- // 禁用模拟预处理语句
3 A" U O4 c" W; S1 j* Y - $this->options[PDO::ATTR_EMULATE_PREPARES] = false; 7 f; q# e( ^' J9 d
- } % s3 Y; I$ i) B; k+ o& U
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
/ ^: h) |9 M V, k - }catch (\PDOException $e) { 5 J; A3 {2 D' M8 k
- if($autoConnection){ //$autoConnection不为false,而是默认的主服务器
- C: p" B8 B/ z( e - trace($e->getMessage(),'','ERR');
3 i' z( x6 t& |8 p3 C - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接 8 ^, w9 e! w# W$ \ A" w
- }elseif($config['debug']){
$ J# o/ x" _' G* I$ H - E($e->getMessage());
+ i6 M$ v( D5 @! P5 U. }6 P - }
; F/ n8 Z+ \- y4 p - }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。 * a6 L. `3 ~, Q4 x
v" Q) s4 J; F- S! C- ]2 s: z" Y/ Q+ ^/ s; u
|