分布式系统中应用程序怎么实现数据库读写分离

本文实例分析了Yii实现MySQL多数据库和读写分离的方法。分享给大家供大家参考。具体分析如下： Yii Framework是一个基于组件、用于开发大型 Web 应用的高性能 PHP 框架。Yii提供了今日Web 20应用开发所需要的几乎一切功能，也是最强大的框架之一，下文我们来介绍Yii实现MySQL多库和读写分离的方法 前段时间为SNS产品做了架构设计，在程序框架方面做了不少相关的压力测试，最终选定了YiiFramework，至于为什么没选用公司内部的 PHP框架，其实理由很充分，公司的框架虽然是"前辈"们辛苦的积累，但毕竟不够成熟，没有大型项目的历练，犹如一个涉世未深的年轻小伙。Yii作为一个 颇有名气开源产品，必定有很多人在使用，意味着有一批人在维护，而且在这之前，我也使用Yii开发过大型项目，Yii的设计模式和它的易扩展特性足以堪当重任。 SNS同一般的社交产品不同的就是它最终要承受大并发和大数据量的考验，架构设计时就要考虑这些问题， web分布式、负载均衡、分布式文件存储、MySQL分布式或读写分离、NoSQL以及各种缓存，这些都是必不可少的应用方案，本文所讲的就是MySQL 分库和主从读写分离在Yii的配置和使用。 Yii默认是不支持读写分离的，我们可以利用Yii的事件驱动模式来实现MySQL的读写分离。 Yii提供了一个强大的CActiveRecord数据库 *** 作类，通过重写getDbConnection方法来实现数据库的切换，然后通过事件 beforeSave、beforeDelete、beforeFind 来实现读写服务器的切换，还需要两个配置文件dbconfig和modelconfig分别配置数据库主从服务器和model所对应的数据库名称，附代码 DBConfigphp文件如下： 复制代码 代码如下:<php return array( 'passport' => array( 'write' => array( 'class' => 'CDbConnection', 'connectionString' => 'mysql:host=101392;dbname=db1′, 'emulatePrepare' => true, //'enableParamLogging' => true, 'enableProfiling' => true, 'username' => 'root', 'password' => '', 'charset' => 'utf8′, 'schemaCachingDuration'=>3600, ), 'read' => array( array( 'class' => 'CDbConnection', 'connectionString' => 'mysql:host=101393;dbname=db1, 'emulatePrepare' => true, //'enableParamLogging' => true, 'enableProfiling' => true, 'username' => 'root', 'password' => '', 'charset' => 'utf8′, 'schemaCachingDuration'=>3600, ), array( 'class' => 'CDbConnection', 'connectionString' => 'mysql:host=101394;dbname=db3′, 'emulatePrepare' => true, //'enableParamLogging' => true, 'enableProfiling' => true, 'username' => 'root', 'password' => '', 'charset' => 'utf8′, 'schemaCachingDuration'=>3600, ), ), ), ); ModelConfigphp如下： 复制代码 代码如下:<php return array( //key为数据库名称，value为Model 'passport' => array('User','Post'), 'microblog' => array('…'), ); > ActiveRecordphp如下： 复制代码 代码如下:/ 基于CActiveRecord类的封装，实现多库和主从读写分离 所有Model都必须继承些类 / class ActiveRecord extends CActiveRecord { //model配置 public $modelConfig = ''; //数据库配置 public $dbConfig = ''; //定义一个多数据库集合 static $dataBase = array(); //当前数据库名称 public $dbName = ''; //定义库类型(读或写) public $dbType = 'read'; //'read' or 'write' / 在原有基础上添加了一个dbname参数 @param string $scenario Model的应用场景 @param string $dbname 数据库名称 / public function __construct($scenario='insert', $dbname = '') { if (!empty($dbname)) $this->dbName = $dbname; parent::__construct($scenario); } / 重写父类的getDbConnection方法 多库和主从都在这里切换 / public function getDbConnection() { //如果指定的数据库对象存在则直接返回 if (self::$dataBase[$this->dbName]!==null) return self::$dataBase[$this->dbName]; if ($this->dbName == 'db'){ self::$dataBase[$this->dbName] = Yii::app()->getDb(); }else{ $this->changeConn($this->dbType); } if(self::$dataBase[$this->dbName] instanceof CDbConnection){ self::$dataBase[$this->dbName]->setActive(true); return self::$dataBase[$this->dbName]; } else throw new CDbException(Yii::t('yii','Model requires a "db" CDbConnection application component')); } / 获取配置文件 @param unknown_type $type @param unknown_type $key / private function getConfig($type="modelConfig",$key="){ $config = Yii::app()->params[$type]; if($key) $config = $config[$key]; return $config; } / 获取数据库名称 / private function getDbName(){ if($this->dbName) return $this->dbName; $modelName = get_class($this->model()); $this->modelConfig = $this->getConfig('modelConfig'); //获取model所对应的数据库名 if($this->modelConfig)foreach($this->modelConfig as $key=>$val){ if(in_array($modelName,$val)){ $dbName = $key; break; } } return $dbName; } / 切换数据库连接 @param unknown_type $dbtype / protected function changeConn($dbtype = 'read'){ if($this->dbType == $dbtype && self::$dataBase[$this->dbName] !== null) return self::$dataBase[$this->dbName]; $this->dbName = $this->getDbName(); if(Yii::app()->getComponent($this->dbName'_'$dbtype) !== null){ self::$dataBase[$this->dbName] = Yii::app()->getComponent($this->dbName'_'$dbtype); return self::$dataBase[$this->dbName]; } $this->dbConfig = $this->getConfig('dbConfig',$this->dbName); //跟据类型取对应的配置(从库是随机值) if($dbtype == 'write'){ $config = $this->dbConfig[$dbtype]; }else{ $slavekey = array_rand($this->dbConfig[$dbtype]); $config = $this->dbConfig[$dbtype][$slavekey]; } //将数据库配置加到component中 if($dbComponent = Yii::createComponent($config)){ Yii::app()->setComponent($this->dbName'_'$dbtype,$dbComponent); self::$dataBase[$this->dbName] = Yii::app()->getComponent($this->dbName'_'$dbtype); $this->dbType = $dbtype; return self::$dataBase[$this->dbName]; } else throw new CDbException(Yii::t('yii','Model requires a "changeConn" CDbConnection application component')); } / 保存数据前选择 主 数据库 / protected function beforeSave(){ parent::beforeSave(); $this->changeConn('write'); return true; } / 删除数据前选择 主 数据库 / protected function beforeDelete(){ parent::beforeDelete(); $this->changeConn('write'); return true; } / 读取数据选择 从 数据库 / protected function beforeFind(){ parent::beforeFind(); $this->changeConn('read'); return true; } / 获取master库对象 / public function dbWrite(){ return $this->changeConn('write'); } / 获取slave库对象 / public function dbRead(){ return $this->changeConn('read'); } } 这是我写好的类，放在components文件夹里，然后所有的Model都继承ActiveRecord类就可以实现多库和主从读写分离了，至于如何支持原生的SQL也同时使用读写分离，此类都已经实现。 希望本文所述对大家基于Yii框架的PHP程序设计有所帮助。

1 确保数据是用户输入安全的（safe）

使用rules方法批量设置Model属性为输入安全的

[php] view plaincopy

public function rules() {

return array(

array('username, password, gender,

email, tel', 'safe'),

);

}

2 如果设置了场景（Scenario），确保该场景匹配输入安全的规则

[php] view plaincopy

public function rules() {

array('gender, email, tel', 'safe', 'on'=> 'create,update'),

}

在属性设置前设置一下场景（Scenario），

[php] view plaincopy

$model->setScenario('create');

$model->attributes = $_POST['user'];

1网站中商品一多，肯定需要一键导入功能，有现在成的第三方插件类PHPExcel，可以直接百度搜索进行下载。

2里面所用到的文件夹主要是Classes这个文件夹。

3把Classes文件夹改名为PHPExcel，复制整个文件夹到yii项目中的protected/extensions。

4在定义的方法中需要用到PHPExcel的地方加上这两句代码

/静用Yii自身的自动加载方法，使PHPExcel自带的autoload生效/        Yii::$enableIncludePath=false;

     /引入PHPExcelphp文件/        Yii::import('applicationextensionsPHPExcelPHPExcel', 1);  

5最后附上代码，此代码主要针对低版本的excel起效，对excel2007无效，不过大致步骤相同。

前台显示代码

<html><head><meta >

控制器代码

/     Excel一键导入功能     /

function actionDaoru(){                    /是否表单提交/            if(isset($_POST['submit'])){            /上传excel文件是否成功/          

$this->upload_file('filename');                        /文件路径及名称/            $file=Yii::app()->BasePath"/modules/houtai/data/excels/"$_FILES['filename']['name'];            $this->excelToArray($file);                                }                        $this->renderPartial('Daoru');    }

/     表数据转化为数组 excel 低版本excel，不包括excel2007     /  

function ExcelToArray($file){            /静用Yii自身的自动加载方法，使PHPExcel自带的autoload生效/  

Yii::$enableIncludePath=false;                /引入PHPExcelphp文件/        Yii::import('applicationextensionsPHPExcelPHPExcel', 1);                            //echo $file;                /创建对象,针对Excel2003/        $objReader=PHPExcel_IOFactory::createReader('Excel5');            /此属性不明，貌似设置为flase也可以/      

$objReader->setReadDataOnly(true);            /加载对象路径/        $objPHPExcel=$objReader->load($file);            /获取工作表/        $objWorksheet=$objPHPExcel->getActiveSheet();    //获得当前活动的工作表，即打开默认显示的那张表        //

$objWorksheet=$objPHPExcel->getSheet(0);    //也可以这样获取，读取第一个表,参数0            /得到总行数/      

$highestRow=$objWorksheet->getHighestRow();            /得到总列数/        $highestColumn=$objWorksheet->getHighestColumn();        $highestColumnIndex=PHPExcel_Cell::columnIndexFromString($highestColumn);            /取单元数据进数组/      

$excelData=array();      

for($row=2;$row<=$highestRow;++$row){            for($col=0;$col<=$highestColumnIndex;++$col){              

$excelData[$row][]=$objWorksheet->getCellByColumnAndRow($col,$row)->getValue();            }        }                  

print_r($excelData);        exit;    }

最后显示的页面是这样子的，导入的excel表中的数据以数组形式显示。

以上就是关于分布式系统中应用程序怎么实现数据库读写分离全部的内容，包括:分布式系统中应用程序怎么实现数据库读写分离、yii中如何创建一个表单接受数据,并存到数据库中、在Yii中怎样把excel表格上传到数据库中等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！