cncml手绘网
标题: ThinkPHP配置简单的mysql读写分离 [打印本页]
作者: admin 时间: 2018-8-9 14:04
标题: ThinkPHP配置简单的mysql读写分离
ThinkPHP内置了分布式数据库的支持,包括主从式数据库的读写分离,但是分布式数据库必须是相同的数据库类型。
配置DB_DEPLOY_TYPE 为1 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下:
- <?php% {4 D$ D9 L8 J8 s6 M1 |* I3 N" N
- return array(4 a5 X& z: @! W( g% R4 s" I* l
- 'DB_DEPLOY_TYPE' => 1, // 设置分布式数据库支持2 r5 A- ~: I+ q8 Y4 `
- 'DB_RW_SEPARATE' => true, // 分布式数据库的读写是否分离8 o% q+ q/ ]8 A& A6 ~
- 'DB_TYPE' => 'mysql', // 数据库类型
9 x6 t$ R, K1 G- y6 N - 'DB_HOST' => '192.168.33.110,192.168.33.111,192.168.33.112', // 数据库服务器地址, Y- x' b- d( _1 M" t
- 'DB_NAME' => 'kp_account', // 数据库名称
, G* R. x/ z- e1 b - 'DB_USER' => 'root,root,root', // 数据库用户名+ K. x0 V3 N& D1 p& e" ?
- 'DB_PWD' => '', // 数据库密码; q3 p3 \2 C; b; y! y
- 'DB_PORT' => '3306,3306,3306', // 数据库端口
' `! s6 J N9 X! H# h E6 D/ q - 'DB_PREFIX' => 'acc_', // 数据表前缀
. p- T6 E2 O/ Y5 p: E! u0 @ - 'DB_MASTER_NUM' => 2
. Z: v, ~" Q$ c; J' ? - );
复制代码 & b6 i5 f# r h1 c
在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了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 可以采用分布式数据库支持。如果采用分布式数据库,定义数据库配置信息的方式如下:
; D+ a; a+ V5 e, q5 y: K0 S! A: D
- //分布式数据库配置定义- _: C- C$ q+ p; u
- 'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
, h( N, U( }0 k% \ - 'DB_TYPE' => 'mysql', //分布式数据库类型必须相同1 W/ @2 p, n/ P0 y1 B: K
- 'DB_HOST' => '192.168.0.1,192.168.0.2',
: q2 p" Z2 m& ?. R* c - 'DB_NAME' => 'thinkphp', //如果相同可以不用定义多个
4 F @& t$ K* O - 'DB_USER' => 'user1,user2',
+ }. Y. U6 z- Z3 I8 e& D - 'DB_PWD' => 'pwd1,pwd2',
. f/ a9 L5 s. C: q$ S- c% T% L8 J" h - 'DB_PORT' => '3306',
; }& T' @/ [+ \! U$ O" P - 'DB_PREFIX' => 'think_',
复制代码 [color=rgba(0, 0, 0, 0.87)]连接的数据库个数取决于DB_HOST定义的数量,所以即使是两个相同的IP也需要重复定义,但是其他的参数如果存在相同的可以不用重复定义,例如:8 U1 B, m' o% [
; z: A- o5 d6 I2 M' I2 H[color=rgba(0, 0, 0, 0.87)]和. P0 o* Z; @( v& K6 Y3 x
[color=rgba(0, 0, 0, 0.87)]等效。
h l& v/ X# y( v" _" n0 L! t/ R- 'DB_USER'=>'user1',
J7 S' K! ~+ n% K0 Q( U( k - 'DB_PWD'=>'pwd1',
复制代码 [color=rgba(0, 0, 0, 0.87)]和( N4 g4 s8 o4 r4 f
'DB_USER'=>'user1,user1', 'DB_PWD'=>'pwd1,pwd1'," G8 w: R3 [% R4 \+ G
[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版本开始,如果从数据库连接错误,会自动切换到主数据库连接。
I7 a; R# U0 x* f' I# j[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 F7 |: D% o% E; M" E# _4 F
5 h6 H; g" j( D5 R9 V注意:主从数据库的数据同步工作不在框架实现,需要数据库考虑自身的同步或者复制机制。
' q. {0 { N& f; d----------------------------------------------------------------------------------------------------------------------------------------------------
3 {1 {% M) Z3 [, A4 ~0 }1.分布式数据库是什么:
tp的分布式数据库主要是通过该配置:
'DB_DEPLOY_TYPE' => 1,// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
2.主从服务器的读写分离是什么:
主从数据库即为一个主数据库会有对应n个从数据库,而从数据库只能有一个对应的从数据库。主从数据库中写的操作需要使用主数据库,而读操作使用从数据库。主数据库与从数据库始终保持数据一致性。其中保持数据库一致的原理即为当主数据库数据发生变化时,会将操作写入到主数据库日志中,而从数据库会不停的读取主数据库的日志保存到自己的日志系统中,然后进行执行,从而保持了主从数据库一致。* D5 M, Z0 e- Y1 K6 C& d, t
3.详解
- h4 l' ]- P3 v# q0 A2 V% F一、单一数据库的连接
在使用的时候,单一数据库的连接配置非常简单。我们只需要在配置文件中配置一下的信息即可。
- 'DB_TYPE' => 'mysql',
$ d8 r- U* t" ^) o \5 L% {2 }# E - 'DB_HOST' => '192.168.5.102',
8 z, N- P( _) l( ^ - 'DB_NAME' => 'databasename', , H7 @0 E% {. h
- 'DB_USER' => 'user',
& B/ c$ [3 W3 g( {6 f+ W0 D - 'DB_PWD' => 'password', 4 k; k2 \, {9 g0 [
- 'DB_PORT' => '3306', : `* P2 |, a: A* l4 i) S4 C% V( \+ T
- 'DB_PREFIX' => 'onmpw_',
复制代码设置完成以后就可以使用了。默认情况下就是单一的数据库连接。
二、分布式数据库的连接
单一数据库的连接很简单,我们着重分析一下分布式数据库的连接。
- 'DB_TYPE' => 'mysql', 9 z" m0 j6 b1 R1 X$ P
- 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103',
4 u- g8 P7 x- h% l# ? - 'DB_NAME' => 'test,test,test',
" S; {/ Y( G' m! b5 K) u( D- F0 O - 'DB_USER' => 'masteruser,slaveuser,slaveuser',
u2 l# `- c8 E. R' [ - 'DB_PWD' => 'masterpass,slavepass,slavepass',
3 {% R7 y2 f. \+ z. h - 'DB_PORT' => '3306',
7 s: x) j" T# j; ` - 'DB_PREFIX' => '',
9 F7 L9 X8 H6 \1 a3 D8 m% W - 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) % F. x4 g1 w$ c$ T
- 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效 5 T7 g" }. K- ~0 h
- 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量
$ c E9 |! H i2 G- L5 B1 ^ R - 'DB_SLAVE_NO' => '', // 指定从服务器序号
复制代码按照以上配置就可以连接分布式数据库了。
下面我们看下面几个选项
‘DB_HOST’
分布式数据库,有几台服务器就要填写几个服务器地址,每个地址之间用逗号隔开。如果是主从式分布的话,前面的地址要是主数据库的地址。
对于下面的用户名和密码还有监听端口之类的,当然是有几个就写几个。如果各个数据库的用户名和密码都一样的话,可以只写一个。
对于这些选项的解析的代码如下
- $_config['username'] = explode(',',$this->config['username']); ! n7 t* J- C' n, @3 P( W) i- k* d
- $_config['password'] = explode(',',$this->config['password']); : N6 z- G6 e6 a9 K4 h% E
- $_config['hostname'] = explode(',',$this->config['hostname']); ! K4 H/ f7 [$ i; M& R' Y
- $_config['hostport'] = explode(',',$this->config['hostport']);
* T# J- t0 R1 `- F- h7 ^3 q0 n - $_config['database'] = explode(',',$this->config['database']); 5 N+ W5 v* H, i% {9 }
- $_config['dsn'] = explode(',',$this->config['dsn']);
6 H1 L" \8 `% }/ Y7 d+ X - $_config['charset'] = explode(',',$this->config['charset']);
复制代码 3 o2 B6 s: O9 s+ P4 `
‘DB_DEPLOY_TYPE’=>1
1 表示是分布式, 0 表示的是集中式(也就是单一服务器)。
该选项的实现是在类 Think\Db\Dirver中
- protected function initConnect($master=true) {
# q6 k* D3 y5 m+ K/ G - if(!empty($this->config['deploy'])) 8 Q9 b+ t ~7 [- s. Z) Q
- // 采用分布式数据库
+ @; W9 [& W- n - $this->_linkID = $this->multiConnect($master); . v+ V4 V' H. O- e) \) z% O0 F
- else $ T3 }( A0 P9 F6 r
- // 默认单数据库
{# N/ p$ j: K, I; S5 m - if ( !$this->_linkID ) $this->_linkID = $this->connect();
3 z8 ]4 W) G- V& S0 [4 R - }
复制代码 ; K8 L5 k+ k2 G' E0 c0 r+ a
$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']){
" U- p+ {$ X3 K1 p - // 主从式采用读写分离 & I* c! [# _ {( _
- if($master)
) y2 ]7 I" P9 I: a) t( l - // 主服务器写入 : L; i( s6 E# `; K" D Y9 P
- $r = $m; ' U8 m6 ~; m4 [( L1 r
- else{
1 v8 X3 f$ C7 H5 ]4 V - if(is_numeric($this->config['slave_no'])) {// 指定服务器读 " s8 Q& O; b/ |' q7 l: ]1 B
- $r = $this->config['slave_no'];
8 h& @8 S% k9 v/ N - }else{ , \' V$ s( W! H- _( Z- C1 X
- // 读操作连接从服务器 % p/ p$ |7 I/ Y# f: ]/ @- K( w
- $r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库 ) W. ]( P4 W4 g( _& R! _9 R2 y
- } + b. \' E! n2 q" @; ]8 N G, U
- } 7 M/ {( U; O: a0 A
- }else{ , M/ {8 Y k* j9 N0 G) k5 E# E
- // 读写操作不区分服务器 ! b( h) A6 E- C) n/ t
- $r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库
j+ v+ V& c& U& V - }
复制代码
) d1 U, ?- l3 j6 ]: s5 T/ 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'])) {// 指定服务器读0 Z6 i1 ^8 L* A+ D! R3 |
$r = $this->config['slave_no'];, u1 }( r- ^ @7 C$ Q2 K
}else{$ ]; G ] T7 G0 v6 c6 y: ?6 f3 }, |% T
// 读操作连接从服务器7 K* } l, |1 z8 |2 u
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
" n% o+ _- c- k" B2 X}
以上是对每个选项的作用的实现代码进行了一个简单的说明。
下面我们来看其连接的部分
- if($m != $r ){
: N3 W V, d0 T; v - $db_master = array(
: |# h. t# l: a% J/ S" ? - 'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0], % d- O7 F' H5 m, N* p5 x
- 'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0], ; J# w( }7 V8 P9 B& i6 r
- 'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
0 E3 Z- o3 R8 v! C - 'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0],
/ H j! q8 h- C - 'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0], 4 E9 m0 F* r. f; d5 i; W
- 'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0], / T' T7 ]# u& a. u
- 'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0], 2 X `" E' l8 h* `5 Y. h" I0 [1 x
- ); " i. _, @) H3 ^9 E3 |7 u: d
- }
s0 V# {; @* j0 ?) i1 Y7 f5 K - $db_config = array( * H* B! t/ X; W" Z2 m% d
- 'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
: k$ a N; T' r! [ - 'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0], & E* s3 m, j7 _! W2 \% A
- 'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0], 9 G4 g6 R4 D0 W: p' V
- 'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0],
: w" h3 A4 ]3 v* e7 u3 |' r: }9 Q - 'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0], : i! I/ K% L: B& ~7 c
- 'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0], ( n1 }9 k. k6 m V; @" l
- 'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0],
, o! S1 U# V1 d - );
3 o; w3 I: U. G8 d( f; ] - return $this->connect($db_config,$r,$r == $m ? false : $db_master);
复制代码 0 r9 U9 g4 D7 Z) n; l
看到这,我觉得大家应该对上面在介绍各个配置选项的代码的时候其中的$r和$m是什么作用了。
现在我们来看 $r == $m ? false : $db_master ,如果数据库读写不分离的情况下,读写是一台服务器的话 传给connect函数的值为false。或者是如果是主从分离的写的情况下传给connect的值也为false。通过上面代码我们看到,如果$r和$m不相等的情况下,会设置$db_master。其实也就是相当于一台备用的,如果选择的$r服务器出现故障不能连接,将会去连接$db_master。
connect()函数的第三个参数其实是表示当$db_config这台服务器连接故障时是否选择备用的连接。false表示不重连,其它值即表示重新连接。
其核心代码如下
- try{ r/ f* o" B2 j6 S! l
- if(empty($config['dsn'])) {
) @; m6 P# `7 ~- k* S# y& f o R5 V - $config['dsn'] = $this->parseDsn($config);
% U0 f% v) h+ o1 F0 C2 _1 R* \ - }
; I- W5 M6 R- F. R) f E - if(version_compare(PHP_VERSION,'5.3.6','<=')){ # i5 J4 O3 Z) R! E4 D
- // 禁用模拟预处理语句 " r+ a) L: _ [& j
- $this->options[PDO::ATTR_EMULATE_PREPARES] = false; 1 W4 a2 g5 `+ p4 X5 j/ ?. s- U
- } # u D+ |8 A5 _( w
- $this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options); * n8 a; o3 s7 d; j+ h% G
- }catch (\PDOException $e) {
3 ^2 o2 c6 u. q4 x5 n- U: k - if($autoConnection){ //$autoConnection不为false,而是默认的主服务器 7 t7 d3 e1 k. J; t- p* j! u! j5 r
- trace($e->getMessage(),'','ERR');
9 E- e" v/ `+ P) `+ v - return $this->connect($autoConnection,$linkNum); //出现异常,使用递归函数重新连接
+ j. y) ~" ~& _( @: s3 r. _ - }elseif($config['debug']){ 1 i( Y, [ {7 n/ H
- E($e->getMessage());
# v6 ~( }# B( k# i) P w - } , J, W6 ]6 s9 ~
- }
复制代码这种方式,对于主从式来说,$r和$m肯定不会相同。因此如果说在读取数据的时候,选择的那台从服务器出现故障的话,那主服务器即是备用的,最后会去主服务器读取。能保证数据读取的时效性。
$ {% y3 Y& Z; I% u% b
# x% W. \0 ~7 j8 z3 d( L: a
* t R0 f" y# q! c/ W
欢迎光临 cncml手绘网 (http://bbs.cncml.com/) |
Powered by Discuz! X3.2 |