打印 | 浏览器收藏 | 复制链接 | 收藏主题
phpma
级别: 管理员
UID: 1
精华: 6
发帖: 270
威望: 318 点
金钱: 2820 RMB
贡献值: 0 点
注册时间:2007-05-17
最后登录:2009-01-10
楼主  发表于: 2008-08-09 00:04
只看楼主 | 小 中 大

 分数据库设计：PHP在高访问量服务中的应用{0808,估计对偶日后用到}

这篇文章写得非常的好，估计在不久就会用到……即使用不到、也会增加自己的见识，对自己的思想有所提升……
     
      做PHP应用，多数是单数据库数据查询和更新，顶多也是主从数据库的支持，实现起来相对简单。主从数据库的问题在于，当会话存储在数据库的时候，同步将可能出现问题，也就是说有可能出现会话的中断。所以我想在主从数据库设计上，应该将所有会话相关表进行特殊对待。即：所有的会话数据表都可以更新和查询，当一个用户访问站点的时候，即将此用户绑定到指定数据库，所有会话访问和查询操作都对此数据库进行。会话表不做同步，其他非会话类更新也从主数据库更新。这样做其实也逃脱不了会话更新时候的数据库切换，所以如果不想麻烦，还是将会话存放在文本中进行的好。

　　分数据库设计，将可能从压力性能上会提升几个档次，当然单次执行效率不会比单数据库来的高的，毕竟存在着数据库切换的效率问题。分库以及主从数据库搭配是可以比较好改善数据库并发瓶颈的方案。原则：大数据量，分库；大访问量，主从。很多时候，都是这两者并行(本文不讨论cache)。

　　我想，如果要实现分库以及主从关系，那么数据库服务器数量将是非常可观，在应用程序中随时切换到某一台服务器，将是非常头痛的问题，配置更换，变量名称，是不是会有一大堆呢？如何寻找更好的解决方案将是本文谈论的话题。

　　首先是分库使得数据库颇多的问题。什么情况下分库？或许有些人还搞不明白为什么要分库，我就简要说一下自己的经验猜测。比如一个博客程序，一般设计是将日志存放在一张日志表中。假设是一个多用户博客，那么将会关联一个uid，如果数据量不大，这样设计是没有问题的，但是当日志量巨大，一天有几十万条日志记录录入的时候，而且访问量也比较可观的时候，我想不可能每个用户来访问日志列表，都去从这包含几千万条日志记录的数据表中去找那么几条，效率可见一斑。这个时候就该考虑到分库的问题。如何分？有一个很简单的分表方法，即，根据uid段，将日志记录在各个数据库中，当然，这个分布还是需要根据以往统计结果做出调整的，因为用户日志分布肯定不是均匀的。设置好uid段，然后根据uid索引到指定数据库配置，创建一个数据库对象即可。

copycode
  1. <?php
  2. $configs['db_info']['blog'][0] = array(   
  3.     'db_host' => '192.168.0.1',   
  4.     'db_name' => 'blog',   
  5.     'db_user' => 'root',   
  6.     'db_pass' => '',   
  7. );   
  8. $configs['db_info']['blog'][1] = array(   
  9.     'db_host' => '192.168.0.2',   
  10.     'db_name' => 'blog',   
  11.     'db_user' => 'root',   
  12.     'db_pass' => '',   
  13. );   
  14. $configs['db_info']['blog'][2] = array(   
  15.     'db_host' => '192.168.0.2',   
  16.     'db_name' => 'blog',   
  17.     'db_user' => 'root',   
  18.     'db_pass' => '',   
  19. );   
  20. //... 
  22. ?>
顶端
更多
phpma
级别: 管理员
UID: 1
精华: 6
发帖: 270
威望: 318 点
金钱: 2820 RMB
贡献值: 0 点
注册时间:2007-05-17
最后登录:2009-01-10
1楼  发表于: 2008-08-09 00:13
只看该作者 | 小 中 大
选择哪一台服务器，只需要根据uid做一个简单的匹配就可以了。
　　再谈到的就是主从数据库了。什么情况下使用主从数据库？比如某个名人博客，访问量相当的大，已经没有办法把他的数据再进行拆分了，这个时候就得考虑主从数据库服务器了，使用多台数据库来分流。这样要适用主从和分库，可能上面配置信息得稍微改动一下。

