ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php
& U3 L# B- d2 B4 v9 G- E+ ~, |% P( O - return array(* \1 {0 [9 s7 X$ p Z# v
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
5 B- p( m; s) X) E9 V M - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离7 U+ T" [' m0 {. j* @4 H
- 'DB_TYPE' => 'mysql', // 数据库类型
. L7 R7 ^' Q; s) ?. @( L- I5 {. x - 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址0 P8 G E( E3 d! @5 h) h7 q
- 'DB_NAME' => 'kp_account', // 数据库名称
$ g. o8 s$ N6 R5 T, `" @6 ` - 'DB_USER' => 'root,root,root', // 数据库用户名0 w( Y& R. y# j+ ]- @+ a# ?
- 'DB_PWD' => '', // 数据库密码: A9 o9 V0 p0 s8 L5 a% R- c
- 'DB_PORT' => '3306,3306,3306', // 数据库端口3 m( X$ k! T5 U% L: [
- 'DB_PREFIX' => 'acc_', // 数据表前缀" F2 b/ ^" H4 T. |' B
- 'DB_MASTER_NUM' => 2
. y0 F: |: d# q - );
复制代码 + F; r% r( W: ^ G
在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: i: K: ~+ y4 p5 f; \
- //分布式数据库配置定义
, g3 ?% ?& C$ {& E) t( N, N - 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持+ z5 n: t7 k# x& z( ^1 W @
- 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同
# }! M- [( g% b/ _ - 'DB_HOST' => '192.168.0.1,192.168.0.2',, p m$ a# I! K! G
- 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个
3 [4 L% Q& Y8 L+ s+ e( g+ o - 'DB_USER' => 'user1,user2',* g3 r' b6 L# ]2 L% W
- 'DB_PWD' => 'pwd1,pwd2',
$ E9 ?# i5 H c h - 'DB_PORT' => '3306',7 l: g: P6 A7 K4 n
- 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:
9 p8 s6 m ` k3 [# b
8 `( Q7 g* z8 H! s5 c+ }( `3 i: H[color=rgba(0, 0, 0, 0.87)]和
, {4 L2 g8 v7 S9 j* n$ z[color=rgba(0, 0, 0, 0.87)]等效。0 L9 H1 I1 d6 { z6 N+ X( c% }
- 'DB_USER'=>'user1', 5 ` X) k1 w# {: j' W8 P5 O
- 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和
8 N' ~ d9 R g+ Q% A; V9 F'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',
& p4 }" j! `( J3 k2 g& ?3 @6 V4 s[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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。 6 I. T; B/ _6 q. i ^* |( v0 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)],否则会发生主从读写错乱的情况。1 X* o; v- O' ~
, O# T& V' m# I5 \
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。
- d5 o+ @, m, ^9 [* {----------------------------------------------------------------------------------------------------------------------------------------------------
! v5 n" U* c2 y3 C) y, X; T' m* ]9 z& M1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。& K6 x! Y6 p0 S: t5 |
3.详解 9 N# U5 K- p% e, E! e; i8 I6 ~8 ^
一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql',
! U8 b5 d' j1 T& b - 'DB_HOST' => '192.168.5.102',
7 b3 Z1 R7 w) c7 K! o4 o. a: v& f! ^ - 'DB_NAME' => 'databasename',
+ s9 j2 N5 I* [+ _; E& E: l - 'DB_USER' => 'user', ( N6 M2 \- D x' n
- 'DB_PWD' => 'password', 5 T6 Y- h5 n' L9 e1 a; v6 P, [
- 'DB_PORT' => '3306', % `- Q( @) ^1 R+ ^
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql', 3 w) n3 I9 a/ f2 H2 ~) L
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103',
+ b ?0 g7 J8 R9 C: J7 ] - 'DB_NAME' => 'test,test,test', 3 w; \6 l, _$ o
- 'DB_USER' => 'masteruser,slaveuser,slaveuser',
4 ?$ g: F* g8 s! T! d- v& o! E3 h - 'DB_PWD' => 'masterpass,slavepass,slavepass',
+ |& U1 _4 o& Z+ b+ H - 'DB_PORT' => '3306', ! p7 R& c6 `$ r* y) |, d! z/ [
- 'DB_PREFIX' => '',
( m4 _7 @; ^ g; s& L, d - 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
' P. P2 d# z% ?0 J6 X4 K - 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效
1 i# C A: r6 Q3 d+ r - 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量
( @' h4 {# y6 d" |8 f: t% ^ - 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); 2 F q" H* ?) i: C% ?
- $_config['password'] = explode(',',$this->config['password']); Q: G9 w3 S3 ~' r
- $_config['hostname'] = explode(',',$this->config['hostname']); 4 M9 N- w5 E5 Q7 x* k- ^
- $_config['hostport'] = explode(',',$this->config['hostport']);
0 E& S; p% i4 }3 ~- A1 U1 V - $_config['database'] = explode(',',$this->config['database']);
- @6 Z- V% ?% O+ Q: a/ Z+ {/ {9 I - $_config['dsn'] = explode(',',$this->config['dsn']);
3 @" b0 p( w ~ - $_config['charset'] = explode(',',$this->config['charset']);
复制代码 2 c$ g* M( p9 K( @( X! }$ `9 H9 b
‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) { ' r2 G) ]- t) i |& V1 S; g3 ^ q
- if(!empty($this->config['deploy']))
- [. A1 r' p* b/ ] - // 采用分布式数据库 # M/ B! P- Z# o/ J# l u$ k
- $this->_linkID = $this->multiConnect($master);
/ g" g* o( _% m/ v - else 7 o' s9 O7 ?5 Y+ j7 Z
- // 默认单数据库
& s1 J% ^* o/ p. g0 ]* O* h - if ( !$this->_linkID ) $this->_linkID = $this->connect(); . g9 h: a( A( R2 E, Y# U% V
- }
复制代码 3 C6 t8 x% P5 V' }2 e0 |* ~" H
$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']){ # _" S3 h; l* C7 A( u
- // 主从式采用读写分离 ; B2 E) V( E7 G; z# g8 _& p" S8 Y) @6 _
- if($master) - y3 k" N$ P4 Z4 a' K3 W0 h/ V5 d
- // 主服务器写入
2 f$ x! d6 k0 R" X& r8 U - $r = $m;
/ ]- f0 t* E5 O& z7 W( j* m - else{
4 G4 e8 t+ B* @3 [9 h4 E - if(is_numeric($this->config['slave_no'])) {// 指定服务器读
, h4 j- F$ U4 N - $r = $this->config['slave_no']; - Q* B' o. h" [* _' |" w
- }else{ / m6 l- j4 p+ I9 F* K, Z
- // 读操作连接从服务器
7 G$ D( |7 K* U9 f! Y9 ]: W) y( } - $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库 P/ m8 N# d& B; ]/ K8 @( V
- } ) i j7 X9 ?$ o' H- X- \
- } 4 j% Y; m) C" w) B' s4 V) Q
- }else{
3 }, t+ |% O: V% F - // 读写操作不区分服务器
8 o' _# p" z# ]0 R E; Z: Z - $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库
, a) \3 V4 k, Z& h9 j8 i7 m* F - }
复制代码 # T' G- u1 _8 l# s
$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'])) {// 指定服务器读
1 M2 e$ ~" G7 M# P" q $r = $this->config['slave_no'];
- l, K. J$ w/ ]0 a1 L$ O) J* @}else{
4 {7 a2 s9 i/ Y3 \: |& c7 h* x* K // 读操作连接从服务器9 O5 J8 z( w7 d: `
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
+ Q8 w9 q1 s' `( t5 C' |} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){
9 `$ U0 m- X! N2 ?( H! n - $db_master = array( & o- Z$ M; M: P" P4 B& t
- 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], , J( V$ r" X* y$ m( a' B. x
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0],
3 M) P; l9 m( N6 ]) s" C9 H& b - 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0], : T3 V7 ~4 m& f% x. X% k! |
- 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0], " ?3 X. L9 w7 e& k0 Q& a
- 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0], * `) y7 O# P: K8 G
- 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
" L8 }3 D$ D U7 X% E - 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], $ T+ ?( l" U+ u5 o
- ); # k. u# K5 f- |0 N; Y3 L
- } ( r: a. h$ w3 }+ Z+ Q
- $db_config = array( y: k3 M+ {- X: ]: Y( k% i8 h
- 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
6 w+ j1 B$ R3 |# F+ y# A, r- \8 ~ - 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0], / P6 }2 w! i9 C8 Y
- 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0], # R, c* _5 _* ^+ V
- 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0], 9 C' [! ?0 O0 }4 g! `( v
- 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0], 4 \; h- x% l- J8 s' e
- 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], 3 M$ U" c8 s* i& H1 n! d/ C: a
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0],
: L: `2 v. W' Y8 Q9 Z+ S - ); " K' @& X9 C2 J' x% y
- return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码 7 R3 [! c$ l) {
看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{
( G( R4 X1 }4 Z' z6 G - if(empty($config['dsn'])) {
0 `- A$ H( N& \' O0 o - $config['dsn'] = $this->parseDsn($config);
8 i- B. p5 ^/ N0 L/ { - }
* l$ G* T8 W5 U0 b: v - if(version_compare(PHP_VERSION,'5.3.6','<=')){
. k: d% r2 P" r8 M - // 禁用模拟预处理语句 9 j: Y0 c* U: C) z9 W" Y
- $this->options[PDO::ATTR_EMULATE_PREPARES] = false; 7 U$ h& Q. T, w9 y# V7 u! |
- } 3 Q8 X! h/ {- Q+ c
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
0 a" a9 U3 t% f4 p+ }" o8 a - }catch (\PDOException $e) {
: h- m1 E9 s1 \( N' _& T - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器 t) H: h3 X" c( N2 q
- trace($e->getMessage(),'','ERR');
3 x' ]7 z4 b2 I: b2 ~ - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接
% `; U6 E- v w6 a- a* A/ T" I5 B - }elseif($config['debug']){
( I+ V* q/ o* z+ O) t; w% c - E($e->getMessage());
7 c! C9 }( C" ^1 N9 X( O - } ( C2 k0 q0 b+ I1 O9 Q, U
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。
" \) p0 O4 E7 d) l; o [
% S8 O, n M; P+ p' @& L, ~& u+ Y' k0 _9 {+ V, H* F: C
|