ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。 配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下: - <?php
1 P9 l, A- y% L/ c - return array(% y$ |; {8 O9 h4 C
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持
4 g2 T; c$ g+ @7 ?' P! e - 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离5 o+ D1 G5 R) ]" ]! k, C/ E
- 'DB_TYPE' => 'mysql', // 数据库类型( n5 E+ l# Q7 f& ~* b
- 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址
. U, L+ v+ f/ i1 B - 'DB_NAME' => 'kp_account', // 数据库名称0 g3 S! }- t3 R3 Y
- 'DB_USER' => 'root,root,root', // 数据库用户名
$ _# g( T! I) m, P# Z - 'DB_PWD' => '', // 数据库密码 f& q* B# y, w/ s9 V
- 'DB_PORT' => '3306,3306,3306', // 数据库端口
8 y, X# }2 @4 d. | - 'DB_PREFIX' => 'acc_', // 数据表前缀8 h# Z9 ]" o+ E9 @" c$ Z
- 'DB_MASTER_NUM' => 2" }6 {. }$ M: I5 G
- );
复制代码 6 ^3 v( a. A- p+ B2 [9 C4 D1 h. 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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下:
5 ~- b* c; f3 K- //分布式数据库配置定义0 h5 j8 L( u# P* q7 V9 q
- 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
/ h% b, `* v u7 P+ A1 K9 g - 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同0 ~' q: t' M; V- S9 u
- 'DB_HOST' => '192.168.0.1,192.168.0.2',
2 R* x) w8 {/ I" z8 q! ~) F8 { - 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个% r3 R; u3 E; L3 ?
- 'DB_USER' => 'user1,user2',
! b7 p; ^4 b% q/ O - 'DB_PWD' => 'pwd1,pwd2',5 J1 s. y7 n6 u' ^
- 'DB_PORT' => '3306',5 `) s- g1 ^5 B) l
- 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:- q0 p& E% l4 M' C- @
5 j" C, {9 }5 D1 l3 X[color=rgba(0, 0, 0, 0.87)]和! o& j) s5 B8 ^# U5 v0 f# ?
[color=rgba(0, 0, 0, 0.87)]等效。- t. Y. |% j3 t. q% a$ C& x, S# L
- 'DB_USER'=>'user1', * K2 U3 o0 p0 L& |; _
- 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和- E' H8 Y$ s0 w
'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1',' j! `0 _* k: w$ N( i
[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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。 / `% @+ j8 I2 d% {5 L7 I+ N$ 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)],否则会发生主从读写错乱的情况。
7 C) @) {3 A6 \: g6 i7 U4 L1 h" v: u9 a2 M4 I, `4 V: E! o( Y4 o
注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。- k2 h# n( r- J+ a! M& h
----------------------------------------------------------------------------------------------------------------------------------------------------
8 f O: j4 O& l6 c0 ^7 m1.分布式数据库是什么: tp的分布式数据库主要是通过该配置: 'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 2.主从服务器的读写分离是什么: 主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。
2 |2 W, G' o$ C/ r2 F, |! Q" q1 O 3.详解 ' S: `: n, m" G7 u
一、单一数据库的连接 在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。 - 'DB_TYPE' => 'mysql',
8 T, L( m0 v) W( J& F) d, \# @8 L - 'DB_HOST' => '192.168.5.102', 6 @4 @$ k# l/ Q+ x ~* z/ N, W. ~( j
- 'DB_NAME' => 'databasename', & C2 j7 @6 I; _1 `* A
- 'DB_USER' => 'user', ; A: w3 x* S9 Q" z R
- 'DB_PWD' => 'password', 9 A* c& z7 i- G8 X D; R0 X. I
- 'DB_PORT' => '3306', 9 p+ G9 O! }5 |# c. n
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。 二、分布式数据库的连接 单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。 - 'DB_TYPE' => 'mysql', 2 H! ?4 m3 @# Y' b( ]
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103',
: p5 v1 z- w$ }/ g+ q( o# Q5 ^ - 'DB_NAME' => 'test,test,test', 4 y8 u3 ^. Y6 f! U( H
- 'DB_USER' => 'masteruser,slaveuser,slaveuser', * o0 P' G2 E& h( @5 M. A. _* l- a
- 'DB_PWD' => 'masterpass,slavepass,slavepass', $ c1 N$ `( }7 |
- 'DB_PORT' => '3306', 4 Q t& R8 Y7 e; r$ W" q3 d" l
- 'DB_PREFIX' => '', 6 T# W D9 N9 Q$ j4 }9 q% Q$ d
- 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) % w. F) X' }0 O$ R6 ]+ D0 [, g
- 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效
( G/ h. Z) ?4 F& R; N - 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量 + _1 H) N. r) ]6 w G$ o
- 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。 下面我们看下面几个选项 ‘DB_HOST’ 分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。 对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。 对于这些选项的解析的代码如下 - $_config['username'] = explode(',',$this->config['username']);
. `. G( i/ \# S. ?4 A( Q n$ I, o/ l - $_config['password'] = explode(',',$this->config['password']);
( D/ _1 D4 e5 Y" q9 l9 k' S" u - $_config['hostname'] = explode(',',$this->config['hostname']);
- ], e& A. V1 P+ N0 a6 F& w - $_config['hostport'] = explode(',',$this->config['hostport']);
7 b) y$ C8 Z% ]+ _8 ~) v. g3 M& a - $_config['database'] = explode(',',$this->config['database']);
' ~* L* D1 V/ ]8 V7 `$ C4 j s: ` - $_config['dsn'] = explode(',',$this->config['dsn']);
) d' j! @/ l l8 v7 M1 M3 j - $_config['charset'] = explode(',',$this->config['charset']);
复制代码 5 n) C |$ |: o' L% t0 | s
‘DB_DEPLOY_TYPE’=>1 1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。 该选项的实现是在类 Think\Db\Dirver中 - protected function initConnect($master=true) {
$ v9 Z3 L1 L# j- z; `8 O - if(!empty($this->config['deploy']))
4 h3 g4 G- @' J/ n+ s Q" S - // 采用分布式数据库 " E8 M% i) Z5 Y, Q) ~$ R; J& B
- $this->_linkID = $this->multiConnect($master); / c/ i4 X' T* |6 ^2 n. t! b4 \
- else / @& L j$ a/ G! n4 k
- // 默认单数据库 ' o2 C; \3 A# I- g/ U
- if ( !$this->_linkID ) $this->_linkID = $this->connect();
" A& O) ~5 C* J! }% L - }
复制代码 9 O) Q) k) |! D3 _5 {
$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']){ 8 [" O1 J! Z6 T! s. n: ]. U0 W8 j6 N
- // 主从式采用读写分离 $ |& q$ A; [5 R# L% z
- if($master)
+ G# v' P; L8 X8 s: b- P* r! Q - // 主服务器写入
, I' o5 e8 \2 y - $r = $m; & l3 m5 I! _" F- I% ^ O
- else{
0 A3 x4 i! C! T9 z( z - if(is_numeric($this->config['slave_no'])) {// 指定服务器读 7 l! Z3 Z k8 ]* O; ^: ^
- $r = $this->config['slave_no']; 4 U/ q1 A$ Y- F" a
- }else{ ; v# f9 j; A4 E/ j I, G" S! o
- // 读操作连接从服务器
8 l5 B7 r+ T { - $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
; |( T4 ]+ Q7 Q- ?5 [* u1 O - } 8 `' y+ Z% T# a3 |4 p+ j. [
- }
+ u$ f5 T/ E5 q) ?1 u0 B, d. Z - }else{
. D) e. r1 ^* p& E! T+ O [ - // 读写操作不区分服务器
! d3 F1 S5 u/ F$ }. U6 }# [9 G - $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库
% G. m9 W: Q/ Q" m8 {9 s - }
复制代码
/ P" p: O& |2 w' h. S* x6 U- Q' {$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'])) {// 指定服务器读
$ N. m4 ?# M! }: b5 E: |* D $r = $this->config['slave_no'];. }. t; s- N! Z( Y f! X v
}else{
+ t' C8 A1 N" l // 读操作连接从服务器- M: H$ m+ b* c
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
1 d1 V: b$ O% L+ G! Q9 ?# q K} 以上是对每个选项的作用的实现代码进行了一个简单的说明。 下面我们来看其连接的部分 - if($m != $r ){ _$ ~1 T' |5 V- ?; [
- $db_master = array( ; ^; X$ f/ n9 N1 o- [! p
- 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], % ~ m* _1 _( v$ _9 F7 I& Q
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0], , q4 k5 Y- b- q: i) J2 O9 n
- 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
5 C- m! F- ]5 b1 S - 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0], * U& L3 t0 m2 L- u3 X! u4 f: P
- 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0],
2 t* b, b v* W) \$ N8 D6 c - 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
0 g6 d/ f, u# K - 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], ) Z' E3 z1 i9 |) [! ~3 P! a; c
- );
9 @* ]" q& X4 z6 U' a) ~ - }
$ h2 M% y4 w* ~3 x - $db_config = array(
5 L) V; r( L9 S P: l - 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
: [9 z6 h- o) y& E `; ?/ t - 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0],
$ h/ N- I, A5 k- y9 { - 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0], , k- {2 }- e3 V J( H+ G1 S# B
- 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0], / c6 g1 m( r/ i3 T
- 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0],
# c1 ^8 R& z ~ [! {. |* O _/ ^ - 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], 0 K! ?4 o/ B+ g/ V
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0], . D: X8 R; @4 y/ H* G' C5 O
- );
- e5 Q+ h* ?3 U( u( @ - return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码
+ K, c# l, o% @- E5 O, `看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。 现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。 connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。 其核心代码如下 - try{
$ m" m* e' h/ W - if(empty($config['dsn'])) { 5 D, F9 B( X) I& ]; y, @2 w9 S. M, V' f
- $config['dsn'] = $this->parseDsn($config); 7 n8 C- {) N" g5 `( E
- }
# C( y" r+ R1 A/ ?* @5 k - if(version_compare(PHP_VERSION,'5.3.6','<=')){ 9 V: M% S* o. x
- // 禁用模拟预处理语句 ( M1 m% r/ X2 B; k4 g8 ^" O r
- $this->options[PDO::ATTR_EMULATE_PREPARES] = false; 3 A4 F8 O9 O$ F8 Z$ Y# p) Y. ~
- }
+ m" Z: D* `* X& x0 ]& a. g8 E" [/ m$ ^ - $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options); 7 V6 x" q0 D* E" P) v) j3 s
- }catch (\PDOException $e) {
3 K8 o& b( e# h - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器
- g; c- a; ^' v# M5 p - trace($e->getMessage(),'','ERR');
# r# C- c- X' W- a1 e5 s - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接
0 ~. m! a! |3 v* O4 o% Z2 M' F. X - }elseif($config['debug']){
% T# ^% \* l9 O* o; d9 K - E($e->getMessage()); 3 h! u4 I9 _$ o7 \% v4 F. \/ e
- } ; s l6 q1 z$ J* S2 k) f
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。 ) Z- h1 H( N4 S8 H
/ F# x' s$ n. f2 M% R
2 C6 T* `/ _1 } |