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

本文实例分析了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文件如下：复制代码 代码如下:?phpreturn array('passport' = array('write' = array('class' = 'CDbConnection','connectionString' = 'mysql:host=10.1.39.2;dbname=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.3;dbname=db1,'emulatePrepare' = true,//'enableParamLogging' = true,'enableProfiling' = true,'username' = 'root','password' = '','charset' = 'utf8′,'schemaCachingDuration'=3600,),array('class' = 'CDbConnection','connectionString' = 'mysql:host=10.1.39.4;dbname=db3′,'emulatePrepare' = true,//'enableParamLogging' = true,'enableProfiling' = true,'username' = 'root','password' = '','charset' = 'utf8′,'schemaCachingDuration'=3600,),),),);ModelConfig.php如下：复制代码 代码如下:?phpreturn 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];} elsethrow 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];} elsethrow 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程序设计有所帮助。

创新互联公司是一家专业从事做网站、网站制作、网页设计的品牌网络公司。如今是成都地区具影响力的网站设计公司,作为专业的成都网站建设公司,创新互联公司依托强大的技术实力、以及多年的网站运营经验,为您提供专业的成都网站建设、营销型网站建设及网站设计开发服务！

php mysql分布式数据库如何实现

当前做分布式的厂商有几家，我知道比较出名的有“华为云分布式数据库DDM”和“阿里云分布式数据库”，感兴趣可以自行搜素了解下。

分布式数据库的几点概念可以了解一下。

数据分库：

以表为单位，把原有数据库切分成多个数据库。切分后不同的表存储在不同的数据库上。

以表中的数据行记录为单位，把原有逻辑数据库切分成多个物理数据库分片，表数据记录分布存储在各个分片上。

路由分发：

在分布式数据库中，路由的作用即将SQL语句进行解析，并转发到正确的分片上，保证SQL执行后得到正确的结果，并且节约QPS资源。

读写分离：

数据库中对计算和缓存资源消耗较多的往往是密集或复杂的SQL查询。当系统资源被查询语句消耗，反过来会影响数据写入操作，进而导致数据库整体性能下降，响应缓慢。因此，当数据库CPU和内存资源占用居高不下，且读写比例较高时，可以为数据库添加只读数据库。

php手把手教你做网站（二十九）thinkphp6部署多个数据库

前边介绍了负载均衡，mysql同步，接下来介绍tp6分布式部署多个数据库，实现读写分离。

tp6的分布式部署读和写仍然是一个系统，这里我们分开操作，给用户展示的就是从数据库，后端添加文章就是主库，然后同步到从库。

1、配置数据库链接参数

目标：实现随机使用数据库展示信息，只是读操作。

测试：前台可以读取表中内容（存放的不一致），查看是否是随机显示的。

打开.env文件进行编辑

说明：

2、编辑database.php

找到deploy设置为1分布式部署，下边不要改，都是读，写入的也就是后端的我们单独建站连接主库。

配置完成，tp6使用的是mt_rand取随机数判断使用哪个数据库。

3、数据库交互写操作

比如浏览量没必要每次都去更新数据库，可以先使用redis缓存，存够1000的整数倍，再去更新数据库。

4、后台独立，也就是写

可以前后端分离，单独做一个网站（没有前端）使用ip访问或者独立的域名连接后台。

5、上传附件（jquery ajax跨域上传）

使用了nginx负载均衡，肯定是多个一样的网站，如果图片存放到一个站，别的就不能访问了，可以单独设置一个附件（压缩包，图片等）服务器，可以使用二级域名连接，这就要求我们上传附件的时候，是上传到附件服务器。

jqueryURL

API控制器apdpic方法

说明：

也可以先传到后台服务器然后使用（php）ftp上传，或者是通过curl上传到附件服务器，感觉那样毕竟麻烦，直接设置跨域会比较简单。

也测试了使用jsonp跨域，但是不能上传附件。

6、thinkphp6实现读写分离（在一个站点）

我个人是不喜欢这样的，负载均衡应该是均衡地读，也就是前台单独一个站点，后端的写是另一个独立的站点，看个人喜好吧。

独立后台的优点：可以提升安全性，因为我们的后台网址是不公开的，避免用户猜测一些后台的信息。

.env配置按照1所述编辑，默认第一个是主库。

database.php

愿大家在新的一年心想事成，万事如意！！！

mysql 如何实现读写分离，用mysql-proxy 或者直接用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安装，我建议不要在线下载安装，还是离线安装的好。大家可以参考 这位不知道大哥还是姐妹，写的挺好按照这个就能装上。在安装的时候可能会出现几种现象，大家可以参考解决一下：

（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，通过该用户读取二进制日志，实现数据同步。

新闻名称：php数据库读写分离实现 mysql实现读写分离
当前链接：http://chengdu.cdxwcx.cn/article/dodoesi.html