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

本文实例分析了Yii实现MySQL多数据库和读写分离的方法。分享给大家供大家参考。具体分析如下： Yii Framework是一个基于组件、用于开发大型 Web 应用的高性能 PHP 框架。Yii提供了今日Web 2.0应用开发所需要的几乎一切功能，也念腊吵是最强大的框架之一，下文我们来介绍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所对应的数据库名称，附代码 DBConfig.php文件如下： 复制代码 代码如下:<?php return array( 'passport' =>array( 'write' =>array( 'class' =>'CDbConnection', 'connectionString' =>'mysql:host=10.1.39.2dbname=db1′, 'emulatePrepare' =>true, //'enableParamLogging' =>true, 'enableProfiling' =>true, 'username' =>'root', 'password' =>'', 'charset' =>'utf8′, 'schemaCachingDuration'=>3600, ), 'read' =>array( array( 'class' =>'CDbConnection', 'connectionString' =>'mysql:host=10.1.39.3dbname=db1, 'emulatePrepare' =>true, //'enableParamLogging' =>true, 'enableProfiling' =>true, 'username' =>'root', 'password' =>'', 'charset' =>'utf8′, 'schemaCachingDuration'=>3600, ), array( 'class' =>'CDbConnection', 'connectionString' =>'mysql:host=10.1.39.4dbname=db3′, 'emulatePrepare' =>true, //'enableParamLogging' =>true, 'enableProfiling' =>true, 'username' =>'root', 'password' =>'', 'charset' =>'utf8′, 'schemaCachingDuration'=>3600, ), ), ), ) ModelConfig.php如下： 复制代码 代码如下:<?php return array( //key为数据库名称，value为Model 'passport' =>array('User','Post'), 'microblog' =>array('…'), ) ?> ActiveRecord.php如下： 复制代码 代码如下:/** * 基于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程序设计有所帮助。

Mysql主从配置，实现读写分离

原理：主服务器（Master）负责网站仿段NonQuery *** 作，从服务器负责Query *** 作，用户可以根据网站功能模特性块固定访问Slave服务器，或者自己写个池或队列，自由为请求分配从服务器连接。主从服务器利用MySQL的二中大世进制日志文件，实现数据同步。二进制日志由主服务器产生，从服务器响应获取同步数据库。

具体实现：

1、卖肢在主从服务器上都装上MySQL数据库，windows系统鄙人安装的是mysql_5.5.25.msi版本，Ubuntu安装的是mysql-5.6.22-linux-glibc2.5-i686.tar

windows安装mysql就不谈了，一般地球人都应该会。鄙人稍微说一下Ubuntu的MySQL安装，我建议不要在线下载安装，还是离线安装的好。大家可以参考 http://www.linuxidc.com/Linux/2013-01/78716.htm 这位不知道大哥还是姐妹，写的挺好按照这个就能装上。在安装的时候可能会出现几种现象，大家可以参考解决一下：

（1）如果您不是使用root用户登录，建议 su - root 切换到Root用户安装，那就不用老是 sudo 了。

（2）存放解压的mysql 文件夹，文件夹名字最好改成mysql

（3）在./support-files/mysql.server start 启动MySQL的时候，可能会出现一个警告，中文意思是启动服务运行读文件时，忽略了my.cnf文件，那是因为my.cnf的文件权限有问题，mysql会认为该文件有危险不会执行。但是mysql还会启动成功，但如果下面配置从服务器参数修改my.cnf文件的时候，你会发现文件改过了，但是重启服务时，修改过后的配置没有执行，而且您 list一下mysql的文件夹下会发现很多.my.cnf.swp等中间文件。这都是因为MySQL启动时没有读取my.cnf的原因。这时只要将my.cnf的文件权限改成my_new.cnf的权限一样就Ok，命令：chmod 644 my.cnf就Ok

（4）Ubuntu中修改文档内容没有Vim，最好把Vim 装上，apt-get install vim,不然估计会抓狂。

这时候我相信MySQL应该安装上去了。

2、配置Master主服务器

（1）在Master MySQL上创建一个用户‘repl’，并允许其他Slave服务器可以通过远程访问Master，通过该用户读取二进制日志，实现数据同步。

---