QQ登录

只需一步,快速开始

 找回密码
 立即注册

QQ登录

只需一步,快速开始

查看: 2184|回复: 1

[PHP开发] 检验mysql主从备份,读写分离

[复制链接]

174

主题

190

帖子

609

积分

注册会员

Rank: 2

积分
609
发表于 2016-1-3 21:47:51 | 显示全部楼层 |阅读模式

马上注册,结交更多好友,享用更多功能,让你轻松玩转社区。

您需要 登录 才可以下载或查看,没有帐号?立即注册

x
先说背景:mysql的主从部署,读写分离,负载均衡之后;需要简单测试和校验一下,在实践中写了个简单的php脚本和校验过程,mark一下,方便再次部署校验。
数据库部署和实践
数据库在实践中,往往需要进行多机主从备份保证安全,这个毋庸置疑;进行读写分离和负载均衡可以极大的提升mysql的读写性能。作者在实践中采用阿里的ameoba进行了读写分离和负载均衡操作。细节步骤参考小拽文章:mysql主从备份,读写分离和负载均衡实践
那么问题来了,部署完了,校验也需慎重,下面是简单的校验过程。
php简单读写库脚本
上码:能用代码说的,最好不用文字说话!
  1. <?php
  2. /**
  3. * 进行读写分离的校验
  4. * @notice :需要关闭主从备份的情况下进行
  5. * 原理:打开主从,写主库,从库获取数据,校验主从备份;关闭主从写ameoba,校验读写分离和负载
  6. *
  7. * @author: cuixiaohuan
  8. * Date: 15/12/29
  9. * Time: 下午9:10
  10. */

  11. class ReadAndWriteTest {
  12.    
  13.     // ameoba 设定端口,校验读写时,放主库配置
  14.     const IP   ="ip:port";
  15.     const PWD  ="pwd";
  16.     const USER ="user";
  17.     const DB   ="db";

  18.     public function __construct(){
  19.         error_reporting(E_ALL ^ E_DEPRECATED);

  20.         $this->initDb();
  21.         $this->_writeTest();
  22.         $this->_selectTest();
  23.     }


  24.     /**
  25.      * 进行10次读操作
  26.      */
  27.     public function _selectTest(){
  28.         for ($i = 0; $i < 10; $i++) {
  29.             $read_sql = 'select * from test limit 10';
  30.             $g_result = mysql_query($read_sql);
  31.             var_dump($g_result);
  32.             mysql_free_result($g_result);
  33.         }
  34.     }

  35.     /**
  36.      * 进行10次写操作
  37.      */
  38.     public function _writeTest(){
  39.         for ($i = 0; $i < 10; $i++) {
  40.             $id        = uniqid();
  41.             $content   = "pingce" . uniqid();
  42.             $write_sql = 'INSERT INTO `test`(`test`, `test1`) VALUES ("' . $id . '","' . $content . '")';
  43.             $g_result = mysql_query($write_sql);
  44.             var_dump($g_result);
  45.         }
  46.     }

  47.     /**
  48.      * 初始化数据库连接信息 info
  49.      */
  50.     private function initDb()
  51.     {
  52.         $crowd_conn = mysql_pconnect(self::IP, self::USER, self::PWD);
  53.         if (!$crowd_conn) {
  54.             die("Could not connect:" . mysql_error());
  55.         }

  56.         $crowd_db = mysql_select_db(self::DB, $crowd_conn);
  57.     }
  58. }

  59. $rw = new ReadAndWriteTest();
复制代码
主从备份校验
  • 开启slave
  • 调整数据库信息为mysql,主库信息,运行脚本。
  • 查看从库的log,有如下写入操作,说明实时主从备份成功。
    1. 151231 15:36:21 4 Query start slave
    2. 14 Connect Out pingce@10.95.112.120:3666
    3. 15 Query BEGIN
    4. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e5c85","pingce5684d957e5cf2")
    5. 15 Query COMMIT /* implicit, from Xid_log_event */
    6. 15 Query BEGIN
    7. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e7937","pingce5684d957e7982")
    8. 15 Query COMMIT /* implicit, from Xid_log_event */
    9. 15 Query BEGIN
    10. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e8e96","pingce5684d957e8ee4")
    11. 15 Query COMMIT /* implicit, from Xid_log_event */
    12. 15 Query BEGIN
    13. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957ea2c2","pingce5684d957ea2eb")
    14. 15 Query COMMIT /* implicit, from Xid_log_event */
    15. 15 Query BEGIN
    16. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eb565","pingce5684d957eb5b3")
    17. 15 Query COMMIT /* implicit, from Xid_log_event */
    18. 15 Query BEGIN
    19. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957ec7ee","pingce5684d957ec83e")
    20. 15 Query COMMIT /* implicit, from Xid_log_event */
    21. 15 Query BEGIN
    22. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eda2f","pingce5684d957eda78")
    23. 15 Query COMMIT /* implicit, from Xid_log_event */
    24. 15 Query BEGIN
    25. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eeca4","pingce5684d957eecf0")
    26. 15 Query COMMIT /* implicit, from Xid_log_event */
    27. 15 Query BEGIN
    28. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eff16","pingce5684d957eff61")
    29. 15 Query COMMIT /* implicit, from Xid_log_event */
    30. 15 Query BEGIN
    31. 15 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957f121e","pingce5684d957f126d")
    32. 15 Query COMMIT /* implicit, from Xid_log_event */
    复制代码

