ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php2 M( h' r4 a' E! J& V
- return array(7 W# x0 D+ b0 M2 p4 k: Z
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
# @' e/ ^1 Y, E$ s( c3 h& f& a5 W - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离, o3 `* h% w" Z0 e0 }
- 'DB_TYPE' => 'mysql', // 数据库类型6 V8 X g! d) p7 X
- 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址5 ~$ T u7 ?1 r, |
- 'DB_NAME' => 'kp_account', // 数据库名称
+ u) f, V; J: j _" ` ^: W - 'DB_USER' => 'root,root,root', // 数据库用户名( h. X& N- l0 j g: i
- 'DB_PWD' => '', // 数据库密码
Q& K6 p$ I8 f! |0 n - 'DB_PORT' => '3306,3306,3306', // 数据库端口# Z3 m9 Z8 Y5 N! _8 ?. J# u5 U
- 'DB_PREFIX' => 'acc_', // 数据表前缀
+ B H' |3 q0 I S2 e# }; t - 'DB_MASTER_NUM' => 2# c+ |' A8 A: x; ? T* \
- );
复制代码 8 e" W7 m; o( {/ U! m7 E% X ~( 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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: 0 o0 P( e# R; G. D8 a; X
- //分布式数据库配置定义8 J: I( g) L7 \: b1 j' d
- 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持! K) w) S1 I" N/ |$ t. p; W
- 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同
/ z+ |# u' a: b3 _$ g - 'DB_HOST' => '192.168.0.1,192.168.0.2',4 P6 I& F2 F" Z" M4 |
- 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个$ c4 O1 `) O% V1 {7 y$ V% M
- 'DB_USER' => 'user1,user2',
2 \) i$ P5 [( N, U g! b - 'DB_PWD' => 'pwd1,pwd2',
' x0 D* y; }5 V4 _ - 'DB_PORT' => '3306',
2 e. K. s! E4 x m6 n - 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:
3 j, R. L$ d: m& l; \0 U0 H. ?2 q
9 K( I. z# t) B: u% H/ F8 F' X[color=rgba(0, 0, 0, 0.87)]和
; R. o# y: A* r' {* `; B8 J[color=rgba(0, 0, 0, 0.87)]等效。# C; _7 j5 r0 e% ~+ Z- b
- 'DB_USER'=>'user1',
: }4 e* {: B3 N# L$ w& j9 N - 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和0 J+ J& N4 p) K4 j* J' H7 c" @
'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',% [: ?0 _0 B/ b9 Y, u; U8 w1 k
[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 c& L5 V# A, {
[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)],否则会发生主从读写错乱的情况。/ a( \4 p; f9 S) j: s4 F4 g
8 n0 q( G+ ?, b, r6 p- b; W$ i. h: v
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。 ], B) b4 s' m% i& \, i
----------------------------------------------------------------------------------------------------------------------------------------------------
! {% v: E. m5 e+ \+ D! x9 ~1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。
3 e, m/ @# w1 P* s 3.详解 / `2 z* P9 ?3 o0 N0 X
一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql', " { ~& M( C& _5 [
- 'DB_HOST' => '192.168.5.102', 0 u: I+ f- q0 ]' I, [
- 'DB_NAME' => 'databasename', 6 {/ R; x3 M1 k
- 'DB_USER' => 'user',
- S3 i6 x% ^8 [ b: _ - 'DB_PWD' => 'password',
( W. ^" n H5 g8 B" S% f - 'DB_PORT' => '3306',
4 r7 Y/ w; G; d' j/ P3 D0 C - 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql', - \( l" A! B3 ], ~' w$ @# F
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103',
* n5 `. p" D# @ - 'DB_NAME' => 'test,test,test', 9 J) e* C! d; N- ^: k* d( t4 \% Q
- 'DB_USER' => 'masteruser,slaveuser,slaveuser', 0 r+ w/ l& L9 m) A5 U
- 'DB_PWD' => 'masterpass,slavepass,slavepass',
0 [2 A6 o) m% T% Q. H* W - 'DB_PORT' => '3306',
( _" h1 t/ f( C% H5 _ - 'DB_PREFIX' => '', 5 h1 A! t! j& A. s* O3 M2 g
- 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
K! I. e/ Z1 ~+ s5 l, a - 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效 4 z% J/ u- d* O1 X; T
- 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量 1 E {* c! H3 M/ c8 ?6 C' w$ Y
- 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); : X6 @9 r1 N# F; {' h
- $_config['password'] = explode(',',$this->config['password']); 0 o' @/ m# B, k, ?
- $_config['hostname'] = explode(',',$this->config['hostname']);
$ g0 T5 c) Y% T4 k3 s& c - $_config['hostport'] = explode(',',$this->config['hostport']);
$ p1 N3 m1 \% D: r( N - $_config['database'] = explode(',',$this->config['database']); 1 {: d- a b4 n! ]
- $_config['dsn'] = explode(',',$this->config['dsn']);
$ F+ Y: E, h6 l- v& C) F5 b+ w - $_config['charset'] = explode(',',$this->config['charset']);
复制代码 * n" p5 N7 [) U; L5 ~( t+ L0 [8 i
‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
( z c5 G1 [4 m1 L4 L7 N3 P7 P - if(!empty($this->config['deploy']))
6 W7 M8 e" m0 e - // 采用分布式数据库 - H, Q/ `4 m# u7 h* V, N4 C
- $this->_linkID = $this->multiConnect($master); ' ]5 B8 R3 R. p2 [, r
- else
; h& N: }* U& j% D8 V0 R: y) i - // 默认单数据库 $ C) j- @- X. L+ U
- if ( !$this->_linkID ) $this->_linkID = $this->connect();
6 L' R6 `+ o1 `& [ J/ D - }
复制代码 3 E7 _: g0 a/ Y! `4 F# I: k$ R
$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']){
4 a$ h* {( F! W& X( G4 v - // 主从式采用读写分离 # O( I3 R2 s7 z9 p
- if($master)
, s% F5 {0 X/ \: _# z ~ - // 主服务器写入
# R3 y+ j: x. | Y- c3 @# {& I5 m - $r = $m;
- O. j/ B \9 J/ h' o7 I( | - else{ 2 w% s! t% B" X$ R& i1 \
- if(is_numeric($this->config['slave_no'])) {// 指定服务器读
. L& F2 [( @2 X& o: K# d - $r = $this->config['slave_no']; ) z$ X1 R2 i" {( Q
- }else{
7 S+ ?3 q; Q2 H% ^& R - // 读操作连接从服务器 4 {" W* u1 M- S
- $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
2 |: k5 i+ N3 { Z - } 0 E& ` ]) P+ K" T6 n6 f+ u
- }
* _. G! q6 S7 S$ d! W! H - }else{
$ R# k) F4 H) B$ w, Y" W/ }/ W - // 读写操作不区分服务器 3 f, z2 G/ \# M# R
- $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库
) u! Q* |' c5 i# A - }
复制代码
+ G: ~) M" T7 N, y4 A! I; L$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'])) {// 指定服务器读
6 r8 l3 x7 a& O0 X' \ v $r = $this->config['slave_no'];$ b8 [( W1 f: ]$ Z' W6 ]: e
}else{% B- p8 W4 l$ `* r# H% q
// 读操作连接从服务器( L p+ g1 R1 `# i8 v
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库# k! \0 M! ?3 e6 }# X( r& O* a
} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){
5 A( M9 i" H2 X9 Y& { - $db_master = array(
. J& j# ^( a" r1 K* ^8 L: N - 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], . | r2 h0 l, @% |/ w: ^: Z8 F
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0], , j! |; N9 n! C% z1 x1 _! F
- 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
. \" y3 V$ L6 S7 k$ b - 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0],
( f, Y6 M- Y7 M7 y" { - 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0],
) z; G2 p6 r3 c% E1 @ - 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
3 e, b% x1 k* p9 F - 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], ( ^% i1 r9 N+ w. Y! \ P2 K+ Y
- ); & N* U/ C. o& R* n
- } 4 ?$ o7 D1 B/ b; @* F! p
- $db_config = array( " V; y" i. H2 d: v8 k
- 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
/ E% I, a. Z* @0 W - 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0],
7 g7 s& [6 b5 V+ _6 W1 u/ }2 a - 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0],
' I. x0 Z8 B7 \# _0 Z" w# \6 @ - 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0], 0 t0 v& `7 X+ g. i0 k2 i7 F, }
- 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0], : r! N# b6 e5 U- l
- 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], 7 H5 b/ K' E$ c+ B
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0],
' H- W" V3 E: C0 v% W) Z - ); * W! e6 \' N2 o3 o( l
- return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码 2 d& i/ t4 H4 n; Q8 M
看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{
2 y/ G) A8 Y( N9 m" |, p7 L - if(empty($config['dsn'])) {
' R7 y0 q: g8 D, {. q, J - $config['dsn'] = $this->parseDsn($config); " t9 t- W a' \/ z8 v. z, f
- } y& Q& Z/ i( Y4 N9 T7 F. c5 Z
- if(version_compare(PHP_VERSION,'5.3.6','<=')){
; h0 P* b8 c6 K/ K7 ~ - // 禁用模拟预处理语句 1 V) G; A' H' W
- $this->options[PDO::ATTR_EMULATE_PREPARES] = false; ' L. z' @9 {- F; ~" }2 e
- } ' e- a# D% k1 C9 h
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
% ~* a9 d {9 V, g$ N+ R" W6 W. w - }catch (\PDOException $e) {
: I. E& P6 w" D) F - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器
4 u2 v0 [" W7 p1 m - trace($e->getMessage(),'','ERR'); $ I8 ]6 g9 D ^1 N; C5 a
- return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接 ( l0 q" i# v c! B6 C$ \
- }elseif($config['debug']){
4 \8 w0 h' R4 E7 d - E($e->getMessage()); * y$ m O$ Z7 K* u4 z
- } 7 a2 t8 {' |( H, R& j
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。
- M" C, M- k, f; M+ Y. P3 Q0 Z- Z5 ?1 |# a
, E8 I5 k4 A( F; L3 F, h/ b& c/ A# g
|