ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php) |' u/ Z- a5 o5 g( {% V* M
- return array(
1 ^: Y) @, W S* y2 E0 j! { - 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
) O/ A, z8 t$ _; k, c5 ?& Q - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离
& _; r3 s8 r6 x* {6 M) \ - 'DB_TYPE' => 'mysql', // 数据库类型
" }% L2 U: H* ], v- h* N& b# n - 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址; ?8 `) N+ C* m" f
- 'DB_NAME' => 'kp_account', // 数据库名称
2 S6 M7 l @0 t4 I& ^9 T0 D - 'DB_USER' => 'root,root,root', // 数据库用户名7 Y. c8 F' @ L2 X0 H; }8 l+ ^% |: T
- 'DB_PWD' => '', // 数据库密码8 ~& J5 Z* w8 p1 E
- 'DB_PORT' => '3306,3306,3306', // 数据库端口( a, L) [2 ?- d/ x
- 'DB_PREFIX' => 'acc_', // 数据表前缀
8 ~# b8 L6 f& o% W, Q- U. E - 'DB_MASTER_NUM' => 2" g, X7 x: c/ V( j6 I( _
- );
复制代码
2 C) c2 I1 l4 R; p$ W& l! M- I在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了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 T9 Q2 J) t f- u/ F5 C- //分布式数据库配置定义2 p# Y; |4 u- }/ y2 ^6 z/ `$ e
- 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持: A# Q0 @) q% w9 `! @0 K7 J
- 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同+ ~6 s2 s( }3 {* X
- 'DB_HOST' => '192.168.0.1,192.168.0.2',
$ l0 o# n! y0 @2 K - 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个
- R# ^. u6 t( ]# h3 c - 'DB_USER' => 'user1,user2',' {' _0 t9 f3 A* i% `
- 'DB_PWD' => 'pwd1,pwd2',
% w d' t; k5 b - 'DB_PORT' => '3306',
3 i: l/ ]" a- e$ z' n - 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:+ R4 |, g5 m+ r Y( f3 ~+ P
. l! u# |8 ]% Z6 }6 ~9 S
[color=rgba(0, 0, 0, 0.87)]和( _1 j' A' g$ I1 T: P
[color=rgba(0, 0, 0, 0.87)]等效。4 \! I4 o% i6 ~1 s/ ^) E
- 'DB_USER'=>'user1',
( [- O1 @# y( f- B0 [1 D( { - 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和4 p1 u% h; h( y5 g7 \1 g: ^
'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',, n4 w9 Z! @6 }7 l
[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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。 4 K: ^, V4 |& d& T+ e# 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)],否则会发生主从读写错乱的情况。. o0 \# F! W/ ?0 k# L7 d; A/ u
& U+ S1 q, [6 x* m+ F, L9 u注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。' I* U1 j/ c5 e$ Y5 l
----------------------------------------------------------------------------------------------------------------------------------------------------8 I" j3 u8 X; r' J6 p
1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。
; f( o* x1 b( n+ @( |) M e 3.详解 . Q: f+ ?( O' c o9 G, Y
一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql',
: | q4 W0 H. B# T3 z( f. U" v+ |( V: B - 'DB_HOST' => '192.168.5.102', 3 T0 f7 \ O: D- r
- 'DB_NAME' => 'databasename',
8 n" v" G6 @! z6 Z L2 g* ]' C' i$ ? - 'DB_USER' => 'user',
- d6 |' H+ e, b& ^4 R& L - 'DB_PWD' => 'password', 2 Y3 T4 w, a4 L: Q" s" J5 l
- 'DB_PORT' => '3306',
% z& {' }" ^- o4 H% h1 |( z - 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql', 4 W: V( C8 ?* ~% S
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', ) s# n+ C1 d# g2 O R [9 B
- 'DB_NAME' => 'test,test,test', 7 Y9 e, e5 i! l7 m) e% n
- 'DB_USER' => 'masteruser,slaveuser,slaveuser',
" p9 ^0 [' t8 d) e - 'DB_PWD' => 'masterpass,slavepass,slavepass', ; i( W" f" A) g' q8 M
- 'DB_PORT' => '3306', ( R1 r( y5 @' P, G z' ]
- 'DB_PREFIX' => '', ; h6 U3 o: c' S% k
- 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
5 ^) a- _: l" d( H# B2 P8 K% u - 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效 ( H# C6 i; h/ G- ^
- 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量 M+ l. O3 k$ H1 `: t1 O, |
- 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); * r8 f8 L5 c2 W. U
- $_config['password'] = explode(',',$this->config['password']);
- ^+ y, e5 K- h% J& c - $_config['hostname'] = explode(',',$this->config['hostname']); ( H7 l4 }) I/ m9 c, }
- $_config['hostport'] = explode(',',$this->config['hostport']); 7 i1 g& D8 Z$ a" |
- $_config['database'] = explode(',',$this->config['database']);
7 I; J0 i" _# E8 K+ l; k - $_config['dsn'] = explode(',',$this->config['dsn']); 8 T+ o. o( B+ U E& B0 y5 |9 |
- $_config['charset'] = explode(',',$this->config['charset']);
复制代码
. C |5 \1 b3 [) c& b8 M9 o‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
: y/ K. o; z$ m - if(!empty($this->config['deploy']))
R" K b( J- l$ }2 Y - // 采用分布式数据库
% Y: K3 `/ J% N8 C3 C- T; x - $this->_linkID = $this->multiConnect($master); 4 C& `" @6 D e
- else
2 Y; |- H& S9 g4 Y( j. Q+ T+ D! T) v - // 默认单数据库 / H! O6 Q0 \3 W* m& |2 G8 x% L- }
- if ( !$this->_linkID ) $this->_linkID = $this->connect(); - b* ^" |4 j* l- s0 ]. X
- }
复制代码
6 Q v; c8 [% p8 l2 W$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']){ ' v; [/ g. _3 ~# F; O7 Y
- // 主从式采用读写分离 ! u3 M- m, s5 _ C- ?
- if($master) 7 a- o0 G) C$ z3 d
- // 主服务器写入 4 p& z) N0 }4 }% A/ y o
- $r = $m; 5 \, |! S) K6 }4 h% u
- else{
" `$ q7 b* H! u1 d% w# Y2 k9 z - if(is_numeric($this->config['slave_no'])) {// 指定服务器读
$ x) L6 S6 I' ~2 m) h/ H4 \ - $r = $this->config['slave_no']; : p2 C2 O5 u# H# Y2 i5 N o1 e6 X$ V
- }else{ l, d1 u4 u$ `$ N
- // 读操作连接从服务器 ; G5 o# W7 W! S3 c
- $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
3 Y2 {3 u4 J. K2 G) l - }
9 o$ Y) N$ e/ e, q2 {# p - }
# {2 O( G a. e& R) C% X - }else{
& q# W4 i7 G s6 g - // 读写操作不区分服务器
2 O+ s; j( J, D$ E) j/ e |" I% g - $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库 7 r9 p+ S% V# H. R2 Z
- }
复制代码 . t- L" X" ]' ?( I9 ~( _* k8 D
$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 Y3 z9 }, k% j' v! b $r = $this->config['slave_no'];0 A$ K& S0 k8 U; X( c# a; F
}else{" g0 a W# k, s$ {% P& |
// 读操作连接从服务器
! X) P- _! F- R# L0 h# O% k $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库3 T3 _# V4 P8 I) D- ?( G; s
} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){ 7 Y* ?7 E) _4 m( s0 u. B
- $db_master = array( / a6 u% }! G: j
- 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0],
6 t2 m9 `& V% {3 a- p - 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0], * K; s( L& Z6 H' D$ ^2 ?
- 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
- [" `+ C- Q) r" l0 ~ - 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0], & k5 v& M2 {& I) {
- 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0], ( \7 N* f" d5 z6 f
- 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
/ F( J8 M7 P! {: {8 u - 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0],
% C' Z, @" l" [+ c6 h7 L" V. d8 j - );
5 a! x7 ]3 K/ _4 e1 Q, M - } ' q! e& i8 E' j. d- {8 V6 g' U
- $db_config = array( ' K$ g7 x# S( `2 J
- 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
6 ~; B6 W; O0 f _1 w, p - 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0], 7 {9 T/ {9 H( Q" L5 X
- 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0], ) o: p; \5 A; n3 Y9 I
- 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0],
# r' q! O5 K, w, O5 ^ - 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0],
- \9 ~+ N+ U/ o; Q - 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0],
) M+ `, c7 G* J1 e( j9 {8 D, M+ e - 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0], 9 x1 a1 y/ M. C5 i
- ); 3 H9 h- c7 C. L2 |( y
- return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码 " W/ n/ d- | q
看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{
2 a& [! A, D z. y1 r - if(empty($config['dsn'])) {
! B u7 l/ ~" F5 U* ? - $config['dsn'] = $this->parseDsn($config);
5 s- ^3 S% h$ M- V& l* ?5 } - } ( w! s+ Y( I6 Z8 M3 `# L
- if(version_compare(PHP_VERSION,'5.3.6','<=')){
% O3 @7 Y$ |, x6 A. Z7 o [9 y - // 禁用模拟预处理语句
& r/ X9 O: n# J" { s( o - $this->options[PDO::ATTR_EMULATE_PREPARES] = false; ; N* A4 ^2 m- o
- } 1 o' F' r W+ X7 L' k& R& k* B
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
, G8 z+ y( Q* | - }catch (\PDOException $e) {
4 W$ m2 [$ H: c3 [ v7 H' T - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器 9 E. T! z- q# D t* u
- trace($e->getMessage(),'','ERR');
' `9 }! k( ?' t \ - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接 ; A# C8 q! w1 d
- }elseif($config['debug']){
1 ?) u0 \* G9 ` - E($e->getMessage());
8 G! m% H$ w6 b- m - } . ?/ m. {+ F8 N1 r# ^
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。
6 [& ~0 X1 F% ?0 z" Z1 m
1 O$ |- L! Z \4 K' `7 A, n7 P8 u/ o6 T: e- v0 W
|