检验读写分离
  • 读写分离,首先需要关闭从机器上的slave。原因:存在主从的话,无法通过log查看出读写分离操作。
    1. mysql> stop slave;
    2. Query OK, 0 rows affected (0.08 sec)
    复制代码

  • 运行脚本:如下信息标示,运行成功。
    1. [cuixiaohuan TestScript]$ /home/work/lamp/php5/bin/php ReadAndWriteTest.php
    2. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e5c85","pingce5684d957e5cf2")bool(true)
    3. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e7937","pingce5684d957e7982")bool(true)
    4. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e8e96","pingce5684d957e8ee4")bool(true)
    5. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957ea2c2","pingce5684d957ea2eb")bool(true)
    6. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eb565","pingce5684d957eb5b3")bool(true)
    7. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957ec7ee","pingce5684d957ec83e")bool(true)
    8. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eda2f","pingce5684d957eda78")bool(true)
    9. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eeca4","pingce5684d957eecf0")bool(true)
    10. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eff16","pingce5684d957eff61")bool(true)
    11. INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957f121e","pingce5684d957f126d")bool(true)
    12. resource(5) of type (mysql result)
    13. resource(6) of type (mysql result)
    14. resource(7) of type (mysql result)
    15. resource(8) of type (mysql result)
    16. resource(9) of type (mysql result)
    17. resource(10) of type (mysql result)
    18. resource(11) of type (mysql result)
    19. resource(12) of type (mysql result)
    20. resource(13) of type (mysql result)
    21. resource(14) of type (mysql result)
    复制代码

  • 查询读写库的log

解释:之所以主库放一个读写库,是因为有些要求超高一致性的数据,备份可能会有延迟;所以,主库承担读写操作,和高负载。
  1. #读写机器log:  进行了10次写和 四次读
  2. 151231 15:29:27 19 Query set names gbk^@
  3. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e5c85","pingce5684d957e5cf2")
  4. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e7937","pingce5684d957e7982")
  5. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957e8e96","pingce5684d957e8ee4")
  6. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957ea2c2","pingce5684d957ea2eb")
  7. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eb565","pingce5684d957eb5b3")
  8. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957ec7ee","pingce5684d957ec83e")
  9. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eda2f","pingce5684d957eda78")
  10. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eeca4","pingce5684d957eecf0")
  11. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957eff16","pingce5684d957eff61")
  12. 19 Query INSERT INTO `test`(`test`, `test1`) VALUES ("5684d957f121e","pingce5684d957f126d")
  13. 19 Query select * from test limit 10
  14. 151231 15:29:28 19 Query select * from test limit 10
  15. 19 Query select * from test limit 10
  16. 19 Query select * from test limit 10
  17. 19 Query select * from test limit 10
复制代码
  • 查看读库的log
    1. # 只进行了读操作,校正了数据库的读写分离操作。
    2. 151231 15:29:20 4 Query stop slave
    3. 151231 15:29:27 3 Query set names gbk^@
    4. 3 Query select * from test limit 10
    5. 3 Query select * from test limit 10
    6. 3 Query select * from test limit 10
    7. 3 Query select * from test limit 10
    8. 3 Query select * from test limit 10
    9. 3 Query select * from test limit 10
    复制代码

最后
一句话:打开slave,校验主从备份;关闭slave,校验读写分离。
【转载请注明:检验mysql主从备份,读写分离| 靠谱崔小拽



2

主题

16

帖子

232

积分

新手上路

Rank: 1

积分
232
发表于 2016-1-5 20:03:36 | 显示全部楼层
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

     
    战略合作|联系方式|广告赞助|商务合作|手机版|小黑屋|( 京ICP备14036609号-6 )

GMT+8, 2017-12-15 19:55

© 2013-2017 Powered by Discuz! X3.3. 本站由 又拍云 提供 CDN 图片存储服务

快速回复 返回顶部 返回列表