ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php
; h3 `& f) y: j W) x6 o, H( u - return array(9 }( U, F# f+ I9 d6 T
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持- u/ G' @5 L4 D- p/ J
- 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离. q' G# e1 w4 B% b# A0 V
- 'DB_TYPE' => 'mysql', // 数据库类型
( x G0 S1 K2 b( \$ C - 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址' f5 ^& j. C8 Q+ Y. K0 D1 d
- 'DB_NAME' => 'kp_account', // 数据库名称
3 I# q* ~, f& w* j+ {/ M - 'DB_USER' => 'root,root,root', // 数据库用户名
; } H {% b5 @7 L2 h - 'DB_PWD' => '', // 数据库密码
4 v* e: P+ d% ?6 V V: E6 i - 'DB_PORT' => '3306,3306,3306', // 数据库端口
" W: m1 p8 s' s( Q t! k - 'DB_PREFIX' => 'acc_', // 数据表前缀
" i+ j/ l" G- K' g9 \7 A - 'DB_MASTER_NUM' => 2- z! c7 g" r$ \/ S5 A9 e' o
- );
复制代码
6 P9 [; I6 S k+ }" i9 ^在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下:
7 t$ d7 ] P/ M& P, l. [- //分布式数据库配置定义
* l9 c8 K; ~/ I8 q; X; k - 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
' ]0 H6 K' J: M% P6 x/ |: K- B4 V) t - 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同
0 ?+ q6 R) n: i8 K0 u5 Z& [" }) o - 'DB_HOST' => '192.168.0.1,192.168.0.2',$ ~. h% f1 ~ Y( H0 ]/ g
- 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个1 y# ]0 N! C* E5 X
- 'DB_USER' => 'user1,user2',1 K. h. J5 B* d+ Y' O1 k+ G
- 'DB_PWD' => 'pwd1,pwd2',. T y' _9 `, k9 y I1 x2 i
- 'DB_PORT' => '3306',
$ u: T9 C0 e9 g% F% h5 z h. ^. a - 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:, \8 v, ?+ S1 ?8 U: O
9 n# f4 I0 `4 V: f. S4 ^/ _1 c" C0 C2 s
[color=rgba(0, 0, 0, 0.87)]和2 y2 C' ^* v; Y3 {3 J) F" Q
[color=rgba(0, 0, 0, 0.87)]等效。, g4 q1 a- p7 T" j# g8 ~$ @
- 'DB_USER'=>'user1',
. N3 l% {9 S& D! F7 F - 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和
( e) Q) x# l6 t$ `# v4 ~- V. F'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',8 l3 A8 D1 }# Z3 j- 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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。 8 K4 ^+ p1 Y! ^# C! x h+ m
[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)],否则会发生主从读写错乱的情况。
: @8 X- c: @! a$ w3 g8 i! u: Y- K! m9 O9 D$ C: l
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。7 E4 V; V: Y/ n( i3 t! k! H6 g
----------------------------------------------------------------------------------------------------------------------------------------------------
3 e R% D' n8 K. ?' W3 d3 U1 m1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。
3 e) b( m2 b* ?9 k8 }% p% V 3.详解 ; u) E6 R4 @# `
一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql',
$ A+ c% v# t, m( ^6 K - 'DB_HOST' => '192.168.5.102', 0 y$ ~) y8 D2 \' i$ \1 z# z
- 'DB_NAME' => 'databasename', / f3 y$ c7 p' C3 I4 x
- 'DB_USER' => 'user', ' F) [+ `. `' T
- 'DB_PWD' => 'password',
$ G _2 F# R8 e* f. n$ a - 'DB_PORT' => '3306', 3 R' ~9 j" |* M& \- L$ Z0 P9 y
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql', 4 \8 [) L0 ^, d4 J- M
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', ! M# T) Y {; u# m( w
- 'DB_NAME' => 'test,test,test',
" Y" ?0 n( O' @6 y Q - 'DB_USER' => 'masteruser,slaveuser,slaveuser',
! I4 a. y$ Z' ~0 k, r9 R - 'DB_PWD' => 'masterpass,slavepass,slavepass',
$ F7 n4 A' j2 ]. d3 _" R - 'DB_PORT' => '3306',
: ^% [* x* E% I8 N7 o - 'DB_PREFIX' => '',
: \ d+ l$ g8 S* u - 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) # o1 S& v/ F# D9 \
- 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效
& U9 ?( i, Z( U5 W - 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量
# m+ h z2 K/ B - 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); % Z4 E) R& F a/ |% k
- $_config['password'] = explode(',',$this->config['password']); . Y4 H b( f9 E6 H( Y
- $_config['hostname'] = explode(',',$this->config['hostname']); 9 N% W7 h; q8 T4 H, b5 U
- $_config['hostport'] = explode(',',$this->config['hostport']); - j9 E6 g& t, b9 T! l
- $_config['database'] = explode(',',$this->config['database']);
A% O: c7 D% Q8 H - $_config['dsn'] = explode(',',$this->config['dsn']);
" @ b: D# M5 H - $_config['charset'] = explode(',',$this->config['charset']);
复制代码 + i# K! T: z- i
‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
) }2 n4 Y' C5 ^, i7 x+ q4 j" J - if(!empty($this->config['deploy'])) * o+ M8 y6 [' Z
- // 采用分布式数据库 * _) \2 o( R1 R" X, w# W; J# O
- $this->_linkID = $this->multiConnect($master); % W, `6 Z; s( k! i; X" j; l* f
- else . U$ V6 T$ X% |' F p
- // 默认单数据库 & A6 l0 i/ a; @" B
- if ( !$this->_linkID ) $this->_linkID = $this->connect();
9 U: U [* N, W3 i2 \2 A - }
复制代码
- v/ w: @! H' u$ W: O9 ~% x8 ^+ M$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']){
1 J5 V' a& v6 H0 K, E- z - // 主从式采用读写分离
/ Y' b3 s, N% l) a6 G- y9 ` - if($master) ) i5 P) g# G% A4 S0 L- a
- // 主服务器写入 $ x& T2 A \5 `5 m0 @: \
- $r = $m;
9 [# p, X+ O6 F* g) D/ U; L - else{
1 a- l7 a! f7 R$ y8 U5 l - if(is_numeric($this->config['slave_no'])) {// 指定服务器读
. `9 U) O$ Q3 [0 ~ - $r = $this->config['slave_no']; d2 z# n4 x, Z" ]
- }else{
( @# G; P3 Q8 S) Z - // 读操作连接从服务器
! S/ J* W+ ]& I - $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
6 z/ B" m, {, a8 m# C - }
; P! P3 f; j. m2 e# `% ~ g, ? - } , J9 t3 B) Q; T4 G% b) W0 z* J
- }else{
. z! o% ` w2 p6 B1 m/ Z - // 读写操作不区分服务器 & M, d7 g$ R) n" l" G
- $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库 $ b$ _+ H- n6 s3 l
- }
复制代码 ( c4 k/ T% O( g3 _: e, W7 W
$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'])) {// 指定服务器读. R( L- f1 o- p: i/ S0 h2 M
$r = $this->config['slave_no'];
- m0 N, D- y$ q9 `- f8 O) I3 |5 i}else{
6 Y( L7 J( L8 ^8 o" }. C // 读操作连接从服务器; r+ ^9 {8 C% z6 s, n
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库% |1 r. U( c; U8 A) v
} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){ 9 h4 o: u, f) _9 k2 \; {2 M
- $db_master = array(
* P9 l2 g* I- d s/ O$ d6 g6 f - 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], * D' {4 _) | y; X
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0],
; b: N' K0 o' ` - 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0], - Q, f! h/ C& f% _1 p
- 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0], ( z$ F# G4 l/ o3 q( K4 Y
- 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0], . U* @: _. [( N: i: x6 y
- 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
( { X. ^) K% E# ^, ^, r8 u - 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0],
: A" k& N: {6 F+ K/ K) u) u- T: j - );
! A+ j8 n1 ^3 ], v7 E- j# a4 Q2 j - } . w' A# t k6 a' A4 k2 w, o- E
- $db_config = array(
& ^. t& O% n3 h0 w9 e5 |/ ~# s* G - 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
3 y" U% p; N- ?( j! @# Z - 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0], + h, v- O5 w0 ]3 j/ W
- 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0], + ~1 c, g+ t; ^! r3 K+ ?. z
- 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0], - ]& ~; ]4 M9 A6 A7 _4 V/ u6 I. U; y
- 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0], 8 G" a4 b, E! g
- 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], 3 M- F0 x" |$ D2 [
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0],
# W* y$ K- O8 Q. M - );
5 f/ k% \( n5 f& O2 U! H% p - return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码
! P d6 n" J! d$ d+ t( m) M a% d看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{ ( h$ h% \: t( `
- if(empty($config['dsn'])) { * a# q' T: s2 s5 z
- $config['dsn'] = $this->parseDsn($config); - Y* i$ ?, b& C& _
- } ( M5 D J6 {5 M% X6 i# F* [1 j
- if(version_compare(PHP_VERSION,'5.3.6','<=')){ - [ a5 Y' | a E
- // 禁用模拟预处理语句
* a; L/ v; r) `! v - $this->options[PDO::ATTR_EMULATE_PREPARES] = false; : I$ H. L& u% I [! p8 H
- }
1 M( C! w6 H& A9 [ - $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options); 0 o& C( m+ t, ^4 H6 X
- }catch (\PDOException $e) {
, b6 J; l( U C; C' L, _/ N$ K - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器 2 ^4 E2 }( R7 X$ B- n( C# A, Q- W
- trace($e->getMessage(),'','ERR');
7 e9 c7 N+ L- S, Q* Z0 q" l. Z9 ~ - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接
2 U8 H9 a1 C. O, r2 T - }elseif($config['debug']){ 2 x8 {1 C2 \5 K2 p
- E($e->getMessage());
: W! F. f A4 l8 W7 |( U; \ - } % _& j& a5 v% x) k
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。 ! E, K1 e- _2 N1 G
3 W% W3 u" r) E% T+ E5 y1 A
" Z1 p! J: f" v; p2 V1 F# s% _
|