thinkphp框架实现mysql读写分离
时间:2019-01-14 22:34 来源:未知 作者:IT
基于thinkphp3.2.3,官方手册:http://www.kancloud.cn/manual/thinkphp/1733
注意事项:
1、首先得配置好mysql主从,可以多主多从
2、在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了DB_MASTER_NUM参数,则可以支持多个主服务器写入。其它的都是从数据库的配置信息,负责读取数据,数量不限制。每次连接从服务器并且进行读取操作的时候,系统会随机进行在从服务器中选择
3、调用模型的CURD操作的话,系统会自动判断当前执行的方法的读操作还是写操作,如果你用的是原生SQL,那么需要注意系统的默认规则: 写操作必须用模型的execute方法,读操作必须用模型的query方法,否则会发生主从读写错乱的情况
config.php
<?php
return array(
//'配置项'=>'配置值'
'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
'DB_TYPE' => 'mysql', //分布式数据库类型必须相同
'DB_HOST' => '192.168.20.195,192.168.20.201',
'DB_NAME' => 'hadoop', //如果相同可以不用定义多个
'DB_USER' => 'open,open',
'DB_PWD' => '123456,123456',
'DB_PORT' => '3306',
'DB_PREFIX' => '',
);
IndexController.class.php
<?php
namespace Home\Controller;
use Think\Controller;
class IndexController extends Controller {
//查询 从库
public function index(){
$obj=M("user");
$data=$obj->select();
print_r($data);exit;
}
//写入 主库
public function add() {
$obj=M("user");
$data["name"]="777";
if ($obj->add($data)) {
//$this->success("数据添加成功") ;
}else {
//$this->error("数据添加失败");
}
}
}
测试:
先调用index.php?s=/Home/Index/add 插入数据然后访问index.php打印查询结果,如果要验证是否插入是否走的master库,把配置文件slave数据库密码故意改错看下效果,同理查询也是
线上的tp读写分离已经运行挺久了
(责任编辑:IT)
基于thinkphp3.2.3,官方手册:http://www.kancloud.cn/manual/thinkphp/1733
注意事项:
1、首先得配置好mysql主从,可以多主多从
2、在读写分离的情况下,默认第一个数据库配置是主服务器的配置信息,负责写入数据,如果设置了DB_MASTER_NUM参数,则可以支持多个主服务器写入。其它的都是从数据库的配置信息,负责读取数据,数量不限制。每次连接从服务器并且进行读取操作的时候,系统会随机进行在从服务器中选择
3、调用模型的CURD操作的话,系统会自动判断当前执行的方法的读操作还是写操作,如果你用的是原生SQL,那么需要注意系统的默认规则: 写操作必须用模型的execute方法,读操作必须用模型的query方法,否则会发生主从读写错乱的情况
config.php
<?php
return array(
//'配置项'=>'配置值'
'DB_DEPLOY_TYPE'=> 1, // 设置分布式数据库支持
'DB_TYPE' => 'mysql', //分布式数据库类型必须相同
'DB_HOST' => '192.168.20.195,192.168.20.201',
'DB_NAME' => 'hadoop', //如果相同可以不用定义多个
'DB_USER' => 'open,open',
'DB_PWD' => '123456,123456',
'DB_PORT' => '3306',
'DB_PREFIX' => '',
);
IndexController.class.php
<?php
namespace Home\Controller;
use Think\Controller;
class IndexController extends Controller {
//查询 从库
public function index(){
$obj=M("user");
$data=$obj->select();
print_r($data);exit;
}
//写入 主库
public function add() {
$obj=M("user");
$data["name"]="777";
if ($obj->add($data)) {
//$this->success("数据添加成功") ;
}else {
//$this->error("数据添加失败");
}
}
}
测试:
先调用index.php?s=/Home/Index/add 插入数据然后访问index.php打印查询结果,如果要验证是否插入是否走的master库,把配置文件slave数据库密码故意改错看下效果,同理查询也是
线上的tp读写分离已经运行挺久了
|