ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php
" }* G; S! H8 J - return array(+ u% U- I/ M0 l6 [& k- J+ ?( e
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
4 {+ @: a0 [& b: _/ r5 `- v0 ]: { - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离% W' J$ T2 U8 B+ [# \
- 'DB_TYPE' => 'mysql', // 数据库类型! e. @8 h; n8 P& q/ L5 s# u4 V
- 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址$ t. x0 h" ^8 M# \' G; S( F& H9 u
- 'DB_NAME' => 'kp_account', // 数据库名称$ W6 q5 L0 a( I% s% x, N
- 'DB_USER' => 'root,root,root', // 数据库用户名
. z9 B5 P8 K* k+ ]9 X. }, l - 'DB_PWD' => '', // 数据库密码
& G7 W7 a' |) J, e, H - 'DB_PORT' => '3306,3306,3306', // 数据库端口
4 R& o" }8 \# M- W# ^ - 'DB_PREFIX' => 'acc_', // 数据表前缀
* @( V: l1 _8 m# z: m3 `! V3 |, q: J - 'DB_MASTER_NUM' => 2 k: Y7 {# P5 d
- );
复制代码 ( y' e+ n' J' H1 a' f0 M* U( I# i5 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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: / M9 ~; D; N5 P" `' {
- //分布式数据库配置定义
7 E9 }: j/ {- Z - 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
: h) g X9 X) A2 O, S* u# X - 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同
* c% ? @8 u& `( k, v6 Q - 'DB_HOST' => '192.168.0.1,192.168.0.2',7 E: J; I& ^3 Z& u- H9 p
- 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个
5 P) f; a, r4 q q1 M - 'DB_USER' => 'user1,user2',
2 s/ u( W& B% S5 E6 Y" C' z - 'DB_PWD' => 'pwd1,pwd2',
/ V( a8 V: v+ L1 z8 R - 'DB_PORT' => '3306',2 {& h9 E& R- P0 ~, ?- Y
- 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:
% H3 n& V0 d# u3 |' i' h5 c5 V
[color=rgba(0, 0, 0, 0.87)]和
! {4 x3 m$ ?7 \; |: ~[color=rgba(0, 0, 0, 0.87)]等效。& z* _9 w( C% w2 ^+ I' M
- 'DB_USER'=>'user1', & q6 C9 r2 j' h* B4 M! l' J, {
- 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和1 p1 f; u1 _8 p4 f! T+ ?% G! A
'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',8 y* Y* l8 o6 v1 R9 c
[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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。 . ~* b' d4 h5 O) a6 V) z
[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)],否则会发生主从读写错乱的情况。& p" o2 K! {# `6 P1 n- k8 q
8 _8 i& A: ?9 D. o8 ]- ~! I
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。
; N x/ n! `6 b- M4 z# d----------------------------------------------------------------------------------------------------------------------------------------------------
+ z* [) o2 {# g. \- y! E1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。5 }7 F; T/ ?0 q2 o( ^! u
3.详解
( ~1 E$ e+ V3 S. }; Q一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql', / g2 A/ [8 W$ {. D
- 'DB_HOST' => '192.168.5.102',
( x+ M$ o6 M7 K0 X: a - 'DB_NAME' => 'databasename', 5 A0 F4 y) J/ \3 S9 [! R. N
- 'DB_USER' => 'user', " V& C4 z2 Q0 j! s
- 'DB_PWD' => 'password', , c5 [7 z5 T4 Q( @# D/ ^$ Z/ V
- 'DB_PORT' => '3306', 9 ?0 O, K# k. c
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql',
% C6 H: O, Z I: `2 ] f/ r - 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103',
8 v9 O1 R4 W* c$ L9 M2 g - 'DB_NAME' => 'test,test,test', 1 a: ]( o3 s0 h; y! X+ y. y
- 'DB_USER' => 'masteruser,slaveuser,slaveuser',
, @/ [# _) A; C- B: f0 i, W+ j* c - 'DB_PWD' => 'masterpass,slavepass,slavepass',
7 Q% e4 T2 e& Z- M4 a# `" Y - 'DB_PORT' => '3306', , t; ]& I* c3 Z
- 'DB_PREFIX' => '',
/ r7 g# q) t. S. @7 d" D q - 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) # i; L: }% ^, P0 d
- 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效
% M {/ V* ^0 P3 L [ - 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量 * b/ R' c+ a! |: J4 a
- 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']);
w3 q% J K# c, L; x# c. u - $_config['password'] = explode(',',$this->config['password']); 6 d1 l0 R- u' h% y
- $_config['hostname'] = explode(',',$this->config['hostname']);
: f( k7 P. p" @ - $_config['hostport'] = explode(',',$this->config['hostport']);
% X6 c$ U. `! Z% u* L - $_config['database'] = explode(',',$this->config['database']); % j! \. r2 n* ]: _' W9 t
- $_config['dsn'] = explode(',',$this->config['dsn']); 8 V* j8 L. t% ]
- $_config['charset'] = explode(',',$this->config['charset']);
复制代码 , @& Q' M9 }( R) a: ]9 |
‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
4 ~8 \- I H! m5 P$ l% O/ a - if(!empty($this->config['deploy']))
" ~* p" m3 M) }7 X* Y' f" n - // 采用分布式数据库
, ]- S Y4 O( p& I - $this->_linkID = $this->multiConnect($master);
9 P0 g! C# V( [3 o8 o - else 6 k, z5 j3 ~- U- @
- // 默认单数据库
. C: H& |( F" n; H - if ( !$this->_linkID ) $this->_linkID = $this->connect();
! K( r7 r6 } O - }
复制代码 " B( R. ?" M0 i# \5 N- K
$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']){ ( X/ X2 J6 D" U' S
- // 主从式采用读写分离 5 O% @4 {+ X) I E/ D
- if($master) - B5 b; ?+ ]- j9 H; I( f- N& |
- // 主服务器写入
( [( y9 X8 ^7 X7 x- _7 U4 n0 p - $r = $m;
; T# E0 s7 Q% ~2 Y9 d - else{
1 I, R5 K4 g8 w& W$ [5 v - if(is_numeric($this->config['slave_no'])) {// 指定服务器读
* [. I- ?3 t9 Q - $r = $this->config['slave_no']; 3 m4 _- x: q& i9 ~
- }else{ 1 l: H5 X& n8 y7 B# y
- // 读操作连接从服务器 ( L( k( a& H4 W2 o6 |
- $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
/ q5 l6 @; U3 C; V4 g3 Q - }
) }, d) p) v' z2 Q+ D+ |. ] - } 3 v7 |' `) ^- T% h- M- ?! d
- }else{ % ~7 B1 E8 N: I* g, s# C" A9 b
- // 读写操作不区分服务器
4 I* A0 a0 A: X3 ? - $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库 2 s7 E1 L& p5 P; ?( q
- }
复制代码 & y. |+ w# P' F
$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'])) {// 指定服务器读2 C0 H- a0 h% x9 Z6 q" c- v
$r = $this->config['slave_no'];6 G& f Y1 _( C
}else{
: C& Z' e+ x' G) U- ` // 读操作连接从服务器
. J3 E/ t- S0 C7 \7 H5 q- R2 S $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库; n/ j3 {3 N: K- e* F% E8 H( W
} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){
8 Y+ d# w# @0 t/ a3 K! ]2 c - $db_master = array( ( w; `+ X" R/ D$ U, r& a$ Y
- 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0],
" \5 n! G) i z0 b- e) o& f. V7 v- @ - 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0], 5 O* R9 I, a* E$ B$ ]/ k& Y
- 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
6 z8 L3 e% E0 r0 V$ d - 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0],
+ ^: K- \! n2 B. ] - 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0], 3 A ?, d( i+ A. ^& g
- 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0], ; e" {! B& J1 J4 X- m6 `' L
- 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], % s0 r& i$ ~9 ?+ V: P
- ); 8 V; _4 o4 ?5 P3 H
- } 3 V. h2 \/ I/ Y
- $db_config = array(
1 ^2 r0 ~3 L5 R- D - 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0], / P* L% V3 o$ k( ?; V [9 w& R
- 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0],
5 F0 X/ |3 M6 A4 X/ b. u& r - 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0],
5 ?. ]. X" V) D% c8 h7 ^5 K - 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0],
$ {# m) y+ R/ w" Y, M) K2 { - 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0],
# A" _. B! u8 S, A- D - 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], - O. u0 H$ I; O' ?! s
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0], % f% f1 f) x: p* Z/ Z, \1 g
- ); * s7 w' N. J/ b5 C; f4 `
- return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码 / u: `6 Y5 u0 d2 X
看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{ , Y8 Z+ v6 E F) A$ u
- if(empty($config['dsn'])) { 5 E: X) _7 D+ V c5 V- Z v- k
- $config['dsn'] = $this->parseDsn($config);
8 A, p0 K8 s4 x& `( E- R- {3 D, T! D5 K - }
% \1 N. q$ T U( _( j - if(version_compare(PHP_VERSION,'5.3.6','<=')){ 6 {* t4 y) g- f0 W- s
- // 禁用模拟预处理语句 ( Y1 R1 Y7 a# T( S* K. ?
- $this->options[PDO::ATTR_EMULATE_PREPARES] = false;
1 i }; N+ z7 C0 r; w - } 0 i! @8 s! Q; m' I4 {& O
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
) H h! [' }6 B& B/ ~4 Y7 O - }catch (\PDOException $e) { 1 s: e' t: w: ^& o1 j4 y
- if($autoConnection){ //$autoConnection不为false,而是默认的主服务器 8 H) r6 z! C1 r& N4 x
- trace($e->getMessage(),'','ERR');
0 l0 L9 y8 g7 Y, e2 X2 Q! O, K - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接 4 X( @8 u. U/ k: M+ Y# x
- }elseif($config['debug']){
. e) E+ c s4 h! U - E($e->getMessage()); * H$ e! d0 @8 _/ g) a8 z& [3 f
- } 1 m A' n- c. Y/ s! {$ r* t
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。 7 V! F% B+ \) B. i. T7 C. ]" s( N
/ h6 G' C) F4 X4 V" k' U" R* m0 z1 v3 r* X8 B
6 e* _$ @. ^, v- E6 ?2 f
|