|
ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php) q6 {! |5 r+ T; e: _$ g! W# v
- return array(+ @5 e; [8 j, B# X6 [6 ]$ G9 V
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
' R# x$ |! R( u m. W - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离
; r1 |* o/ a$ E9 j - 'DB_TYPE' => 'mysql', // 数据库类型
. O: k7 a. [; J" Q7 K; d - 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址
/ Y4 i. g% F7 [% B/ r. L5 U6 u6 V9 V - 'DB_NAME' => 'kp_account', // 数据库名称
! B& g. r: k8 |, ?8 @: [* h - 'DB_USER' => 'root,root,root', // 数据库用户名
+ \7 J6 H$ Q) k3 q( P - 'DB_PWD' => '', // 数据库密码
9 g" [5 |8 M& H! d) O3 c - 'DB_PORT' => '3306,3306,3306', // 数据库端口. R9 z) B! Y6 {3 m% Z$ {
- 'DB_PREFIX' => 'acc_', // 数据表前缀
6 I9 E0 j6 F( M1 C+ K5 @2 m" O - 'DB_MASTER_NUM' => 2& j; s" d8 [# k1 [$ h8 s& D' s
- );
复制代码 5 J8 N0 c# g# j! X6 i" f
在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: 5 d/ x) ? k0 d# t) [3 ?9 v
- //分布式数据库配置定义
6 ^( U7 x B5 I3 a2 V3 M - 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
4 c& r. P* H8 u+ m' ~ - 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同; F. p5 a) b) x, E. Z0 u& [
- 'DB_HOST' => '192.168.0.1,192.168.0.2',& T) Z7 R: u7 p
- 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个
; Y0 `3 m0 M' V2 A0 k - 'DB_USER' => 'user1,user2',) w4 \+ l# z. U
- 'DB_PWD' => 'pwd1,pwd2',
$ C- z g% _9 h+ }3 `$ f' h T - 'DB_PORT' => '3306',1 M" J: X# k( H( I: E( T
- 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:
: A# V% Z W1 i" s- o& N, I# r* m2 K* |; o, G. [
[color=rgba(0, 0, 0, 0.87)]和) K3 |5 B+ A4 l0 {4 l, {8 K
[color=rgba(0, 0, 0, 0.87)]等效。3 v. A9 [2 J3 e6 R+ C
- 'DB_USER'=>'user1',
, C! y9 c6 j7 N$ @" M+ i - 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和
) @4 _, o0 m3 v9 S' Y'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',8 s' O' E3 p9 d" G8 [
[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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。 & q1 h3 O) F- V" L3 q6 Z" u
[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 [; ^8 k9 a2 p1 B5 u2 A* |7 s1 i8 P4 G0 O9 c
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。, S* H4 n: H0 C- A
----------------------------------------------------------------------------------------------------------------------------------------------------; p, T0 R) [! f. T7 Q5 j
1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。
2 N; |# c6 d2 {* K 3.详解 7 [* ?! N" O/ [ d
一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql', 2 L# Q% f* J; ]! u. M; K
- 'DB_HOST' => '192.168.5.102', 0 R( }6 d# w9 q- Q" O2 ^* ^
- 'DB_NAME' => 'databasename',
% a6 b2 o' i, l: c' c( e - 'DB_USER' => 'user', 5 T$ A( T/ h* u2 Q
- 'DB_PWD' => 'password', 4 L' C2 Y/ A' d% H
- 'DB_PORT' => '3306', 2 R j: f$ C* u% L5 S1 B
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql',
+ B# _' P, f1 ~ - 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', ( _- ]. }( X6 i: _9 k+ l
- 'DB_NAME' => 'test,test,test',
% i+ p, D3 v+ I8 f! u6 B! v - 'DB_USER' => 'masteruser,slaveuser,slaveuser', m2 e: d8 K% U. Z$ w1 I6 B
- 'DB_PWD' => 'masterpass,slavepass,slavepass',
2 g6 U. g L2 O- w- {# J5 S - 'DB_PORT' => '3306', : H3 u. W" Z, Q) K! O
- 'DB_PREFIX' => '',
. v2 m' b- K' h4 d( @5 S7 j! j4 _ - 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
4 S# ^- E' c( |+ S- }* o/ K. r9 J" P; F - 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效
J4 K" |2 X* [ \ - 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量 0 I' n1 S L1 N& i \( A2 Z. r
- 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); 7 [; B: T* y' O: u. ]
- $_config['password'] = explode(',',$this->config['password']); , I5 _; f' F1 P4 K7 i! f
- $_config['hostname'] = explode(',',$this->config['hostname']); y w0 _5 `3 K8 D t
- $_config['hostport'] = explode(',',$this->config['hostport']);
( _4 x( B: }8 A - $_config['database'] = explode(',',$this->config['database']); 3 k5 L+ d, J+ c& B% S8 S
- $_config['dsn'] = explode(',',$this->config['dsn']); . K/ D# f) k. m7 d
- $_config['charset'] = explode(',',$this->config['charset']);
复制代码 * S% R8 h- h/ G
‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
+ ^: f/ K5 W" g# Q4 B9 B* ^ - if(!empty($this->config['deploy']))
1 U7 O _2 |) t" W2 I& D7 ? - // 采用分布式数据库
# [( z4 B4 D6 H - $this->_linkID = $this->multiConnect($master); - U" O# L" c1 F4 H
- else 6 m; c! c8 T2 m* R
- // 默认单数据库 / X- r( l. H! M
- if ( !$this->_linkID ) $this->_linkID = $this->connect(); ' n6 X# ?" D. g* M1 @1 G' L& r
- }
复制代码
3 ], j+ a3 P3 u* }- p3 S$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 w \% k" @ U - // 主从式采用读写分离
: B" `% k" _) x, s$ Q - if($master)
5 n% d# d ] A( R( o: G - // 主服务器写入 . l) l, c- T5 s w
- $r = $m;
, Y# i9 a I0 s+ [# h) ]/ r; I z o6 w - else{ & a. q; a$ d/ w# U( a
- if(is_numeric($this->config['slave_no'])) {// 指定服务器读
; U5 B" P6 D8 e* \ - $r = $this->config['slave_no'];
: c8 I$ E( S# V. S. J - }else{ u/ _& s- l% v+ P9 Z+ {0 I' f. e
- // 读操作连接从服务器
/ y- b" o% P/ t. j* n) u( ] - $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库 0 t, B. n% N% d( |9 N
- }
4 x: L' ]% J" L+ n) ^ - }
8 j; V4 U% [6 Q% d$ L* U2 ? - }else{
( k# U2 n# l! [- x' j! u - // 读写操作不区分服务器 2 U" f% z- @7 Q, T1 H
- $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库 ( |" q6 p0 ~, B) d" h {
- }
复制代码 ) o5 A" U0 S* ^) N1 k, y2 S6 u
$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'])) {// 指定服务器读
$ z( y% ~6 b: Z $r = $this->config['slave_no'];8 D/ s% [, Q' E' u# |( k7 V* E$ D i6 F
}else{
& E8 D! J! Z5 z6 \. I8 N // 读操作连接从服务器
0 J. S; V Q. ^# P $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库, Y' M* _9 s, ^4 F m& ^6 s
} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){ * I. }) F* }7 i+ Z1 i
- $db_master = array(
; C% g F5 D% }4 L - 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], ) }! h6 `! |" ?% \9 ~; E4 c# }
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0],
8 |. }" i8 ^+ C/ B - 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
, G: s+ j- d4 b2 P0 M+ r( p! L. [ - 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0], + k. N8 q- l; W9 L1 i1 I2 p
- 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0], 7 w% c9 J t7 Y* L% _. ?; h
- 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
; o1 w( |1 J! W5 o w0 }5 C# a; H - 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0],
1 F- E1 r. z0 ]8 ]% V5 l3 u - );
x8 p" m: i% P) I0 q - } 2 V/ Q# f5 U. w A; C- R4 Z e
- $db_config = array( 6 o* H* m! q2 I; ~+ z4 O
- 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0], ; p) _/ P& U" {; B
- 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0], 0 [* z3 g! B B/ g. H
- 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0],
, K( ?8 c/ [" ]9 \ - 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0], ; q# \' z U9 K% ~# t0 O
- 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0],
2 A4 {9 D4 P7 V( ?$ v/ L2 s - 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], " J1 ], Z1 O# Q) f5 i* f4 l
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0], / w0 p `6 l5 |' d! b, [
- ); ' m ?: {$ u( R2 A
- return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码 , z/ u x! O8 h) ]
看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{
$ A5 S3 M' Q3 p* j - if(empty($config['dsn'])) { 2 ?' e( ]" Z* u
- $config['dsn'] = $this->parseDsn($config); . N3 N/ A4 Z# I# D' g: ^7 M$ S, N
- }
6 e* W8 q8 h- P5 |0 j* L, C% Z - if(version_compare(PHP_VERSION,'5.3.6','<=')){ o+ _5 [ ?, f
- // 禁用模拟预处理语句 5 j* d+ v- y3 d5 e: U7 x
- $this->options[PDO::ATTR_EMULATE_PREPARES] = false;
. i. K9 i! [9 J$ l# Y$ B& r - } % i8 y! `$ w8 f5 Z
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options); 3 ~; ^, W' t5 Q& K, S' c' K7 v+ @
- }catch (\PDOException $e) {
3 @- j* R$ z; F6 w: _" Z7 @ - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器
9 D/ ]0 Z' k) ` - trace($e->getMessage(),'','ERR'); 1 y/ k! W: v) J c+ c
- return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接
) L& Z! R9 q. q* b# `5 E8 g - }elseif($config['debug']){
E. q& k% S( D+ n3 r6 ^ - E($e->getMessage());
/ M t V% i* l( J7 X+ O; w, y4 ? - } * a4 m/ ~* P3 n, \5 e
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。 4 }# b5 M+ p( n
+ S7 _: E- E1 G; h* J
2 _; y3 g3 g6 V! c; T' ?! R |