Phalcon框架和Yaf类似&＃xff0c;是一款用C实现的拓展级别的框架&＃xff0c;不过其功能实现更加丰富&＃xff0c;设计思路基于依赖注入、容器等方式&＃xff0c;更符合现代框架思想。本文主要针对Phalcon框架数据库层的读写分离进行说明&＃xff0c;权当记录。
前提准备
既然需要主从分离&＃xff0c;那么数据库连接至少得有两个&＃xff0c;即将主库和从库分别作为服务注册到di容器&＃xff0c;如下
// app/config/services.php
use Phalcon\Db\Adapter\Pdo\Mysql;
// 设置主库
$di->setShared(&＃39;dbMaster&＃39;, function () {
$params &＃61; [
&＃39;host&＃39; &＃61;> &＃39;127.0.0.1&＃39;,
&＃39;username&＃39; &＃61;> &＃39;root&＃39;,
&＃39;password&＃39; &＃61;> &＃39;root&＃39;,
&＃39;dbname&＃39; &＃61;> &＃39;phalcon_test&＃39;,
&＃39;charset&＃39; &＃61;> &＃39;utf8&＃39;,
&＃39;port&＃39; &＃61;> 3306,
];
return new Mysql($params);
});
// 设置从库 本地测试 和主库用一个mysql实例即可 $di->setShared(&＃39;dbSlave&＃39;, function () { $params &＃61; [ &＃39;host&＃39; &＃61;> &＃39;127.0.0.1&＃39;, &＃39;username&＃39; &＃61;> &＃39;root&＃39;, &＃39;password&＃39; &＃61;> &＃39;root&＃39;, &＃39;dbname&＃39; &＃61;> &＃39;phalcon_test&＃39;, &＃39;charset&＃39; &＃61;> &＃39;utf8&＃39;, &＃39;port&＃39; &＃61;> 3306, ]; return new Mysql($params); });
实现方法一
基于Model初始化时的读写分离设置
Model配置如下&＃xff0c;例子是写在每个Model的initialize方法中&＃xff0c;当然你也可以统一写到BaseModel中&＃xff0c;然后每个Model继承即可。
// app/models/Users.php
use Phalcon\Mvc\Model;
class Users extends Model
{
/**
* 设置Model主从切换
*/
public function initialize()
{
// 写操作 使用dbMaster连接
$this->setWriteConnectionService(&＃39;dbMaster&＃39;);
// 读操作 使用dbSlave连接
$this->setReadConnectionService(&＃39;dbSlave&＃39;);
}
/**
* 表名
*/
public function getSource()
{
return &＃39;table_xxx&＃39;;
}
}
实现方法二
基于modelsManager实现的读写分离
1、首先需要自定义modelsManager实现&＃xff0c;用于替换框架自带的Manager
// app/library/ModelsManager.php
use Phalcon\Mvc\Model\Manager;
class ModelsManager extends Manager
{
/**
* 读操作 返回dbSlave
*
* &＃64;param \Phalcon\Mvc\ModelInterface $model
*
* &＃64;return \Phalcon\Db\Adapter\Pdo\Mysql
*/
public function getReadConnection(\Phalcon\Mvc\ModelInterface $model)
{
return $this->getDI()->get(&＃39;dbSlave&＃39;);
}
/**
* 写操作 返回dbMaster
*
* &＃64;param \Phalcon\Mvc\ModelInterface $model
*
* &＃64;return \Phalcon\Db\Adapter\Pdo\Mysql
*/
public function getWriteConnection(\Phalcon\Mvc\ModelInterface $model)
{
return $this->getDI()->get(&＃39;dbMaster&＃39;);
}
}
2、将自定义modelsManage注册到di容器
// app/config/services.php
use app/library/ModelsManager;
/**
* 设置自定义modelsManager
*/
$di->setShared(
&＃39;modelsManager&＃39;,
new ModelsManager()
);
实现效果
按照上述方法实现后&＃xff0c;你所用到的Phalcon实现的SQL查询均可自动实现主从切换&＃xff0c;包括Query、QueryBuilder、AR、PHQL等。
当然&＃xff0c;如果你某些情境下需要强制指定主库或者从库操作怎么办&＃xff0c;如下即可&＃xff1a;
// di容器
$di &＃61; \Phalcon\Di\FactoryDefault::getDefault();
// 获取主库链接直接操作
$di->get(&＃39;dbMaster&＃39;)->execute(&＃39;update table_xxx set age &＃61; 100 where id &＃61; 1&＃39;);
// 获取从库链接直接操作
$di->get(&＃39;dbSlave&＃39;)->query(&＃39;select * from table_xxx&＃39;);
如何验证
空口无凭&＃xff0c;我怎么知道所有的读操作都发生在了从库上&＃xff0c;所有的写操作都发生在了主库上&＃xff1b;别担心&＃xff0c;每次查询的时候写个日志记录一下不就完了。
需要更改最上面注册dbMaster和dbSlave时的逻辑&＃xff0c;如下&＃xff1a;
// app/config/services.php
use Phalcon\Db\Adapter\Pdo\Mysql;
// 设置主库
$di->setShared(&＃39;dbMaster&＃39;, function () {
$params &＃61; [
&＃39;host&＃39; &＃61;> &＃39;127.0.0.1&＃39;,
&＃39;username&＃39; &＃61;> &＃39;root&＃39;,
&＃39;password&＃39; &＃61;> &＃39;root&＃39;,
&＃39;dbname&＃39; &＃61;> &＃39;phalcon_test&＃39;,
&＃39;charset&＃39; &＃61;> &＃39;utf8&＃39;,
&＃39;port&＃39; &＃61;> 3306,
];
$connection &＃61; new Mysql($params);
// 记录每次sql查询日志
$logger &＃61; new \Phalcon\Logger\Adapter\File(&＃39;/tmp/phalcon_sqls.log&＃39;);
$eventsManager &＃61; new \Phalcon\Events\Manager();
// 注册记录sql的event
$eventsManager->attach(&＃39;db&＃39;, function ($event, $connection) use ($logger) {
($event->getType() &＃61;&＃61; &＃39;beforeQuery&＃39;) && $logger->log(&＃39;Master: &＃39; . $connection->getRealSQLStatement());
});
// 设置事件管理器
$connection->setEventsManager($eventsManager);
return $connection;
});
// 设置从库 本地测试 和主库用一个mysql实例即可
$di->setShared(&＃39;dbSlave&＃39;, function () {
$params &＃61; [
&＃39;host&＃39; &＃61;> &＃39;127.0.0.1&＃39;,
&＃39;username&＃39; &＃61;> &＃39;root&＃39;,
&＃39;password&＃39; &＃61;> &＃39;root&＃39;,
&＃39;dbname&＃39; &＃61;> &＃39;phalcon_test&＃39;,
&＃39;charset&＃39; &＃61;> &＃39;utf8&＃39;,
&＃39;port&＃39; &＃61;> 3306,
];
$connection &＃61; new Mysql($params);
// 记录每次sql查询日志
$logger &＃61; new \Phalcon\Logger\Adapter\File(&＃39;/tmp/phalcon_sqls.log&＃39;);
$eventsManager &＃61; new \Phalcon\Events\Manager();
// 注册记录sql的event
$eventsManager->attach(&＃39;db&＃39;, function ($event, $connection) use ($logger) {
($event->getType() &＃61;&＃61; &＃39;beforeQuery&＃39;) && $logger->log(&＃39;Slave: &＃39; . $connection->getRealSQLStatement());
});
// 设置事件管理器
$connection->setEventsManager($eventsManager);
return $connection;
});
完成之后查看/tmp/phalcon_sqls.log日志&＃xff0c;如下&＃xff0c;即代表成功进行了分离
[Wed, 16 May 18 11:18:43 &＃43;0800][DEBUG] Slave: SELECT &＃96;table_xxx&＃96;.&＃96;id&＃96; FROM &＃96;table_xxx&＃96;
[Wed, 16 May 18 11:18:43 &＃43;0800][DEBUG] Master: UPDATE &＃96;table_xxx&＃96; SET &＃96;name&＃96; &＃61; &＃39;xxx&＃39;
优劣比较
个人觉得两种方法实现各有优劣&＃xff0c;需要结合自己的业务进行选取.
使用方法一时&＃xff0c;可以单独设置每个Model使用的db链接&＃xff0c;适用于多个库中同名表操作的不同情境&＃xff0c;更加灵活。
使用方法二时比较固定&＃xff0c;直接使用Manager返回固定db链接&＃xff0c;不再做其他处理逻辑&＃xff0c;比较死板&＃xff0c;但性能会高于方法一。
建议如果只是为了使用主从切换功能的话&＃xff0c;方法二会更适合&＃xff0c;性能会更高&＃xff0c;毕竟实际业务可能没有那么多切换库的逻辑。
写在最后
上述两种方法可以同时存在&＃xff0c;但优先级是方法二 > 方法一&＃xff0c;即modelsManager的优先级高于Model中定义。本质原因是因为Model中执行SQL查询时&＃xff0c;也会向modelsManager索取db实例&＃xff0c;框架源代码文件如下
// phalcon/mvc/model.zep
/**
* Gets the connection used to read data for the model
*/
public function getReadConnection() ->
{
var transaction;
let transaction &＃61; this->_transaction;
if typeof transaction &＃61;&＃61; "object" {
return transaction->getConnection();
}
return ( this->_modelsManager)->getReadConnection(this);
}
/**
* Gets the connection used to write data to the model
*/
public function getWriteConnection() ->
{
var transaction;
let transaction &＃61; this->_transaction;
if typeof transaction &＃61;&＃61; "object" {
return transaction->getConnection();
}
return ( this->_modelsManager)->getWriteConnection(this);
}
可以看出读写Model进行查询时db实例的获取会通过modelsManager的getReadConnection和getWriteConnection方法实现&＃xff0c;默认情况下Manager会返回Model注册时的实例&＃xff0c;即方法一的实现&＃xff0c;但如果同时使用了方法二&＃xff0c;会直接覆盖原本Manager的实现&＃xff0c;不会再使用Model中注册的逻辑。
来自&＃xff1a;http://www.cnblogs.com/cheng6018/p/9341823.html
京公网安备 11010802041100号