|
ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php
$ w' k# b- x7 @8 t7 U - return array(4 ^7 H5 L6 O& H6 h% U+ }$ \4 o
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
/ S- t9 [% @: r% Q- Q, m- m - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离
) f- ~5 L7 i. z5 V( C* b - 'DB_TYPE' => 'mysql', // 数据库类型* `* z( }7 e- W7 s( r' {2 A
- 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址
9 x+ }3 E4 J& L0 u, O( ^ - 'DB_NAME' => 'kp_account', // 数据库名称
1 ` l- c0 r" F& t8 T - 'DB_USER' => 'root,root,root', // 数据库用户名: j- R O, P7 X% Z, K& H
- 'DB_PWD' => '', // 数据库密码
. x6 t$ X, N0 q! p$ P9 Q2 E# g - 'DB_PORT' => '3306,3306,3306', // 数据库端口
( U- V9 ~ ?9 [8 k8 C M1 L; h - 'DB_PREFIX' => 'acc_', // 数据表前缀
) l# x) d% D0 _/ X - 'DB_MASTER_NUM' => 2
; @8 q" O: ]) H; o - );
复制代码 8 J" E9 o" ]/ x# K' x0 [' Q
在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: ; T: U# }, n- E) f6 F/ x1 ]. N( c1 D# t
- //分布式数据库配置定义' p0 V( I9 K, h! k; c& d1 n
- 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持; v0 s; j, A0 x0 e1 e
- 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同
+ u9 F7 T4 \5 \# n: m5 J/ h" d - 'DB_HOST' => '192.168.0.1,192.168.0.2',/ }8 N9 \+ e: _: R, R
- 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个
# ~' `3 Q0 W* H! U' b" i7 n - 'DB_USER' => 'user1,user2',$ }" C: {) n1 ~. U Q
- 'DB_PWD' => 'pwd1,pwd2',; c1 B0 D! {* p) G3 T$ }- i0 M3 @/ a0 P1 \
- 'DB_PORT' => '3306',/ z6 [6 ]6 v* n, c/ k+ k- q6 e3 R
- 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:* T2 ]9 ?, H% j" g
3 G2 z3 s4 C. A. e[color=rgba(0, 0, 0, 0.87)]和
! A! G# y0 b+ S' @% I8 C5 G[color=rgba(0, 0, 0, 0.87)]等效。2 s7 x9 i& M1 n) y0 `0 c$ \( K
- 'DB_USER'=>'user1', ; c$ O0 R% B; ]$ w4 p+ k- b3 w X
- 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和
! _" P* h% N: h9 U9 e* _'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',1 I1 r: x, G6 j Q# m# c! I( |3 J! u
[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 J. K4 y7 _2 d) p6 e( P. 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)],否则会发生主从读写错乱的情况。% O: I6 u8 O# B# _
" |) n4 F5 V) M* f+ \7 C
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。& T9 m O. E# y# C: v
----------------------------------------------------------------------------------------------------------------------------------------------------& [+ g' K! T# }. g. ^
1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。
. w3 `3 r4 j! T( a7 U) s; [ 3.详解
; H' H# `+ G, f- U5 h* v( W一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql', G4 q" e f! ]6 f
- 'DB_HOST' => '192.168.5.102',
3 c r" k. f( A4 Z# l4 k( k {- X - 'DB_NAME' => 'databasename',
6 V5 ?, m2 b5 }: Q4 j" H7 h3 {' ? - 'DB_USER' => 'user',
6 K- z1 g4 @' a0 @0 H& u Y5 v; u, H - 'DB_PWD' => 'password', * B1 g0 m3 A0 k* F
- 'DB_PORT' => '3306', % r% D1 d5 |" D) h4 Z! A
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql', " g d& y$ ^& D; r5 {
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', 4 w5 f; {1 F3 ?; |
- 'DB_NAME' => 'test,test,test', 3 M3 K) g- d2 x# Q$ E! L( U3 y5 t
- 'DB_USER' => 'masteruser,slaveuser,slaveuser', 3 w. F6 J( y) O# ?: F" E
- 'DB_PWD' => 'masterpass,slavepass,slavepass',
0 x& f1 k' }3 y& G( a$ S. D) g9 x - 'DB_PORT' => '3306',
! ~) W l1 M1 k( g) C - 'DB_PREFIX' => '', 3 ]; P, \, q: T1 d4 s- q# g6 @
- 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
" L% v& g: K( S' E0 L* V - 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效
: b$ X8 L) f* {0 H! x - 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量 - ^9 Z \) M7 ?+ K+ G
- 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); ( }$ X; F7 |- U, G
- $_config['password'] = explode(',',$this->config['password']); U; ^/ y$ D1 O$ m: x1 A6 l
- $_config['hostname'] = explode(',',$this->config['hostname']);
Y' W2 `5 M0 Q. i+ [ - $_config['hostport'] = explode(',',$this->config['hostport']);
. M8 u1 ?& X3 q7 m1 ^ - $_config['database'] = explode(',',$this->config['database']); & ~7 v$ @/ L7 R! e7 \- L. d
- $_config['dsn'] = explode(',',$this->config['dsn']);
e" N: _% T1 w7 H; ^8 p - $_config['charset'] = explode(',',$this->config['charset']);
复制代码
! X5 o3 @6 t) R4 Q‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
, I; i5 T% ]; { - if(!empty($this->config['deploy'])) + |/ N' b) R. M0 s9 h: o4 V
- // 采用分布式数据库
/ i6 Z* C% o, i7 b - $this->_linkID = $this->multiConnect($master);
/ g. A+ k7 r/ I! h - else $ h& n. U }' y2 _" P' H
- // 默认单数据库
a5 M# M3 J6 T7 }" h( b$ ]- a% N - if ( !$this->_linkID ) $this->_linkID = $this->connect(); $ I0 N/ i" F2 u! T h% |8 K- @9 G( w
- }
复制代码
# m9 o% ~) R9 [2 i$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']){ ; ? l4 Z9 t' S: u8 f
- // 主从式采用读写分离
* k+ _( I! Z+ S4 y, B3 J; H - if($master) 6 ?# m. w3 s5 K, |. H6 ~' I1 H
- // 主服务器写入 " Y$ B- t9 @4 q! n+ i6 r2 [
- $r = $m;
. Z4 ^( S3 ^& ?$ r - else{ ; E6 _- H6 ?2 k, N6 J
- if(is_numeric($this->config['slave_no'])) {// 指定服务器读 $ a/ A9 ~. o. T, Q: R/ @+ u
- $r = $this->config['slave_no']; " t) b% b" d* C6 U/ S
- }else{ ) X: t/ Z. S4 l+ C2 v; c6 G
- // 读操作连接从服务器
- u2 g2 z3 h y# k) u - $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
" k' Y3 _* C& V9 t: A. ]/ h2 W - }
; _$ q+ W8 x+ N* U) U* t% s - }
, D) u2 q4 _% u& d+ [, D - }else{ - c0 Y$ }* A" w$ r* |3 u
- // 读写操作不区分服务器 6 r# E1 `% F) ]) D, O
- $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库
& c8 N: R/ N' ?4 u) ?2 H - }
复制代码 ( V2 Z6 ^6 C5 B% L; n" D; {; 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'])) {// 指定服务器读7 Y/ ]# T& E0 T M! B, w F
$r = $this->config['slave_no'];. n( |2 U( k: d( M# t
}else{
2 `1 s9 P6 s0 E+ A: |2 e2 G // 读操作连接从服务器
2 } n. o2 W9 v" y $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
$ q5 A2 q8 C# e- X: \% Q" o% h5 I} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){ & a- o$ |) W, P) M5 Z
- $db_master = array( + ]% A) {3 M3 g/ w
- 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], $ t+ }! [9 |2 \! j) z5 G w4 ?) e
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0], . B( x7 w" B7 p/ M; ^2 s2 p; c
- 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0], a6 Z7 x/ I v( \2 }
- 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0],
/ P, g8 @4 q- g/ F5 p: q* |# f& l - 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0], * h3 ?: G( R: G3 H) G
- 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0], 8 r0 W `0 r3 d; d4 n( j
- 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], 9 b4 ^" J. R( _. o; w& w: J E
- ); 1 S# e( g" Q- G5 z/ J
- }
; \0 z. E* R6 d& i. ^6 Q - $db_config = array( ' \) z8 [: P, ?9 U/ }4 N0 e
- 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0], ; p' v. ^+ F. [! |
- 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0],
0 ^9 V" A$ R8 z* Y3 A( E% v' o - 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0], * u$ B8 E# X) C0 Q: [, o
- 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0],
- E+ u8 \3 k4 l - 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0], * B0 I9 I L0 M' t& r& K
- 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], ! Y+ c+ f! p2 J! ?+ ]4 U8 l8 p
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0],
# l( p# Y5 [4 t - ); 5 L/ o: j4 x1 }& {" y: G
- return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码
/ R; r1 W" F& z7 z5 V看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{ # C! |' }# i% `* d! y) o/ w
- if(empty($config['dsn'])) {
6 Y: [2 v1 ~: l$ N - $config['dsn'] = $this->parseDsn($config);
, T7 v+ S: }+ _1 x1 \ - }
) }3 k6 p% V3 ? - if(version_compare(PHP_VERSION,'5.3.6','<=')){ " [5 k n! v( {) z0 G
- // 禁用模拟预处理语句
( ^( ]( w( V2 i9 E( r+ j9 e - $this->options[PDO::ATTR_EMULATE_PREPARES] = false; 1 A5 K! f0 a) _ M0 v7 \! e2 C
- } + e% f' i- l6 }2 r; |
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
4 S* w/ U6 ^/ Q8 M - }catch (\PDOException $e) { % l, M7 g' ?/ B7 v* d
- if($autoConnection){ //$autoConnection不为false,而是默认的主服务器
& M W/ E$ G0 R" A3 a4 e+ Q - trace($e->getMessage(),'','ERR'); % x6 U) O9 b; N' K, `
- return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接 / v! n- I. H& {" [8 E" x/ ~
- }elseif($config['debug']){ 8 o f, d. ]2 S/ ?7 t& S
- E($e->getMessage()); ) w& `* |( X; I+ g
- } ' n( k% T4 D* h$ L" E. ]( I' j" L
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。 : g/ T+ Y+ ^: ], k& j
% z( S/ ^5 N0 R% K3 M( Z3 D
& r: d4 }( Q3 r( i# d |