ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php2 c* d; p7 M1 Q7 l( F+ d) V2 a) d
- return array(4 d3 U$ Z5 i" @: G/ C3 w8 }7 `
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
% x# ^2 t# t5 V) T! ]# Z - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离; O9 C% Q2 B7 H% ~! [; }
- 'DB_TYPE' => 'mysql', // 数据库类型
+ I+ i* m& A4 Q - 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址- f) K7 g, z @0 y
- 'DB_NAME' => 'kp_account', // 数据库名称
3 Q+ J' b9 @* p: [ w - 'DB_USER' => 'root,root,root', // 数据库用户名& Q, j& {* Y$ U, `
- 'DB_PWD' => '', // 数据库密码/ H3 v3 }( b% _
- 'DB_PORT' => '3306,3306,3306', // 数据库端口$ P! W+ f0 A, \1 C M
- 'DB_PREFIX' => 'acc_', // 数据表前缀
/ |2 H: ^) ?9 x3 J9 n- |: l. w - 'DB_MASTER_NUM' => 21 W, o. C0 w/ }6 T, k7 p
- );
复制代码
8 t9 {2 @8 D1 @8 p3 C! X7 f0 m# a- |在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: ' c% W1 r _# c: n5 B1 ?% R* P
- //分布式数据库配置定义
. Z* v3 }$ J | n7 E, N9 F" P. t - 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
/ a) Z5 d/ o6 ] P( O0 a - 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同0 y' i9 \/ D; |: Q! c/ t
- 'DB_HOST' => '192.168.0.1,192.168.0.2',; L- C# d- f" n) Z
- 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个
2 h' M; f# P- } - 'DB_USER' => 'user1,user2',3 _5 u' C- X& s" A1 c+ t
- 'DB_PWD' => 'pwd1,pwd2',
% d( d8 A* E; F& B2 C4 ~ - 'DB_PORT' => '3306',
3 k. I4 {0 V4 J0 U" D6 w - 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:% A/ C" V3 Y. d9 V2 o: a- t
4 g# l. c* Y0 I[color=rgba(0, 0, 0, 0.87)]和
" f$ e' v3 u& f0 t7 z* S9 y2 e% F[color=rgba(0, 0, 0, 0.87)]等效。4 Z" z- m. S$ a
- 'DB_USER'=>'user1', + H% m; c$ ~8 n+ r) _ p$ k+ P
- 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和
% u- f1 }; Z0 w! b7 }9 `0 X'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',
6 U z3 E9 J2 e: I6 u7 @[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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。 ; R- z* S9 j& Q3 Y; [7 w3 h4 t' i
[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)],否则会发生主从读写错乱的情况。1 R7 J" J! e3 K( {
8 C0 T" F3 x' C4 O. h
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。2 t; z6 z5 [/ m* N# Q6 F
----------------------------------------------------------------------------------------------------------------------------------------------------
1 r5 ~- U1 x; O$ `2 F1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。, k& f$ I" h6 [
3.详解 $ v9 F* i" P( o0 R9 L# G# d# N3 E
一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql',
- z9 h- q6 i3 j; x; H1 L0 c5 A" J" Q - 'DB_HOST' => '192.168.5.102', 1 _; Y. y2 Z1 g* ]0 t
- 'DB_NAME' => 'databasename', / g" K! L2 `" M' q
- 'DB_USER' => 'user',
" b X0 k* [4 A4 R1 x - 'DB_PWD' => 'password',
! q9 y1 R, C5 u! C7 n9 s& H4 K - 'DB_PORT' => '3306', 1 R2 J: Y7 u; g* |2 |
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql',
9 z* U5 v, P( w! K* w& D - 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', 2 b4 j4 ^* N7 C* f9 S/ t
- 'DB_NAME' => 'test,test,test', 2 S; c( t/ b& j9 S3 S
- 'DB_USER' => 'masteruser,slaveuser,slaveuser', ' ^! {; F9 L# O! O" x
- 'DB_PWD' => 'masterpass,slavepass,slavepass',
/ D- B1 l; T8 A0 r7 y - 'DB_PORT' => '3306',
m! C/ Y$ ^3 ]" i- N+ C& z- a - 'DB_PREFIX' => '',
6 t7 X" B. T5 n2 N$ Z8 D& d - 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) * V w% }# O2 ?( F
- 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效 $ F" J7 p% ~( f5 t# r0 E X
- 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量
# ~2 ^% K2 s% j+ H0 E - 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']); 2 x$ X- m! n% I, ^/ C- T% {6 p) c
- $_config['password'] = explode(',',$this->config['password']);
2 Q% J1 ~$ \$ f - $_config['hostname'] = explode(',',$this->config['hostname']);
, I4 d+ ^6 g0 i6 b' h* k+ \ - $_config['hostport'] = explode(',',$this->config['hostport']); * k/ g3 p5 u- u0 x
- $_config['database'] = explode(',',$this->config['database']);
1 X8 b3 C' q6 c+ e* K9 U% ^ - $_config['dsn'] = explode(',',$this->config['dsn']); 1 m' m: k, Z6 o* m* r+ M
- $_config['charset'] = explode(',',$this->config['charset']);
复制代码 5 G$ h" P3 x( p, S- N4 [4 U
‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
: ?+ V+ z- _$ Y; N6 B; h# g - if(!empty($this->config['deploy'])) : c! w, I. d6 {: m
- // 采用分布式数据库
5 [' ^$ [/ G; g - $this->_linkID = $this->multiConnect($master); ( O" Z- b8 Q- Y2 h$ g
- else
7 U* d/ g; k9 X: A - // 默认单数据库
0 P% C2 }6 ]! o+ p& K - if ( !$this->_linkID ) $this->_linkID = $this->connect();
7 I+ T- i1 f+ I1 t - }
复制代码
# I6 x6 ?8 R: o7 x8 u$ P9 ~$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']){
- h: l5 m# O( P1 W: l - // 主从式采用读写分离 , g. \# B) |- i
- if($master)
+ _0 E0 H( @0 K ]" D) ] - // 主服务器写入
! X8 ]( p/ R1 O" [! O8 b - $r = $m;
7 M! q5 D2 x5 K3 z1 N L: N) t - else{ 8 k9 ] K" u% p+ a* \% |" |
- if(is_numeric($this->config['slave_no'])) {// 指定服务器读
' ]6 j. L# K0 ^/ d - $r = $this->config['slave_no'];
2 \1 u3 L4 L; Z o - }else{ 3 n9 N7 |' j0 I3 o$ a9 |. m; R9 ~
- // 读操作连接从服务器 6 O1 j, Y, V% _8 p x6 s
- $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库 7 e8 Z' `+ b$ O2 m
- }
3 i3 B$ H$ q& [. G) K - }
5 C; E7 h3 @6 P# n! v - }else{ ( n h# D! A, d) p
- // 读写操作不区分服务器 1 L3 J' u! a, _ E+ Y8 c7 e4 H% ]
- $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库 9 B" k7 Y8 M. A
- }
复制代码 7 G# `6 n# Z' d; k* u; B
$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'])) {// 指定服务器读
& u( H2 d0 D- c1 \/ _1 q $r = $this->config['slave_no'];
) c* c3 C, i( u}else{
3 T) o4 P7 X- O // 读操作连接从服务器2 U1 G: D7 L& J. h% S5 y( W& b
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
* }0 O. {* [8 n2 x} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){
' g8 h# h3 e/ _+ [+ Q- v- D - $db_master = array(
; z! n( F$ D j5 b) c$ Z - 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], + c0 J% d {! i6 j8 h6 I
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0],
6 t1 e- [. d# {4 E - 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
' ^3 z# r' W% e5 j - 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0],
3 }0 N/ f& o- q' `. C# {5 w6 q1 b - 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0],
! [, [) `7 I: r - 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
' Z i' Q# w2 O) E4 D - 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], ; S7 W& \! L3 H8 M
- ); * I0 t- H$ |, G; Z8 y
- } : q( B6 [6 H1 i. y0 x1 z- V) E
- $db_config = array(
: l6 l/ h9 r1 h - 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0], - E6 N5 |9 L/ p$ t4 n: k
- 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0],
9 m% A/ y8 H" M+ y1 Q8 P - 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0],
+ G$ s2 r& S$ R2 A - 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0], & ?: Y# c; W; F. E
- 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0],
' X& m4 Q5 s# i1 v; _* Z. c - 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], & z' t5 {( V3 A1 r4 `5 K/ B% z
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0],
! _- x1 r1 `' a- H8 `% y/ [ - );
: U1 s* K) m, j* e, c- | - return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码
1 @# a9 O( p' j$ H7 t: G看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{
' G9 }. O( u- A; `+ O5 m2 C4 H - if(empty($config['dsn'])) { 5 U( x b3 d1 N
- $config['dsn'] = $this->parseDsn($config); 4 ? z8 x7 b" ^+ T
- } ( E% [" f. q/ d2 W
- if(version_compare(PHP_VERSION,'5.3.6','<=')){ r+ E7 z o l# H
- // 禁用模拟预处理语句
k+ u5 [9 @$ M - $this->options[PDO::ATTR_EMULATE_PREPARES] = false;
4 u# e# K/ Y- l0 B: ?: N) j( \9 Q - } * b! v6 J: C7 \+ j5 N) j* M
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
1 D) G8 h" ]; v r - }catch (\PDOException $e) {
' L# ]) @6 ]% z! x1 W7 t1 q - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器 : N/ y) W$ ?- c! @+ D
- trace($e->getMessage(),'','ERR');
( Z$ Z8 w( b: g# P" g - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接
2 U6 U# a; L' F' w+ n1 _ - }elseif($config['debug']){ 1 n" Q% v( |/ O( s$ V- p4 [
- E($e->getMessage());
: j2 R! G" d, K# m7 z, U- u - }
+ y' n B- q. s5 q7 n! T" o" Y - }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。
8 g8 H9 N5 X" T! R5 v& d5 Y3 Z; y2 l7 @6 ^ p. R
' U3 E% B& ~; {, S2 t# V4 H1 J7 q |