copycode
  2. [$configs['db_info']['blog'][0]['master'] = array(   
  3.     'db_host' => '192.168.0.1',   
  4.     'db_name' => 'blog',   
  5.     'db_user' => 'root',   
  6.     'db_pass' => '',   
  7. );   
  8. $configs['db_info']['blog'][0]['slave'][0] = array(   
  9.     'db_host' => '192.168.0.2',   
  10.     'db_name' => 'blog',   
  11.     'db_user' => 'root',   
  12.     'db_pass' => '',   
  13. );   
  14. $configs['db_info']['blog'][0]['slave'][1] = array(   
  15.     'db_host' => '192.168.0.3',   
  16.     'db_name' => 'blog',   
  17.     'db_user' => 'root',   
  18.     'db_pass' => '',   
  19. );   
  20. $configs['db_info']['blog'][1]['master'] = array(   
  21.     'db_host' => '192.168.0.4',   
  22.     'db_name' => 'blog',   
  23.     'db_user' => 'root',   
  24.     'db_pass' => '',   
  25. );   
  26. $configs['db_info']['blog'][1]['slave'][0] = array(   
  27.     'db_host' => '192.168.0.5',   
  28.     'db_name' => 'blog',   
  29.     'db_user' => 'root',   
  30.     'db_pass' => '',   
  31. );   
  32. $configs['db_info']['blog'][1]['slave'][1] = array(   
  33.     'db_host' => '192.168.0.6',   
  34.     'db_name' => 'blog',   
  35.     'db_user' => 'root',   
  36.     'db_pass' => '',   
  37. );   
  38. $configs['db_info']['session'][0]['master'] = array(   
  39.     'db_host' => '192.168.0.7',   
  40.     'db_name' => 'session',   
  41.     'db_user' => 'root',   
  42.     'db_pass' => '',   
  43. );   
  44. $configs['db_info']['session'][1]['master'] = array(   
  45.     'db_host' => '192.168.0.8',   
  46.     'db_name' => 'session',   
  47.     'db_user' => 'root',   
  48.     'db_pass' => '',   
  49. ); 


写到这里，我想都应该知道如何分表和分配你的数据库了吧，接下去我就来说一下如何轻松的读取这样的配置信息，如何将这些配置融入你的数据库驱动中。首先以单例摸式创建DB类

copycode
  1. <?php   
  2. if (!defined("DB_FETCH_ASSOC")) {   
  3.     define("DB_FETCH_ASSOC", 1);   
  4. }   
  5.  
  6. if (!defined("DB_FETCH_ROW")) {   
  7.     define("DB_FETCH_ROW", 2);   
  8. }   
  9.  
  10. if (!defined("DB_FETCH_ARRAY")) {   
  11.     define("DB_FETCH_ARRAY", 3);   
  12. }   
  13.  
  14. if (!defined("DB_FETCH_DEFAULT")) {   
  15.     define("DB_FETCH_DEFAULT", DB_FETCH_ASSOC);   
  16. }   
  17. class DB {   
  18.     function DB($dsn, $db_key, $p_conn, $fetch_mode) {   
  19.         $this->dsn        = $dsn;   
  20.         $this->db_key    = $db_key;   
  21.         $this->sql        = '';   
  22.         $this->sqls      = array();   
  23.         $this->u_sqls    = array();   
  24.         $this->q_sqls    = array();   
  25.         $this->u_conn    = null;   
  26.         $this->q_conn    = null;   
  27.         $this->p_conn    = $p_conn;   
  28.         $this->fecth_mode = $fetch_mode;   
  29.         $this->query_num  = 0;   
  30.         $this->update_num = 0;   
  31.     }   
  32.  
  33.     function &init(& $dsn, $db_key, $p_conn = false, $fetch_mode = DB_FETCH_DEFAULT) {   
  34.         static $db;   
  35.         $db_key = explode('.', $db_key);   
  36.         $db_key = "['" . implode("']['" , $db_key) . "']";   
  37.         eval('$flag = isset($db' . $db_key . ');');   
  38.         eval("\$db_info = \$dsn['db_info']" . $db_key . ";");   
  39.         if (!$flag) {   
  40.             $obj = new DB($db_info, $db_key, $p_conn, $fetch_mode);   
  41.             eval('$db' . $db_key . ' = $obj;');   
  42.             unset($obj);   
  43.         }   
  44.         return $db;   
  45.     }   
  46. }   
  47. $db = &DB::init($configs, 'blog.0');   
  48. print_r($db);   
  49. ?> 
顶端
更多
phpma
级别: 管理员
UID: 1
精华: 6
发帖: 270
威望: 318 点
金钱: 2820 RMB
贡献值: 0 点
注册时间:2007-05-17
最后登录:2009-01-10
2楼  发表于: 2008-08-09 00:14
只看该作者 | 小 中 大
从上面打印结果可以看出，blog数据库集群的第一组数据库服务器被载入到$this->dsn中了。这个下面就是简单的数据COPY的主从服务器，所以可以使用随机数来指定到某一台服务器。以下是一个简单的随机数实现：

copycode
  1. class DB {   
  2.     //....   
  3.  
  4.     function connectDB($type = "master") {   
  5.         if ($type == "master") {   
  6.             $db_host = $this->dsn["master"]["db_host"];   
  7.             $db_name = $this->dsn["master"]["db_name"];   
  8.             $db_user = $this->dsn["master"]["db_user"];   
  9.             $db_pass = $this->dsn["master"]["db_pass"];   
  10.             $this->u_conn = mysqli_connect($db_host, $db_user, $db_pass);   
  11.             $this->selectDB($db_name, $this->conn);   
  12.             if (!$this->u_conn) {   
  13.                 $message = "Update DataBase Connect False : ($db_host, $db_user, ******) !";   
  14.                 $this->error($message, 0);   
  15.             }   
  16.         } else {   
  17.             if (emptyempty($_COOKIE[$_configs['cookie_prefix'] . 'db_no'])) {   
  18.                 $db_no = array_rand($this->dsn["db_info"]["slave"]);   
  19.             } else {   
  20.                 $db_no = $_COOKIE[$_configs['cookie_prefix'] . 'db_no'];   
  21.             }   
  22.             $db_info = $this->dsn["slave"][$db_no];   
  23.             $db_host = $db_info["db_host"];   
  24.             $db_name = $db_info["db_name"];   
  25.             $db_user = $db_info["db_user"];   
  26.             $db_pass = $db_info["db_pass"];   
  27.             $this->q_conn = mysqli_connect($db_host, $db_user, $db_pass);   
  28.  
  29.             if (!$this->q_conn) {   
  30.                 if (!$this->u_conn) {   
  31.                     $this->connectDB();   
  32.                 }   
  33.                 $this->q_conn = $this->u_conn;   
  34.                 if (!$this->q_conn) {   
  35.                     $message = "Query DataBase Connect False : ($db_host, $db_user, ******) !";   
  36.                     $this->error($message, 0);   
  37.                 }   
  38.             } else {   
  39.                 $this->selectDB($db_name, $this->q_conn);   
  40.             }   
  41.         }   
  42.     }   
  43.  
  44.     function selectDB($db_name, $conn) {   
  45.         if ($db_name != null) {   
  46.             if(! mysqli_select_db($conn, $db_name)) {   
  47.                 $code = mysqli_errno($conn);   
  48.                 $message = mysqli_error($conn);   
  49.                 $this->error($message, $code);   
  50.             }   
  51.             return true;   
  52.         }   
  53.         return false;   
  54.     }   
  55.  
  56.     function query($sql, $limit = 1, $quick = false) {   
  57.         if ($limit != null) {   
  58.             $sql = $sql . " LIMIT " . $limit;   
  59.         }   
  60.         $this->sqls[] = $sql;   
  61.         $this->q_sqls[] = $sql;   
  62.         $this->sql = $sql;   
  63.  
  64.         if (emptyempty($this->q_conn)) {   
  65.             $this->connectDB("slave");   
  66.         }   
  67.         $this->qrs = mysqli_query($this->q_conn, $sql, $quick ? MYSQLI_USE_RESULT : MYSQLI_STORE_RESULT);   
  68.         if (!$this->qrs) {   
  69.             $code = mysqli_errno($this->q_conn);   
  70.             $message = mysqli_error($this->q_conn);   
  71.             $this->error($message, $code);   
  72.         }   
  73.         $this->query_num++;   
  74.         return $this->qrs;   
  75.     }   
  76.  
  77.     function update($sql) {   
  78.         $this->sql = $sql;   
  79.         $this->sqls[] = $this->sql;   
  80.         $this->u_sqls[] = $this->sql;   
  81.         if ($this->u_conn == null) {   
  82.             $this->connectDB("master");   
  83.         }   
  84.  
  85.         $this->urs = mysqli_query($this->u_conn, $sql, MYSQLI_USE_RESULT);   
  86.         $this->update_num++;   
  87.  
  88.         if (!$this->urs) {   
  89.             return false;   
  90.         } else {   
  91.             return true;   
  92.         }   
  93.     }   
  94. } 



至此，基本框架已经出来了，来看看调用方法：

copycode
  1. <?php   
  2. //　连接到第一组会话服务器   
  3. $db = &DB::init($configs, 'session.0');   
  4. //  执行一次查询   
  5. $db['session'][0]->query('SELECT ...');   
  6.  
  7. //  再次连接BLOG服务器   
  8. $db = &DB::init($configs, 'blog.1');   
  9. //  执行一次更新   
  10. $db['blog'][1]->update('UPDATE ...');   
  11.  
  12. //  再次调用会话更新   
  13. $db['session'][0]->update('INSERT ...');   
  14. ?> 
顶端
更多